Class IncomingMessageQueueImpl
- java.lang.Object
-
- com.biglybt.pifimpl.local.network.IncomingMessageQueueImpl
-
- All Implemented Interfaces:
IncomingMessageQueue
public class IncomingMessageQueueImpl extends java.lang.Object implements IncomingMessageQueue
-
-
Field Summary
Fields Modifier and Type Field Description private IncomingMessageQueue
core_queue
private java.util.HashMap
registrations
-
Constructor Summary
Constructors Modifier Constructor Description protected
IncomingMessageQueueImpl(IncomingMessageQueue core_queue)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
deregisterListener(IncomingMessageQueueListener listener)
Remove registration of queue listener.int
getPercentDoneOfCurrentMessage()
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
registerPriorityListener(IncomingMessageQueueListener listener)
Register queue listener that will get to process messages *ahead* of the core.
-
-
-
Field Detail
-
core_queue
private final IncomingMessageQueue core_queue
-
registrations
private final java.util.HashMap registrations
-
-
Constructor Detail
-
IncomingMessageQueueImpl
protected IncomingMessageQueueImpl(IncomingMessageQueue core_queue)
-
-
Method Detail
-
registerListener
public void registerListener(IncomingMessageQueueListener listener)
Description copied from interface:IncomingMessageQueue
Register queue listener.- Specified by:
registerListener
in interfaceIncomingMessageQueue
- Parameters:
listener
- to register
-
registerPriorityListener
public void registerPriorityListener(IncomingMessageQueueListener listener)
Description copied from interface:IncomingMessageQueue
Register queue listener that will get to process messages *ahead* of the core.- Specified by:
registerPriorityListener
in interfaceIncomingMessageQueue
-
registerListenerSupport
private void registerListenerSupport(IncomingMessageQueueListener listener, boolean is_priority)
-
deregisterListener
public void deregisterListener(IncomingMessageQueueListener listener)
Description copied from interface:IncomingMessageQueue
Remove registration of queue listener.- Specified by:
deregisterListener
in interfaceIncomingMessageQueue
- Parameters:
listener
- to remove
-
notifyOfExternalReceive
public void notifyOfExternalReceive(Message message) throws java.io.IOException
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:
java.io.IOException
-
getPercentDoneOfCurrentMessage
public int getPercentDoneOfCurrentMessage()
- Specified by:
getPercentDoneOfCurrentMessage
in interfaceIncomingMessageQueue
-
-