|
@@ -42,7 +42,7 @@ func UnSubscribe(messageQueue common.MessageQueue, group string, topic string) e
|
|
|
func Publish(messageQueue common.MessageQueue, topic string, event *common.CloudEvent) error {
|
|
func Publish(messageQueue common.MessageQueue, topic string, event *common.CloudEvent) error {
|