Package | Description |
---|---|
com.hp.util.net.msg |
Building blocks for creating extensible, network-spanning, asynchronousmessage protocols.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractConversationProvider
An abstract conversation provider that does not track the conversations it
issues.
|
class |
AbstractConversationTracker
An abstract conversation provider that keeps track of the conversations
using their id.
|
class |
AbstractQueuedConversationTracker
An abstract conversation provider that maintains a shared executor for
creating queued conversations and keeps track of them using their id.
|
class |
ConversationBroker
A broker, acting as a conversation provider, by dispatching conversation
provisioning requests to multiple other conversation providers that have
been registered with the broker.
|
static class |
Echo.Provider
Echo conversation provider.
|
static class |
RequestResponseConversation.Provider
Provider and tracker of generic request response conversations.
|
static class |
SendOnlyConversation.Provider
Provider and tracker of generic send-only conversations.
|
Modifier and Type | Method and Description |
---|---|
ConversationProvider |
ConversationBroker.getProvider(String topic)
Get the provider associated with the specified topic.
|
ConversationProvider |
Connection.provider()
Get the conversation provider associated with this connection.
|
Modifier and Type | Method and Description |
---|---|
Connection |
ConnectionBroker.accept(String name,
ConversationProvider resolver)
Host and accept a connection on the specified network port.
|
Connection |
ConnectionBroker.accept(String name,
ConversationProvider resolver,
ConnectionListener listener)
Host and accept a connection on the specified network port.
|
void |
ConversationBroker.addProvider(String topic,
ConversationProvider provider)
Add a new provider for the specified topic.
|
Connection |
ConnectionBroker.connect(String name,
String host,
int port,
ConnectionBroker.Transport transport,
ConversationProvider resolver)
Make a connection to the given host and on the specified network port.
|
Connection |
ConnectionBroker.connect(String name,
String host,
int port,
ConnectionBroker.Transport transport,
ConversationProvider resolver,
ConnectionListener listener)
Make a connection to the given host and on the specified network port.
|
Connection |
ConnectionBroker.connect(String name,
String host,
int port,
ConversationProvider resolver)
Make a plain-text connection to the given host and on the specified
network port.
|
Constructor and Description |
---|
LocalConnectionPair(String name,
ConversationProvider firstProvider,
ConversationProvider secondProvider)
Creates a pair of connections using the supplied conversation providers.
|
Copyright © 2015. All Rights Reserved.