From 0346f90a0c05d26ee5a8e7a84534e6ad9ac98270 Mon Sep 17 00:00:00 2001 From: Peter Grlica Date: Mon, 8 Jan 2024 09:28:01 +0100 Subject: [PATCH] Removed deprecated code from messagebus --- server/pkg/messagebus/consumer/eventbus.go | 8 -------- 1 file changed, 8 deletions(-) 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, - } -}