- close
void close(AsyncResultHandler!Void handler)
Undocumented in source. Be warned that the author may not have intended to support it.
- connect
AmqpClient connect(AsyncResultHandler!AmqpConnection connectionHandler)
Undocumented in source. Be warned that the author may not have intended to support it.
- connect
AmqpConnection connect()
Undocumented in source. Be warned that the author may not have intended to support it.
- connectAsync
Future!AmqpConnection connectAsync()
Undocumented in source. Be warned that the author may not have intended to support it.
- createReceiver
AmqpClient createReceiver(string address, Handler!AmqpReceiver completionHandler)
Undocumented in source. Be warned that the author may not have intended to support it.
- createReceiver
AmqpClient createReceiver(string address, AmqpReceiverOptions receiverOptions, Handler!AmqpReceiver completionHandler)
Undocumented in source. Be warned that the author may not have intended to support it.
- createSender
AmqpClient createSender(string address, Handler!AmqpSender completionHandler)
Undocumented in source. Be warned that the author may not have intended to support it.
- createSender
AmqpClient createSender(string address, AmqpSenderOptions options, Handler!AmqpSender completionHandler)
Undocumented in source. Be warned that the author may not have intended to support it.
- register
void register(AmqpConnectionImpl connection)
Undocumented in source. Be warned that the author may not have intended to support it.
- 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.
- 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.
- connectAsync
Future!AmqpConnection connectAsync()
Like {@link #connect(Handler)} but returns a {@code Future} of the asynchronous result
- connect
AmqpConnection connect()
Undocumented in source.
- close
void close(AsyncResultHandler!Void closeHandler)
Closes the client.
The client must always be closed once not needed anymore.
- 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.