Methods Summary |
---|
public void | cancelQueueListener(com.aelitis.azureus.core.networkmanager.IncomingMessageQueue$MessageQueueListener listener)Cancel queue event notification listener.
|
public void | destroy()Destroy this queue.
|
public MessageStreamDecoder | getDecoder()
|
public int | getPercentDoneOfCurrentMessage()Get the percentage of the current message that has already been received.
|
public void | notifyOfExternallyReceivedMessage(Message message)Notifty the queue (and its listeners) of a message received externally on the queue's behalf.
|
public int | receiveFromTransport(int max_bytes)Receive (read) message(s) data from the underlying transport.
|
public void | registerQueueListener(com.aelitis.azureus.core.networkmanager.IncomingMessageQueue$MessageQueueListener listener)Add a listener to be notified of queue events.
|
public void | resumeQueueProcessing()Manually resume processing (reading) incoming messages.
NOTE: Allows us to resume docoding externally, in case it was auto-paused internally.
|
public void | setDecoder(MessageStreamDecoder new_stream_decoder)Set the message stream decoder that will be used to decode incoming messages.
|