Constructor and Description |
---|
AmqpBridge(AmqpBridge delegate) |
Modifier and Type | Method and Description |
---|---|
void |
close(io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> resultHandler)
Shuts the bridge down, closing the underlying connection.
|
rx.Observable<Void> |
closeObservable()
Shuts the bridge down, closing the underlying connection.
|
static AmqpBridge |
create(io.vertx.rxjava.core.Vertx vertx)
Creates a Bridge.
|
static AmqpBridge |
create(io.vertx.rxjava.core.Vertx vertx,
AmqpBridgeOptions options)
Creates a Bridge with the given options.
|
<T> io.vertx.rxjava.core.eventbus.MessageConsumer<T> |
createConsumer(String amqpAddress)
Creates a consumer on the given AMQP address.
|
<T> io.vertx.rxjava.core.eventbus.MessageProducer<T> |
createProducer(String amqpAddress)
Creates a producer to the given AMQP address.
|
Object |
getDelegate() |
static AmqpBridge |
newInstance(AmqpBridge arg) |
void |
start(String hostname,
int port,
io.vertx.core.Handler<io.vertx.core.AsyncResult<AmqpBridge>> resultHandler)
Starts the bridge, establishing the underlying connection.
|
void |
start(String hostname,
int port,
String username,
String password,
io.vertx.core.Handler<io.vertx.core.AsyncResult<AmqpBridge>> resultHandler)
Starts the bridge, establishing the underlying connection.
|
rx.Observable<AmqpBridge> |
startObservable(String hostname,
int port)
Starts the bridge, establishing the underlying connection.
|
rx.Observable<AmqpBridge> |
startObservable(String hostname,
int port,
String username,
String password)
Starts the bridge, establishing the underlying connection.
|
public AmqpBridge(AmqpBridge delegate)
public Object getDelegate()
public static AmqpBridge create(io.vertx.rxjava.core.Vertx vertx)
vertx
- the vertx instance to usepublic static AmqpBridge create(io.vertx.rxjava.core.Vertx vertx, AmqpBridgeOptions options)
vertx
- the vertx instance to useoptions
- the optionspublic void start(String hostname, int port, String username, String password, io.vertx.core.Handler<io.vertx.core.AsyncResult<AmqpBridge>> resultHandler)
hostname
- the host name to connect toport
- the port to connect tousername
- the usernamepassword
- the passwordresultHandler
- the result handlerpublic rx.Observable<AmqpBridge> startObservable(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, io.vertx.core.Handler<io.vertx.core.AsyncResult<AmqpBridge>> resultHandler)
hostname
- the host name to connect toport
- the port to connect toresultHandler
- the result handlerpublic rx.Observable<AmqpBridge> startObservable(String hostname, int port)
hostname
- the host name to connect toport
- the port to connect topublic <T> io.vertx.rxjava.core.eventbus.MessageConsumer<T> createConsumer(String amqpAddress)
amqpAddress
- the address to consume frompublic <T> io.vertx.rxjava.core.eventbus.MessageProducer<T> createProducer(String amqpAddress)
amqpAddress
- the address to produce topublic void close(io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> resultHandler)
resultHandler
- the result handlerpublic rx.Observable<Void> closeObservable()
public static AmqpBridge newInstance(AmqpBridge arg)
Copyright © 2016. All rights reserved.