Package | Description |
---|---|
com.solace.messaging |
A root API package that contains interfaces and classes for developing Java applications using
Solace PubSub Messaging Java Client
|
com.solace.messaging.publisher |
A package that contains interfaces and classes to handle publishing messages.
|
com.solace.messaging.receiver |
A package that contains interfaces and classes to handle receiving messages.
|
com.solace.messaging.util |
A package that contains interfaces and classes of utilities required to work with other PubSub+
Messaging APIs.
|
Modifier and Type | Method and Description |
---|---|
<MessagingService> |
MessagingService.connectAsync(CompletionListener<MessagingService> connectionListener) |
Modifier and Type | Method and Description |
---|---|
<DirectMessagePublisher> |
DirectMessagePublisher.startAsync(CompletionListener<DirectMessagePublisher> startListener) |
<PersistentMessagePublisher> |
PersistentMessagePublisher.startAsync(CompletionListener<PersistentMessagePublisher> startListener) |
<RequestReplyMessagePublisher> |
RequestReplyMessagePublisher.startAsync(CompletionListener<RequestReplyMessagePublisher> startListener) |
Modifier and Type | Method and Description |
---|---|
<DirectMessageReceiver> |
DirectMessageReceiver.startAsync(CompletionListener<DirectMessageReceiver> startListener) |
<PersistentMessageReceiver> |
PersistentMessageReceiver.startAsync(CompletionListener<PersistentMessageReceiver> startListener) |
<RequestReplyMessageReceiver> |
RequestReplyMessageReceiver.startAsync(CompletionListener<RequestReplyMessageReceiver> startListener) |
Modifier and Type | Method and Description |
---|---|
<T> void |
AsyncConnectable.connectAsync(CompletionListener<T> connectionListener)
Connects asynchronously with a PubSub+ event broker with a callback.
|
void |
AsyncConnectable.disconnectAsync(CompletionListener<Void> disconnectionListener)
Disconnects asynchronously with a PubSub+ event broker with a callback.
|
<T> void |
AsyncLifecycleControl.startAsync(CompletionListener<T> startListener)
Asynchronously starts service for consuming/publishing operations using a callback for
completion notification.
|
void |
AsyncLifecycleControl.terminateAsync(CompletionListener<Void> terminationListener,
long gracePeriod)
Asynchronously terminates (gracefully) the service for consuming/publishing operations using a
callback for a completion notification.
|
Copyright 2019-2024 Solace Corporation. All rights reserved.