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

java.lang.Object
  extended by 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