Package | Description |
---|---|
com.hp.util.net.msg |
Building blocks for creating extensible, network-spanning, asynchronousmessage protocols.
|
Modifier and Type | Class and Description |
---|---|
class |
Echo
Echo response conversation that writes back the same messages it receives.
|
class |
QueuedConversation
Conversation capable of accepting messages in one thread and processing
them in potentially another thread.
|
class |
RequestResponseConversation
Base implementation of a simple synchronous request/response conversation.
|
class |
SendOnlyConversation
Conversation suitable for sending messages only.
|
Modifier and Type | Field and Description |
---|---|
protected Map<Integer,Conversation> |
AbstractConversationTracker.conversations |
Modifier and Type | Method and Description |
---|---|
protected Conversation |
AbstractConversationTracker.addConversation(Conversation c)
Add a new conversation to keep track of.
|
Conversation |
AbstractConversationTracker.get(int cid)
Get the conversation with the specified id.
|
Conversation |
SendOnlyConversation.Provider.newConversation(String topic,
int cid,
int pid) |
Conversation |
RequestResponseConversation.Provider.newConversation(String topic,
int cid,
int pid) |
Conversation |
Echo.Provider.newConversation(String topic,
int cid,
int pid) |
Conversation |
ConversationProvider.newConversation(String topic,
int cid,
int parentId)
Get a conversation for the specified topic.
|
Conversation |
ConversationBroker.newConversation(String topic,
int cid,
int parentId) |
Conversation |
Connection.startConversation(String topic,
int cid,
int parentId)
Initiate a conversation on the specified topic.
|
Modifier and Type | Method and Description |
---|---|
Map<Integer,Conversation> |
Connection.conversations()
Provides an unmodifiable view of the ongoing conversations on this
connection.
|
Map<Integer,Conversation> |
AbstractConversationTracker.conversations()
Get the map of conversations that are currently being tracked.
|
Modifier and Type | Method and Description |
---|---|
protected Conversation |
AbstractConversationTracker.addConversation(Conversation c)
Add a new conversation to keep track of.
|
void |
Connection.endConversation(Conversation conversation)
Conclude the specified conversation.
|
void |
ConversationProvider.removeConversation(Conversation c)
Remove the specified conversation.
|
void |
ConversationBroker.removeConversation(Conversation c) |
void |
AbstractConversationTracker.removeConversation(Conversation c) |
void |
AbstractConversationProvider.removeConversation(Conversation c) |
void |
Connection.sendMessage(Conversation conversation,
byte[] message)
Send a byte array message in the context of the specified conversation.
|
void |
Connection.sendMessage(Conversation conversation,
Writable message)
Send a writable message in the context of the specified conversation.
|
Copyright © 2015. All Rights Reserved.