diff --git a/server/pkg/messagebus/consumer/eventbus.go b/server/pkg/messagebus/consumer/eventbus.go index a5439e50f..0971b058d 100644 --- a/server/pkg/messagebus/consumer/eventbus.go +++ b/server/pkg/messagebus/consumer/eventbus.go @@ -5,7 +5,6 @@ import ( "github.com/cortezaproject/corteza/server/pkg/eventbus" "github.com/cortezaproject/corteza/server/pkg/messagebus/types" - st "github.com/cortezaproject/corteza/server/system/types" ) type ( @@ -37,10 +36,3 @@ func (cq *EventbusConsumer) Write(ctx context.Context, p []byte) error { cq.dispatcher.Dispatch(ctx, cq.servicer.CreateQueueEvent(cq.queue, p)) return nil } - -func makeEvent(q string, p []byte) *st.QueueMessage { - return &st.QueueMessage{ - Queue: q, - Payload: p, - } -}