Package com.biglybt.pif.network
Interface OutgoingMessageQueue
-
- All Known Implementing Classes:
OutgoingMessageQueueImpl
public interface OutgoingMessageQueue
Queue for sending outgoing messages.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description 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()
-
-