Package | Description |
---|---|
com.ibm.mqlight.api |
Non-blocking API |
com.ibm.mqlight.api.samples |
Modifier and Type | Method and Description |
---|---|
static <T> NonBlockingClient |
NonBlockingClient.create(EndpointService endpointService,
CallbackService callbackService,
NetworkService networkService,
TimerService timerService,
com.google.gson.GsonBuilder gsonBuilder,
ClientOptions options,
NonBlockingClientListener<T> listener,
T context)
Creates a new instance of the
NonBlockingClient in starting state. |
static <T> NonBlockingClient |
NonBlockingClient.create(String service,
ClientOptions options,
NonBlockingClientListener<T> listener,
T context)
Creates a new instance of the
NonBlockingClient in starting state. |
static <T> NonBlockingClient |
NonBlockingClient.create(String service,
NonBlockingClientListener<T> listener,
T context)
Creates a new instance of the
NonBlockingClient in starting state. |
abstract <T> NonBlockingClient |
NonBlockingClient.start(CompletionListener<T> listener,
T context)
Requests that the client transitions into started state.
|
<T> NonBlockingClient |
NonBlockingClient.subscribe(String topicPattern,
DestinationListener<T> dstListener,
CompletionListener<T> compListener,
T context)
Subscribes to a destination.
|
abstract <T> NonBlockingClient |
NonBlockingClient.subscribe(String topicPattern,
SubscribeOptions subOptions,
DestinationListener<T> destListener,
CompletionListener<T> compListener,
T context)
Subscribes the client to a destination, based on the supplied topic pattern and
share parameters.
|
<T> NonBlockingClient |
NonBlockingClient.unsubscribe(String topicPattern,
CompletionListener<T> listener,
T context)
Unsubscribes from a destination.
|
<T> NonBlockingClient |
NonBlockingClient.unsubscribe(String topicPattern,
int ttl,
CompletionListener<T> listener,
T context)
Unsubscribes from a destination.
|
abstract <T> NonBlockingClient |
NonBlockingClient.unsubscribe(String topicPattern,
String share,
CompletionListener<T> listener,
T context)
Unsubscribes from a destination.
|
abstract <T> NonBlockingClient |
NonBlockingClient.unsubscribe(String topicPattern,
String share,
int ttl,
CompletionListener<T> listener,
T context)
Unsubscribes from a destination.
|
Modifier and Type | Method and Description |
---|---|
void |
NonBlockingClientListener.onDrain(NonBlockingClient client,
T context)
Called as a notification when the client has flushed any buffered messages to the network.
|
void |
NonBlockingClientAdapter.onDrain(NonBlockingClient client,
T context) |
void |
CompletionListener.onError(NonBlockingClient client,
T context,
Exception exception)
Called to indicate that the operation failed.
|
void |
DestinationAdapter.onMalformed(NonBlockingClient client,
T context,
MalformedDelivery delivery) |
void |
DestinationListener.onMalformed(NonBlockingClient client,
T context,
MalformedDelivery delivery)
Invoked to deliver a malformed message to the client.
|
void |
DestinationAdapter.onMessage(NonBlockingClient client,
T context,
Delivery delivery) |
void |
DestinationListener.onMessage(NonBlockingClient client,
T context,
Delivery delivery)
Invoked to deliver a message to the client.
|
void |
NonBlockingClientListener.onRestarted(NonBlockingClient client,
T context)
Called as a notification when the client transitions into restarting state.
|
void |
NonBlockingClientAdapter.onRestarted(NonBlockingClient client,
T context) |
void |
NonBlockingClientListener.onRetrying(NonBlockingClient client,
T context,
ClientException exception)
Called as a notification when the client transitions into retrying state.
|
void |
NonBlockingClientAdapter.onRetrying(NonBlockingClient client,
T context,
ClientException throwable) |
void |
NonBlockingClientListener.onStarted(NonBlockingClient client,
T context)
Called as a notification when the client transitions into started state.
|
void |
NonBlockingClientAdapter.onStarted(NonBlockingClient client,
T context) |
void |
NonBlockingClientListener.onStopped(NonBlockingClient client,
T context,
ClientException exception)
Called as a notification when the client transitions into stopped state.
|
void |
NonBlockingClientAdapter.onStopped(NonBlockingClient client,
T context,
ClientException throwable) |
void |
CompletionListener.onSuccess(NonBlockingClient client,
T context)
Called to indicate that the operation completed successfully.
|
void |
DestinationAdapter.onUnsubscribed(NonBlockingClient client,
T context,
String topicPattern,
String share,
Exception error) |
void |
DestinationListener.onUnsubscribed(NonBlockingClient client,
T context,
String topicPattern,
String share,
Exception error)
Invoked to provide a notification that the client is no longer subscribed to a destination
that this
DestinationListneer has previously being associated with. |
Modifier and Type | Method and Description |
---|---|
void |
Send.SendRunnable.onError(NonBlockingClient client,
String context,
Exception exception) |
void |
Receive.Listener.onMalformed(NonBlockingClient client,
Void context,
MalformedDelivery delivery) |
void |
Receive.Listener.onMessage(NonBlockingClient client,
Void context,
Delivery delivery) |
void |
Send.SendRunnable.onSuccess(NonBlockingClient client,
String context) |
void |
Receive.Listener.onUnsubscribed(NonBlockingClient client,
Void context,
String topicPattern,
String share,
Exception error) |
Constructor and Description |
---|
Send.SendRunnable(NonBlockingClient client,
Map<String,Object> args,
String[] messages) |
Copyright © 2015 International Business Machines Corporation. All rights reserved.