diff options
| -rw-r--r-- | weed/filer2/filer_notify.go | 18 |
1 files changed, 11 insertions, 7 deletions
diff --git a/weed/filer2/filer_notify.go b/weed/filer2/filer_notify.go index 2ce45db0e..a96d8fe4b 100644 --- a/weed/filer2/filer_notify.go +++ b/weed/filer2/filer_notify.go @@ -15,13 +15,17 @@ func (f *Filer) NotifyUpdateEvent(oldEntry, newEntry *Entry) { return } - msgqueue.Queue.SendMessage( - key, - &filer_pb.EventNotification{ - OldEntry: toProtoEntry(oldEntry), - NewEntry: toProtoEntry(newEntry), - }, - ) + if msgqueue.Queue != nil { + + msgqueue.Queue.SendMessage( + key, + &filer_pb.EventNotification{ + OldEntry: toProtoEntry(oldEntry), + NewEntry: toProtoEntry(newEntry), + }, + ) + + } } |