Home

messaging_rabbitmq / com.hexagonkt.messaging.rabbitmq / RabbitMqClient

RabbitMqClient

class RabbitMqClient :Closeable

Rabbit client.

  • TODO Review if channel handling is still needed in Java 4.1.x version
  • TODO Add metrics
  • TODO Ordered shutdown

Constructors

Name Summary
<init> .RabbitMqClient(uri:URI)
Rabbit client.RabbitMqClient(connectionFactory: ConnectionFactory, poolSize:Int= getRuntime().availableProcessors())

Properties

Name Summary
connected .val connected:Boolean

Functions

Name Summary
bindExchange .fun bindExchange(exchange:String, exchangeType:String, routingKey:String, queue:String):Unit
call fun call(requestQueue:String, message:String):String
close fun close():Unit
consume .fun <T :Any> consume(exchange:String, routingKey:String, type:KClass<T>, handler: (T) ->Unit):Unit
fun <T :Any, R :Any> consume(queueName:String, type:KClass<T>, handler: (T) -> R):Unit
declareQueue .fun declareQueue(name:String):Unit
deleteQueue .fun deleteQueue(name:String):Unit
publish fun publish(queue:String, message:String, correlationId:String? = null):Unit
fun publish(exchange:String, routingKey:String, message:String, correlationId:String? = null):Unit