Chris Lu
4 years ago
committed by
GitHub
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with
4 additions and
0 deletions
-
docker/compose/notification.toml
-
docker/compose/replication.toml
-
weed/replication/sub/notification_gocdk_pub_sub.go
|
|
@ -113,6 +113,10 @@ func (k *GoCDKPubSubInput) Initialize(configuration util.Configuration, prefix s |
|
|
|
func (k *GoCDKPubSubInput) ReceiveMessage() (key string, message *filer_pb.EventNotification, onSuccessFn func(), onFailureFn func(), err error) { |
|
|
|
msg, err := k.sub.Receive(context.Background()) |
|
|
|
if err != nil { |
|
|
|
var conn *amqp.Connection |
|
|
|
if k.sub.As(&conn) && conn.IsClosed() { |
|
|
|
glog.Fatalln(err) |
|
|
|
} |
|
|
|
return |
|
|
|
} |
|
|
|
onFailureFn = func() { |
|
|
|