org.gudy.azureus2.pluginsimpl.local.network
Class IncomingMessageQueueImpl

java.lang.Object
  org.gudy.azureus2.pluginsimpl.local.network.IncomingMessageQueueImpl

All Implemented Interfaces:

IncomingMessageQueue

public class IncomingMessageQueueImpl
extends Object
implements IncomingMessageQueue

Constructor Summary

protected

IncomingMessageQueueImpl(IncomingMessageQueue core_queue)

Method Summary

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.
void	registerPriorityListener(IncomingMessageQueueListener listener) 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

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

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

getPercentDoneOfCurrentMessage

public int getPercentDoneOfCurrentMessage()

Specified by:

getPercentDoneOfCurrentMessage in interface IncomingMessageQueue