This commit is contained in:
parent
13eec03d8e
commit
ce1aa81dbd
@ -16,9 +16,9 @@ class ConsumerWrapper {
|
||||
val inputConnection = factory.newConnection()
|
||||
val inputChannel = inputConnection.createChannel()
|
||||
|
||||
inputChannel.exchangeDeclare(envConfig.mqExchange, BuiltinExchangeType.FANOUT)
|
||||
inputChannel.exchangeDeclare(envConfig.mqExchange, BuiltinExchangeType.DIRECT)
|
||||
val inputQueueName = inputChannel.queueDeclare().queue
|
||||
inputChannel.queueBind(inputQueueName, envConfig.mqExchange, "")
|
||||
inputChannel.queueBind(inputQueueName, envConfig.mqExchange, "meta")
|
||||
|
||||
inputChannel.basicConsume(inputQueueName, false, DatabaseConsumer(inputChannel))
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user