Class OutgoingMessageQueueImpl
java.lang.Object
com.biglybt.pifimpl.local.network.OutgoingMessageQueueImpl
- All Implemented Interfaces:
OutgoingMessageQueue
-
Field Summary
Fields -
Constructor Summary
ConstructorsModifierConstructorDescriptionprotected
OutgoingMessageQueueImpl
(OutgoingMessageQueue core_queue) -
Method Summary
Modifier and TypeMethodDescriptionvoid
Remove registration of queue listener.int[]
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.Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface com.biglybt.pif.network.OutgoingMessageQueue
getPercentDoneOfCurrentMessage
-
Field Details
-
core_queue
-
registrations
-
-
Constructor Details
-
OutgoingMessageQueueImpl
-
-
Method Details
-
setEncoder
Description copied from interface:OutgoingMessageQueue
Set the message stream encoder that will be used to encode outgoing messages.- Specified by:
setEncoder
in interfaceOutgoingMessageQueue
- Parameters:
encoder
- to use
-
sendMessage
Description copied from interface:OutgoingMessageQueue
Queue the given message for sending.- Specified by:
sendMessage
in interfaceOutgoingMessageQueue
- Parameters:
message
- to send
-
registerListener
Description copied from interface:OutgoingMessageQueue
Register queue listener.- Specified by:
registerListener
in interfaceOutgoingMessageQueue
- Parameters:
listener
- to register
-
deregisterListener
Description copied from interface:OutgoingMessageQueue
Remove registration of queue listener.- Specified by:
deregisterListener
in interfaceOutgoingMessageQueue
- Parameters:
listener
- to remove
-
notifyOfExternalSend
Description copied from interface:OutgoingMessageQueue
Notifty the queue (and its listeners) of a message sent externally on the queue's behalf.- Specified by:
notifyOfExternalSend
in interfaceOutgoingMessageQueue
- Parameters:
message
- sent externally
-
getCurrentMessageProgress
public int[] getCurrentMessageProgress()- Specified by:
getCurrentMessageProgress
in interfaceOutgoingMessageQueue
-
getDataQueuedBytes
public int getDataQueuedBytes()- Specified by:
getDataQueuedBytes
in interfaceOutgoingMessageQueue
-
getProtocolQueuedBytes
public int getProtocolQueuedBytes()- Specified by:
getProtocolQueuedBytes
in interfaceOutgoingMessageQueue
-
isBlocked
public boolean isBlocked()- Specified by:
isBlocked
in interfaceOutgoingMessageQueue
-