Skip to content

Commit 8371eee

Browse files
authored
Merge pull request #321 from cloudfoundry-community/resolve-event-type-filtration-bug
Fix event-type filtration bug
2 parents 6e84f45 + e37285b commit 8371eee

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

eventrouter/default.go

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,13 @@ func New(appCache cache.Cache, sink eventsink.Sink, config *Config) (Router, err
3232
}
3333

3434
func (r *router) Route(msg *events.Envelope) error {
35+
eventType := msg.GetEventType()
36+
37+
if _, ok := r.selectedEvents[eventType.String()]; !ok {
38+
// Ignore this event since we are not interested
39+
return nil
40+
}
41+
3542
_ = r.sink.Write(msg)
3643

3744
return nil

0 commit comments

Comments
 (0)