AmqpClient

Members

Functions

close

void close(AsyncResultHandler!Void closeHandler)

Closes the client. The client must always be closed once not needed anymore.

connect

AmqpClient connect(AsyncResultHandler!AmqpConnection connectionHandler)

Connects to the AMQP broker or router. The location is specified in the {@link AmqpClientOptions} as well as the potential credential required.

connect

AmqpConnection connect()

Undocumented in source.

connectAsync

Future!AmqpConnection connectAsync()

Like {@link #connect(Handler)} but returns a {@code Future} of the asynchronous result

createReceiver

AmqpClient createReceiver(string address, Handler!AmqpReceiver completionHandler)

Creates a receiver used to consume messages from the given address. The receiver has no handler and won't start receiving messages until a handler is explicitly configured. This method avoids having to connect explicitly. You can retrieve the connection using {@link AmqpReceiver#connection()}.

createReceiver

AmqpClient createReceiver(string address, AmqpReceiverOptions receiverOptions, Handler!AmqpReceiver completionHandler)

Creates a receiver used to consumer messages from the given address. This method avoids having to connect explicitly. You can retrieve the connection using {@link AmqpReceiver#connection()}.

createSender

AmqpClient createSender(string address, Handler!AmqpSender completionHandler)

Creates a sender used to send messages to the given address. The address must be set.

createSender

AmqpClient createSender(string address, AmqpSenderOptions options, Handler!AmqpSender completionHandler)

Creates a sender used to send messages to the given address. The address must be set.

Static functions

create

AmqpClient create(AmqpClientOptions options)

Creates a new instance of {@link AmqpClient} using an internal Vert.x instance (with default configuration) and the given AMQP client configuration. Note that the created Vert.x instance will be closed when the client is closed.

• AmqpClient