diff options
Diffstat (limited to 'weed/server/filer_server.go')
| -rw-r--r-- | weed/server/filer_server.go | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/weed/server/filer_server.go b/weed/server/filer_server.go index 61ca972cc..c9dabe5cb 100644 --- a/weed/server/filer_server.go +++ b/weed/server/filer_server.go @@ -8,9 +8,12 @@ import ( _ "github.com/chrislusf/seaweedfs/weed/filer2/mysql" _ "github.com/chrislusf/seaweedfs/weed/filer2/postgres" _ "github.com/chrislusf/seaweedfs/weed/filer2/redis" + _ "github.com/chrislusf/seaweedfs/weed/msgqueue/kafka" + _ "github.com/chrislusf/seaweedfs/weed/msgqueue/log" "github.com/chrislusf/seaweedfs/weed/glog" "github.com/chrislusf/seaweedfs/weed/security" "net/http" + "github.com/chrislusf/seaweedfs/weed/msgqueue" ) type FilerOption struct { @@ -23,6 +26,7 @@ type FilerOption struct { SecretKey string DirListingLimit int DataCenter string + EnableNotification bool } type FilerServer struct { @@ -46,6 +50,10 @@ func NewFilerServer(defaultMux, readonlyMux *http.ServeMux, option *FilerOption) fs.filer.LoadConfiguration() + if fs.option.EnableNotification { + msgqueue.LoadConfiguration() + } + defaultMux.HandleFunc("/favicon.ico", faviconHandler) defaultMux.HandleFunc("/", fs.filerHandler) if defaultMux != readonlyMux { |