public interface AmqpBridge
Modifier and Type | Method and Description |
---|---|
void |
close(Handler<AsyncResult<Void>> resultHandler)
Shuts the bridge down, closing the underlying connection.
|
static AmqpBridge |
create(Vertx vertx)
Creates a Bridge.
|
static AmqpBridge |
create(Vertx vertx,
AmqpBridgeOptions options)
Creates a Bridge with the given options.
|
<T> MessageConsumer<T> |
createConsumer(String amqpAddress)
Creates a consumer on the given AMQP address.
|
<T> MessageProducer<T> |
createProducer(String amqpAddress)
Creates a producer to the given AMQP address.
|
void |
endHandler(Handler<Void> endHandler)
Set an end handler.
|
void |
start(String hostname,
int port,
Handler<AsyncResult<AmqpBridge>> resultHandler)
Starts the bridge, establishing the underlying connection.
|
void |
start(String hostname,
int port,
String username,
String password,
Handler<AsyncResult<AmqpBridge>> resultHandler)
Starts the bridge, establishing the underlying connection.
|
static AmqpBridge create(Vertx vertx)
vertx
- the vertx instance to usestatic AmqpBridge create(Vertx vertx, AmqpBridgeOptions options)
vertx
- the vertx instance to useoptions
- the optionsvoid start(String hostname, int port, String username, String password, Handler<AsyncResult<AmqpBridge>> resultHandler)
hostname
- the host name to connect toport
- the port to connect tousername
- the usernamepassword
- the passwordresultHandler
- the result handlervoid start(String hostname, int port, Handler<AsyncResult<AmqpBridge>> resultHandler)
hostname
- the host name to connect toport
- the port to connect toresultHandler
- the result handler<T> MessageConsumer<T> createConsumer(String amqpAddress) throws IllegalStateException
amqpAddress
- the address to consume fromIllegalStateException
- if the bridge was not started or the method is invoked on a thread other than the bridge Context thread,
as used in the result handler callback from the start methods.<T> MessageProducer<T> createProducer(String amqpAddress) throws IllegalStateException
amqpAddress
- the address to produce toIllegalStateException
- if the bridge was not started or the method is invoked on a thread other than the bridge Context thread,
as used in the result handler callback from the start methods.void close(Handler<AsyncResult<Void>> resultHandler)
resultHandler
- the result handlerCopyright © 2023 Eclipse. All rights reserved.