Vert.x AMQP Bridge. Facilitates sending and receiving AMQP 1.0 messages.
Constructor and description |
---|
AmqpBridge
(java.lang.Object delegate) |
Type | Name and description |
---|---|
void |
close(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> resultHandler) Shuts the bridge down, closing the underlying connection. |
static AmqpBridge |
create(Vertx vertx) Creates a Bridge. |
static AmqpBridge |
create(Vertx vertx, java.util.Map<java.lang.String, java.lang.Object> options) Creates a Bridge with the given options. |
MessageConsumer<T> |
createConsumer(java.lang.String amqpAddress) Creates a consumer on the given AMQP address. |
MessageProducer<T> |
createProducer(java.lang.String amqpAddress) Creates a producer to the given AMQP address. |
java.lang.Object |
getDelegate() |
void |
start(java.lang.String hostname, int port, java.lang.String username, java.lang.String password, io.vertx.core.Handler<io.vertx.core.AsyncResult<AmqpBridge>> resultHandler) Starts the bridge, establishing the underlying connection. |
void |
start(java.lang.String hostname, int port, io.vertx.core.Handler<io.vertx.core.AsyncResult<AmqpBridge>> resultHandler) Starts the bridge, establishing the underlying connection. |
Methods inherited from class | Name |
---|---|
class java.lang.Object |
java.lang.Object#wait(long, int), java.lang.Object#wait(long), java.lang.Object#wait(), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll() |
Shuts the bridge down, closing the underlying connection.
resultHandler
- the result handlerCreates a Bridge.
vertx
- the vertx instance to useCreates a Bridge with the given options.
vertx
- the vertx instance to useoptions
- the options (see AmqpBridgeOptions)Creates a consumer on the given AMQP address. This method MUST be called from the bridge Context thread, as used in the result handler callback from the start methods. The bridge MUST be successfully started before the method is called.
amqpAddress
- the address to consume fromCreates a producer to the given AMQP address. This method MUST be called from the bridge Context thread, as used in the result handler callback from the start methods. The bridge MUST be successfully started before the method is called.
amqpAddress
- the address to produce toStarts the bridge, establishing the underlying connection.
hostname
- the host name to connect toport
- the port to connect tousername
- the usernamepassword
- the passwordresultHandler
- the result handlerStarts the bridge, establishing the underlying connection.
hostname
- the host name to connect toport
- the port to connect toresultHandler
- the result handler