|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface IncomingMessageQueue
Inbound peer message queue.
Nested Class Summary | |
---|---|
static interface |
IncomingMessageQueue.MessageQueueListener
For notification of queue events. |
Method Summary | |
---|---|
void |
cancelQueueListener(IncomingMessageQueue.MessageQueueListener listener)
Cancel queue event notification listener. |
void |
destroy()
Destroy this queue. |
MessageStreamDecoder |
getDecoder()
|
int |
getPercentDoneOfCurrentMessage()
Get the percentage of the current message that has already been received. |
void |
notifyOfExternallyReceivedMessage(Message message)
Notifty the queue (and its listeners) of a message received externally on the queue's behalf. |
int[] |
receiveFromTransport(int max_bytes,
boolean protocol_is_free)
Receive (read) message(s) data from the underlying transport. |
void |
registerQueueListener(IncomingMessageQueue.MessageQueueListener listener)
Add a listener to be notified of queue events. |
void |
resumeQueueProcessing()
Manually resume processing (reading) incoming messages. |
void |
setDecoder(MessageStreamDecoder new_stream_decoder)
Set the message stream decoder that will be used to decode incoming messages. |
Method Detail |
---|
void setDecoder(MessageStreamDecoder new_stream_decoder)
new_stream_decoder
- to useMessageStreamDecoder getDecoder()
int getPercentDoneOfCurrentMessage()
int[] receiveFromTransport(int max_bytes, boolean protocol_is_free) throws IOException
max_bytes
- to read
IOException
- on receive errorvoid notifyOfExternallyReceivedMessage(Message message) throws IOException
message
- received externally
IOException
void resumeQueueProcessing()
void registerQueueListener(IncomingMessageQueue.MessageQueueListener listener)
listener
- void cancelQueueListener(IncomingMessageQueue.MessageQueueListener listener)
listener
- void destroy()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |