Pünkösd Marcell
ce1aa81dbd
All checks were successful
continuous-integration/drone/push Build is passing
25 lines
830 B
Kotlin
25 lines
830 B
Kotlin
package mq
|
|
|
|
import com.rabbitmq.client.BuiltinExchangeType
|
|
import com.rabbitmq.client.ConnectionFactory
|
|
import config.EnvConfig
|
|
|
|
class ConsumerWrapper {
|
|
private val envConfig = EnvConfig()
|
|
|
|
fun recieve(){
|
|
val factory = ConnectionFactory()
|
|
factory.host = envConfig.mqHost
|
|
factory.username = envConfig.mqUserName
|
|
factory.password = envConfig.mqPassWord
|
|
|
|
val inputConnection = factory.newConnection()
|
|
val inputChannel = inputConnection.createChannel()
|
|
|
|
inputChannel.exchangeDeclare(envConfig.mqExchange, BuiltinExchangeType.DIRECT)
|
|
val inputQueueName = inputChannel.queueDeclare().queue
|
|
inputChannel.queueBind(inputQueueName, envConfig.mqExchange, "meta")
|
|
|
|
inputChannel.basicConsume(inputQueueName, false, DatabaseConsumer(inputChannel))
|
|
}
|
|
} |