renamed isla_exchange to isla_Exchange

islax · Jul 29, 2019 · 562a120 · 562a120
1 parent 6b471a4
commit 562a120
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/event/RabbitMQEventDispatcher.go b/event/RabbitMQEventDispatcher.go
@@ -43,7 +43,7 @@ func NewRabbitMQEventDispatcher(logger *log.Logger) (*RabbitMQEventDispatcher, e
 
 	dispatcher := &RabbitMQEventDispatcher{
 		logger:                 logger,
-		exchangeName:           "isla_Exchange",
+		exchangeName:           "isla_exchange",
 		sendChannel:            sendChannel,
 		retryChannel:           retryChannel,
 		connectionCloseChannel: connectionCloseChannel,

diff --git a/event/monitor/rabbitMQEventMonitor.go b/event/monitor/rabbitMQEventMonitor.go
@@ -62,7 +62,7 @@ func (monitor *rabbitMQEventMonitor) connectToRabbitMQ(queueName string, eventsT
 				monitor.logger.Errorf("Failed to open a channel")
 			} else {
 				err = queueChannel.ExchangeDeclare(
-					"isla_Exchange", // name
+					"isla_exchange", // name
 					"topic",         // type
 					true,            // durable
 					false,           // auto-deleted
@@ -89,7 +89,7 @@ func (monitor *rabbitMQEventMonitor) connectToRabbitMQ(queueName string, eventsT
 							err = queueChannel.QueueBind(
 								q.Name,          // queue name
 								normalizedEvent, // routing key
-								"isla_Exchange", // exchange
+								"isla_exchange", // exchange
 								false,
 								nil)
 							if err != nil {