org.gudy.azureus2.plugins.network
Interface OutgoingMessageQueue

All Known Implementing Classes:
OutgoingMessageQueueImpl

public interface OutgoingMessageQueue

Queue for sending outgoing messages.


Method Summary
 void deregisterListener(OutgoingMessageQueueListener listener)
          Remove registration of queue listener.
 int getDataQueuedBytes()
           
 int getPercentDoneOfCurrentMessage()
           
 int getProtocolQueuedBytes()
           
 boolean isBlocked()
           
 void notifyOfExternalSend(Message message)
          Notifty the queue (and its listeners) of a message sent externally on the queue's behalf.
 void registerListener(OutgoingMessageQueueListener listener)
          Register queue listener.
 void sendMessage(Message message)
          Queue the given message for sending.
 void setEncoder(MessageStreamEncoder encoder)
          Set the message stream encoder that will be used to encode outgoing messages.
 

Method Detail

setEncoder

void setEncoder(MessageStreamEncoder encoder)
Set the message stream encoder that will be used to encode outgoing messages.

Parameters:
encoder - to use

sendMessage

void sendMessage(Message message)
Queue the given message for sending.

Parameters:
message - to send

registerListener

void registerListener(OutgoingMessageQueueListener listener)
Register queue listener.

Parameters:
listener - to register

deregisterListener

void deregisterListener(OutgoingMessageQueueListener listener)
Remove registration of queue listener.

Parameters:
listener - to remove

notifyOfExternalSend

void notifyOfExternalSend(Message message)
Notifty the queue (and its listeners) of a message sent externally on the queue's behalf.

Parameters:
message - sent externally

getPercentDoneOfCurrentMessage

int getPercentDoneOfCurrentMessage()

getDataQueuedBytes

int getDataQueuedBytes()

getProtocolQueuedBytes

int getProtocolQueuedBytes()

isBlocked

boolean isBlocked()