Skip to content

Commit ad7e71a

Browse files
committed
Don't automatically create eventsink queue and bind it to eventsink exchange.
Let clients do that so that we don't have a queue for the eventsink filling up if there are no consumers.
1 parent be90ae1 commit ad7e71a

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

CHANGELOG.md

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,8 @@ and this project adheres to [Semantic Versioning](http://semver.org/).
1111
Replaced `get()` with `getOrElse()`.
1212
- Consolidated field names sent by the EventSinkService to maximize reuse.
1313
- Changed `EventSinkService` logging to debug to minimize chatter.
14+
- Don't automatically create eventsink queue and bind it to eventsink exchange. Let clients do that so that we don't
15+
have a queue for the eventsink filling up if there are no consumers.
1416

1517
## 1.15.0 - 2021-03-03
1618

app/services/rabbitmq/RabbitMQMessageService.scala

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -233,8 +233,6 @@ class RabbitMQMessageService extends MessageService {
233233
// This probably isn't going to extract queue (use other submit() for that) so make a new broker
234234
val tempChannel = connection.get.createChannel()
235235
tempChannel.exchangeDeclare(exchange, exchange_type, true)
236-
tempChannel.queueDeclare(routing_key, true, false, false, null)
237-
tempChannel.queueBind(routing_key, exchange, routing_key)
238236
tempChannel.basicPublish(exchange, routing_key, null, message.toString.getBytes)
239237
}
240238

0 commit comments

Comments
 (0)