diff --git a/connectClient/listener.go b/connectClient/listener.go index 6197d5d64fe9f0622f097474d72ef598d6c3aa2f..d2df3c5327354e19c06a48c82dd0f24e181a5df0 100644 --- a/connectClient/listener.go +++ b/connectClient/listener.go @@ -13,7 +13,7 @@ type listener struct { // Hear will be called whenever a message matching // the RegisterListener call is received -// Message handling logic goes here +// User-defined message handling logic goes here func (l listener) Hear(item receive.Message) { jww.INFO.Printf("Message received: %v", item) } diff --git a/connectClient/main.go b/connectClient/main.go index a4ccd7c890b9a08b873cbaa78584210d03773cff..a2c4571e66250cd3954b2d124cd93f1b64342bb5 100644 --- a/connectClient/main.go +++ b/connectClient/main.go @@ -159,6 +159,7 @@ func main() { // Register a listener for messages-------------------------------------------------- // Listen for all types of messages using catalog.NoType + // User-defined behavior for message reception goes in the listener _, err = handler.RegisterListener(catalog.NoType, listener{ name: "e2e Message Listener", })