diff --git a/common/observer/dispatcher/direct_event_dispatcher.go b/common/observer/dispatcher/direct_event_dispatcher.go index 412585b795ca07d8b67e0c2978f7697604b16bd8..b539ef92d5597d3f101bc2c3dbe3a768598ed015 100644 --- a/common/observer/dispatcher/direct_event_dispatcher.go +++ b/common/observer/dispatcher/direct_event_dispatcher.go @@ -38,10 +38,12 @@ type DirectEventDispatcher struct { observer.BaseListenable } +// NewDirectEventDispatcher ac constructor of DirectEventDispatcher func NewDirectEventDispatcher() observer.EventDispatcher { return &DirectEventDispatcher{} } +// Dispatch event directly func (ded *DirectEventDispatcher) Dispatch(event observer.Event) { if event == nil { logger.Warnf("[DirectEventDispatcher] dispatch event nil") diff --git a/common/observer/dispatcher/direct_event_dispatcher_test.go b/common/observer/dispatcher/direct_event_dispatcher_test.go index 557dd1522539d8f7595f0d8227dc736720200f19..355c930a9e86dbe6e82adc2795f8590c15a473c2 100644 --- a/common/observer/dispatcher/direct_event_dispatcher_test.go +++ b/common/observer/dispatcher/direct_event_dispatcher_test.go @@ -19,11 +19,14 @@ package dispatcher import ( "fmt" - "github.com/apache/dubbo-go/common/observer" "reflect" "testing" ) +import ( + "github.com/apache/dubbo-go/common/observer" +) + func TestDirectEventDispatcher_Dispatch(t *testing.T) { ded := NewDirectEventDispatcher() ded.AddEventListener(&TestEventListener{}) diff --git a/common/observer/event_dispatcher.go b/common/observer/event_dispatcher.go index 8b3950480b0f800ef8d3e44bd68e7ff78015b7a2..8513818041b824645d97fbb39f0665d53b8798ae 100644 --- a/common/observer/event_dispatcher.go +++ b/common/observer/event_dispatcher.go @@ -51,7 +51,7 @@ func SetAndInitGlobalDispatcher(name string) { if globalEventDispatcher != nil { logger.Warnf("EventDispatcher already init. It will be replaced") } - if dispatchers[name] == nil { + if dp, ok := dispatchers[name]; !ok || dp == nil { panic("EventDispatcher for " + name + " is not existing, make sure you have import the package.") } globalEventDispatcher = dispatchers[name]()