Removed deprecated code from messagebus

2024-01-08 09:28:01 +01:00
parent 5be49ecb14
commit 0346f90a0c
1 changed files with 0 additions and 8 deletions
@@ -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,
-	}
-}