1 files changed, 0 insertions, 47 deletions
diff --git a/plugins/temporal/workflow/message_queue.go b/plugins/temporal/workflow/message_queue.go
deleted file mode 100644
index 8f4409d1..00000000
--- a/plugins/temporal/workflow/message_queue.go
+++ /dev/null
@@ -1,47 +0,0 @@
-package workflow
-
-import (
-	rrt "github.com/spiral/roadrunner/v2/plugins/temporal/protocol"
-	"go.temporal.io/api/common/v1"
-	"go.temporal.io/api/failure/v1"
-)
-
-type messageQueue struct {
-	seqID func() uint64
-	queue []rrt.Message
-}
-
-func newMessageQueue(sedID func() uint64) *messageQueue {
-	return &messageQueue{
-		seqID: sedID,
-		queue: make([]rrt.Message, 0, 5),
-	}
-}
-
-func (mq *messageQueue) flush() {
-	mq.queue = mq.queue[0:0]
-}
-
-func (mq *messageQueue) allocateMessage(cmd interface{}, payloads *common.Payloads) (uint64, rrt.Message) {
-	msg := rrt.Message{
-		ID:       mq.seqID(),
-		Command:  cmd,
-		Payloads: payloads,
-	}
-
-	return msg.ID, msg
-}
-
-func (mq *messageQueue) pushCommand(cmd interface{}, payloads *common.Payloads) uint64 {
-	id, msg := mq.allocateMessage(cmd, payloads)
-	mq.queue = append(mq.queue, msg)
-	return id
-}
-
-func (mq *messageQueue) pushResponse(id uint64, payloads *common.Payloads) {
-	mq.queue = append(mq.queue, rrt.Message{ID: id, Payloads: payloads})
-}
-
-func (mq *messageQueue) pushError(id uint64, failure *failure.Failure) {
-	mq.queue = append(mq.queue, rrt.Message{ID: id, Failure: failure})
-}