Package com.biglybt.pif.network
Interface OutgoingMessageQueue
- All Known Implementing Classes:
OutgoingMessageQueueImpl
public interface OutgoingMessageQueue
Queue for sending outgoing messages.
-
Method Summary
Modifier and TypeMethodDescriptionvoid
Remove registration of queue listener.int[]
int
default int
int
boolean
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 Details
-
setEncoder
Set the message stream encoder that will be used to encode outgoing messages.- Parameters:
encoder
- to use
-
sendMessage
Queue the given message for sending.- Parameters:
message
- to send
-
registerListener
Register queue listener.- Parameters:
listener
- to register
-
deregisterListener
Remove registration of queue listener.- Parameters:
listener
- to remove
-
notifyOfExternalSend
Notifty the queue (and its listeners) of a message sent externally on the queue's behalf.- Parameters:
message
- sent externally
-
getPercentDoneOfCurrentMessage
default int getPercentDoneOfCurrentMessage() -
getCurrentMessageProgress
int[] getCurrentMessageProgress() -
getDataQueuedBytes
int getDataQueuedBytes() -
getProtocolQueuedBytes
int getProtocolQueuedBytes() -
isBlocked
boolean isBlocked()
-