Class IncomingMessageQueueImpl

java.lang.Object

com.biglybt.pifimpl.local.network.IncomingMessageQueueImpl

All Implemented Interfaces:

IncomingMessageQueue

public class IncomingMessageQueueImpl
extends Object
implements IncomingMessageQueue

Field Summary

Fields

Modifier and Type	Field	Description
private final IncomingMessageQueue	core_queue
private final HashMap	registrations

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	IncomingMessageQueueImpl(IncomingMessageQueue core_queue)

Method Summary

Modifier and Type	Method	Description
void	deregisterListener(IncomingMessageQueueListener listener)	Remove registration of queue listener.
int[]	getCurrentMessageProgress()
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.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface IncomingMessageQueue

getPercentDoneOfCurrentMessage

Field Details

core_queue

private final IncomingMessageQueue core_queue

registrations

private final HashMap registrations

Constructor Details

IncomingMessageQueueImpl

protected IncomingMessageQueueImpl(IncomingMessageQueue core_queue)

Method Details

registerListener

public void registerListener(IncomingMessageQueueListener listener)

Description copied from interface: IncomingMessageQueue

Register queue listener.

Specified by:

registerListener in interface IncomingMessageQueue

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 interface IncomingMessageQueue

Parameters:

listener -

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 interface IncomingMessageQueue

Parameters:

listener - to remove

notifyOfExternalReceive

public void notifyOfExternalReceive(Message message)
                             throws 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 interface IncomingMessageQueue

Parameters:

message - received externally

Throws:

IOException

getCurrentMessageProgress

public int[] getCurrentMessageProgress()

Specified by:

getCurrentMessageProgress in interface IncomingMessageQueue