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()