diff --git a/internal/adapters/brokeradapter/brokeradapter.go b/internal/adapters/brokeradapter/brokeradapter.go deleted file mode 100644 index 724836ca611da7406f023d35dd82ce81c2ad46cc..0000000000000000000000000000000000000000 --- a/internal/adapters/brokeradapter/brokeradapter.go +++ /dev/null @@ -1,26 +0,0 @@ -package brokeradapter - -import "github.com/streadway/amqp" - -// A Message describes a standard message queue message within the service -type Message struct { - Headers map[string]interface{} - Body []byte -} - -// An Gateway converts AMQP formats to universal formats -type Gateway struct { -} - -// CreateGateway creates a gateway -func CreateGateway() *Gateway { - return &Gateway{} -} - -// TransformMessage transforms an AMQP delivery into a general format -func (a *Gateway) TransformMessage(msg amqp.Delivery) *Message { - return &Message{ - Headers: (map[string]interface{})(msg.Headers), - Body: msg.Body, - } -} diff --git a/internal/adapters/brokeradapter/interface.go b/internal/adapters/brokeradapter/interface.go deleted file mode 100644 index d67d8a9c09e620525725049aae5faaa85b92aac3..0000000000000000000000000000000000000000 --- a/internal/adapters/brokeradapter/interface.go +++ /dev/null @@ -1,8 +0,0 @@ -package brokeradapter - -import "github.com/streadway/amqp" - -// GatewayInterface is an interface describing a GateWay -type GatewayInterface interface { - TransformMessage(msg amqp.Delivery) *Message -}