From 246cfffde26a83c3fb16fe9215fc842db552c37a Mon Sep 17 00:00:00 2001
From: thijsheijden <hi@thijsheijden.nl>
Date: Mon, 17 May 2021 19:10:04 +0200
Subject: [PATCH] Removed unused broker gateway
---
.../adapters/brokeradapter/brokeradapter.go | 26 -------------------
internal/adapters/brokeradapter/interface.go | 8 ------
2 files changed, 34 deletions(-)
delete mode 100644 internal/adapters/brokeradapter/brokeradapter.go
delete mode 100644 internal/adapters/brokeradapter/interface.go
diff --git a/internal/adapters/brokeradapter/brokeradapter.go b/internal/adapters/brokeradapter/brokeradapter.go
deleted file mode 100644
index 724836c..0000000
--- 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 d67d8a9..0000000
--- 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
-}
--
GitLab