|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.gudy.azureus2.pluginsimpl.local.peers.PeerForeignNetworkConnection.imq
protected class PeerForeignNetworkConnection.imq
Nested Class Summary |
---|
Nested classes/interfaces inherited from interface com.aelitis.azureus.core.networkmanager.IncomingMessageQueue |
---|
IncomingMessageQueue.MessageQueueListener |
Constructor Summary | |
---|---|
protected |
PeerForeignNetworkConnection.imq()
|
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. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
protected PeerForeignNetworkConnection.imq()
Method Detail |
---|
public void setDecoder(MessageStreamDecoder new_stream_decoder)
IncomingMessageQueue
setDecoder
in interface IncomingMessageQueue
new_stream_decoder
- to usepublic MessageStreamDecoder getDecoder()
getDecoder
in interface IncomingMessageQueue
public int getPercentDoneOfCurrentMessage()
IncomingMessageQueue
getPercentDoneOfCurrentMessage
in interface IncomingMessageQueue
public int[] receiveFromTransport(int max_bytes, boolean protocol_is_free) throws IOException
IncomingMessageQueue
receiveFromTransport
in interface IncomingMessageQueue
max_bytes
- to read
IOException
- on receive errorpublic void notifyOfExternallyReceivedMessage(Message message)
IncomingMessageQueue
notifyOfExternallyReceivedMessage
in interface IncomingMessageQueue
message
- received externallypublic void resumeQueueProcessing()
IncomingMessageQueue
resumeQueueProcessing
in interface IncomingMessageQueue
public void registerQueueListener(IncomingMessageQueue.MessageQueueListener listener)
IncomingMessageQueue
registerQueueListener
in interface IncomingMessageQueue
public void cancelQueueListener(IncomingMessageQueue.MessageQueueListener listener)
IncomingMessageQueue
cancelQueueListener
in interface IncomingMessageQueue
public void destroy()
IncomingMessageQueue
destroy
in interface IncomingMessageQueue
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |