Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<AmqpBridge> |
__TYPE_ARG |
Constructor and Description |
---|
AmqpBridge(AmqpBridge delegate) |
AmqpBridge(Object delegate) |
Modifier and Type | Method and Description |
---|---|
void |
close(Handler<AsyncResult<Void>> resultHandler)
Shuts the bridge down, closing the underlying connection.
|
Observable<Void> |
closeObservable()
Deprecated.
use
rxClose() instead |
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.
|
boolean |
equals(Object o) |
AmqpBridge |
getDelegate() |
int |
hashCode() |
static AmqpBridge |
newInstance(AmqpBridge arg) |
Single<Void> |
rxClose()
Shuts the bridge down, closing the underlying connection.
|
Single<AmqpBridge> |
rxStart(String hostname,
int port)
Starts the bridge, establishing the underlying connection.
|
Single<AmqpBridge> |
rxStart(String hostname,
int port,
String username,
String password)
Starts the bridge, establishing the underlying connection.
|
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.
|
Observable<AmqpBridge> |
startObservable(String hostname,
int port)
Deprecated.
|
Observable<AmqpBridge> |
startObservable(String hostname,
int port,
String username,
String password)
Deprecated.
|
String |
toString() |
public static final io.vertx.lang.rx.TypeArg<AmqpBridge> __TYPE_ARG
public AmqpBridge(AmqpBridge delegate)
public AmqpBridge(Object delegate)
public AmqpBridge getDelegate()
public static AmqpBridge create(Vertx vertx)
vertx
- the vertx instance to usepublic static AmqpBridge create(Vertx vertx, AmqpBridgeOptions options)
vertx
- the vertx instance to useoptions
- the optionspublic void 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 handler@Deprecated public Observable<AmqpBridge> startObservable(String hostname, int port, String username, String password)
rxStart(java.lang.String, int, java.lang.String, java.lang.String)
insteadhostname
- the host name to connect toport
- the port to connect tousername
- the usernamepassword
- the passwordpublic Single<AmqpBridge> rxStart(String hostname, int port, String username, String password)
hostname
- the host name to connect toport
- the port to connect tousername
- the usernamepassword
- the passwordpublic void start(String hostname, int port, Handler<AsyncResult<AmqpBridge>> resultHandler)
hostname
- the host name to connect toport
- the port to connect toresultHandler
- the result handler@Deprecated public Observable<AmqpBridge> startObservable(String hostname, int port)
rxStart(java.lang.String, int, java.lang.String, java.lang.String)
insteadhostname
- the host name to connect toport
- the port to connect topublic Single<AmqpBridge> rxStart(String hostname, int port)
hostname
- the host name to connect toport
- the port to connect topublic <T> MessageConsumer<T> createConsumer(String amqpAddress)
amqpAddress
- the address to consume frompublic <T> MessageProducer<T> createProducer(String amqpAddress)
amqpAddress
- the address to produce topublic void close(Handler<AsyncResult<Void>> resultHandler)
resultHandler
- the result handler@Deprecated public Observable<Void> closeObservable()
rxClose()
insteadpublic Single<Void> rxClose()
public void endHandler(Handler<Void> endHandler)
endHandler
- the handlerpublic static AmqpBridge newInstance(AmqpBridge arg)
Copyright © 2023 Eclipse. All rights reserved.