Class IncomingMessageQueueImpl
java.lang.Object
com.biglybt.pifimpl.local.network.IncomingMessageQueueImpl
- All Implemented Interfaces:
IncomingMessageQueue
-
Field Summary
Fields -
Constructor Summary
ConstructorsModifierConstructorDescriptionprotected
IncomingMessageQueueImpl
(IncomingMessageQueue core_queue) -
Method Summary
Modifier and TypeMethodDescriptionvoid
Remove registration of queue listener.int[]
void
notifyOfExternalReceive
(Message message) Notifty the queue (and its listeners) of a message received externally on the queue's behalf.void
registerListener
(IncomingMessageQueueListener listener) Register queue listener.private void
registerListenerSupport
(IncomingMessageQueueListener listener, boolean is_priority) void
Register queue listener that will get to process messages *ahead* of the core.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.IncomingMessageQueue
getPercentDoneOfCurrentMessage
-
Field Details
-
core_queue
-
registrations
-
-
Constructor Details
-
IncomingMessageQueueImpl
-
-
Method Details
-
registerListener
Description copied from interface:IncomingMessageQueue
Register queue listener.- Specified by:
registerListener
in interfaceIncomingMessageQueue
- Parameters:
listener
- to register
-
registerPriorityListener
Description copied from interface:IncomingMessageQueue
Register queue listener that will get to process messages *ahead* of the core.- Specified by:
registerPriorityListener
in interfaceIncomingMessageQueue
- Parameters:
listener
-
-
registerListenerSupport
-
deregisterListener
Description copied from interface:IncomingMessageQueue
Remove registration of queue listener.- Specified by:
deregisterListener
in interfaceIncomingMessageQueue
- Parameters:
listener
- to remove
-
notifyOfExternalReceive
Description copied from interface:IncomingMessageQueue
Notifty the queue (and its listeners) of a message received externally on the queue's behalf.- Specified by:
notifyOfExternalReceive
in interfaceIncomingMessageQueue
- Parameters:
message
- received externally- Throws:
IOException
-
getCurrentMessageProgress
public int[] getCurrentMessageProgress()- Specified by:
getCurrentMessageProgress
in interfaceIncomingMessageQueue
-