class RabbitMQClient extends AnyRef
- Alphabetic
- By Inheritance
- RabbitMQClient
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
- new RabbitMQClient(_asJava: AnyRef)
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
- def asJava: AnyRef
-
def
basicAck(deliveryTag: Long, multiple: Boolean, resultHandler: Handler[AsyncResult[JsonObject]]): Unit
Acknowledge one or several received messages.
Acknowledge one or several received messages. Supply the deliveryTag from the AMQP.Basic.GetOk or AMQP.Basic.Deliver method containing the received message being acknowledged.
-
def
basicAckFuture(deliveryTag: Long, multiple: Boolean): Future[JsonObject]
Like basicAck but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
basicConsume(queue: String, address: String, autoAck: Boolean, resultHandler: Handler[AsyncResult[Unit]]): Unit
Start a non-nolocal, non-exclusive consumer, with a server-generated consumerTag.
-
def
basicConsume(queue: String, address: String, resultHandler: Handler[AsyncResult[Unit]]): Unit
Start a non-nolocal, non-exclusive consumer, with auto acknowledgement and a server-generated consumerTag.
-
def
basicConsumeFuture(queue: String, address: String, autoAck: Boolean): Future[Unit]
Like basicConsume but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
basicConsumeFuture(queue: String, address: String): Future[Unit]
Like basicConsume but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
basicGet(queue: String, autoAck: Boolean, resultHandler: Handler[AsyncResult[JsonObject]]): Unit
Retrieve a message from a queue using AMQP.Basic.Get
-
def
basicGetFuture(queue: String, autoAck: Boolean): Future[JsonObject]
Like basicGet but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
basicNack(deliveryTag: Long, multiple: Boolean, requeue: Boolean, resultHandler: Handler[AsyncResult[JsonObject]]): Unit
Reject one or several received messages.
-
def
basicNackFuture(deliveryTag: Long, multiple: Boolean, requeue: Boolean): Future[JsonObject]
Like basicNack but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
basicPublish(exchange: String, routingKey: String, message: JsonObject, resultHandler: Handler[AsyncResult[Unit]]): Unit
Publish a message.
Publish a message. Publishing to a non-existent exchange will result in a channel-level protocol exception, which closes the channel. Invocations of Channel#basicPublish will eventually block if a resource-driven alarm is in effect.
-
def
basicPublishFuture(exchange: String, routingKey: String, message: JsonObject): Future[Unit]
Like basicPublish but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
basicQos(prefetchCount: Int, resultHandler: Handler[AsyncResult[Unit]]): Unit
Request specific "quality of service" settings, Limiting the number of unacknowledged messages on a channel (or connection).
Request specific "quality of service" settings, Limiting the number of unacknowledged messages on a channel (or connection). This limit is applied separately to each new consumer on the channel.
-
def
basicQosFuture(prefetchCount: Int): Future[Unit]
Like basicQos but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
exchangeBind(destination: String, source: String, routingKey: String, resultHandler: Handler[AsyncResult[Unit]]): Unit
Bind an exchange to an exchange.
-
def
exchangeBindFuture(destination: String, source: String, routingKey: String): Future[Unit]
Like exchangeBind but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
exchangeDeclare(exchange: String, type: String, durable: Boolean, autoDelete: Boolean, config: Map[String, String], resultHandler: Handler[AsyncResult[Unit]]): Unit
Declare an exchange with additional parameters such as dead lettering or an alternate exchnage.
-
def
exchangeDeclare(exchange: String, type: String, durable: Boolean, autoDelete: Boolean, resultHandler: Handler[AsyncResult[Unit]]): Unit
Declare an exchange.
-
def
exchangeDeclareFuture(exchange: String, type: String, durable: Boolean, autoDelete: Boolean, config: Map[String, String]): Future[Unit]
Like exchangeDeclare but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
exchangeDeclareFuture(exchange: String, type: String, durable: Boolean, autoDelete: Boolean): Future[Unit]
Like exchangeDeclare but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
exchangeDelete(exchange: String, resultHandler: Handler[AsyncResult[Unit]]): Unit
Delete an exchange, without regard for whether it is in use or not.
-
def
exchangeDeleteFuture(exchange: String): Future[Unit]
Like exchangeDelete but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
exchangeUnbind(destination: String, source: String, routingKey: String, resultHandler: Handler[AsyncResult[Unit]]): Unit
Unbind an exchange from an exchange.
-
def
exchangeUnbindFuture(destination: String, source: String, routingKey: String): Future[Unit]
Like exchangeUnbind but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
-
def
isConnected(): Boolean
Check if a connection is open
Check if a connection is open
- returns
true when the connection is open, false otherwise
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
isOpenChannel(): Boolean
Check if a channel is open
Check if a channel is open
- returns
true when the connection is open, false otherwise
-
def
messageCount(queue: String, resultHandler: Handler[AsyncResult[JsonObject]]): Unit
Returns the number of messages in a queue ready to be delivered.
-
def
messageCountFuture(queue: String): Future[JsonObject]
Like messageCount but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
-
def
queueBind(queue: String, exchange: String, routingKey: String, resultHandler: Handler[AsyncResult[Unit]]): Unit
Bind a queue to an exchange
-
def
queueBindFuture(queue: String, exchange: String, routingKey: String): Future[Unit]
Like queueBind but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
queueDeclare(queue: String, durable: Boolean, exclusive: Boolean, autoDelete: Boolean, resultHandler: Handler[AsyncResult[JsonObject]]): Unit
Declare a queue
-
def
queueDeclareAuto(resultHandler: Handler[AsyncResult[JsonObject]]): Unit
Actively declare a server-named exclusive, autodelete, non-durable queue.
-
def
queueDeclareAutoFuture(): Future[JsonObject]
Like queueDeclareAuto but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
queueDeclareFuture(queue: String, durable: Boolean, exclusive: Boolean, autoDelete: Boolean): Future[JsonObject]
Like queueDeclare but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
queueDelete(queue: String, resultHandler: Handler[AsyncResult[JsonObject]]): Unit
Delete a queue, without regard for whether it is in use or has messages on it
-
def
queueDeleteFuture(queue: String): Future[JsonObject]
Like queueDelete but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
queueDeleteIf(queue: String, ifUnused: Boolean, ifEmpty: Boolean, resultHandler: Handler[AsyncResult[JsonObject]]): Unit
Delete a queue
-
def
queueDeleteIfFuture(queue: String, ifUnused: Boolean, ifEmpty: Boolean): Future[JsonObject]
Like queueDeleteIf but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
start(resultHandler: Handler[AsyncResult[Unit]]): Unit
Start the rabbitMQ client.
Start the rabbitMQ client. Create the connection and the chanel.
-
def
startFuture(): Future[Unit]
Like start but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
def
stop(resultHandler: Handler[AsyncResult[Unit]]): Unit
Stop the rabbitMQ client.
Stop the rabbitMQ client. Close the connection and its chanel.
-
def
stopFuture(): Future[Unit]
Like stop but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )