org.activemq.service.impl
Class DispatcherImpl

java.lang.Object
  extended by org.activemq.service.impl.DispatcherImpl
All Implemented Interfaces:
Dispatcher, Service

public class DispatcherImpl
extends Object
implements Dispatcher

A dispatcher of messages to some JMS connection.

Typically this uses either IO or NIO to shovel the messages down a socket as fast as possible - in either a push or pull way.

Version:
$Revision: 1.1.1.1 $

Constructor Summary
DispatcherImpl()
           
 
Method Summary
 void addActiveSubscription(BrokerClient client, Subscription sub)
          Add an active subscription
 void register(MessageContainerManager mcm)
          Register the MessageContainerManager for the Dispatcher
 void removeActiveSubscription(BrokerClient client, Subscription sub)
          remove an active subscription
 void start()
          start the DispatchWorker
 void stop()
          stop the DispatchWorker
 void wakeup()
          Called to indicate that there is work to do this will wake up a Dispatch Worker if it is waiting for messages to dispatch
 void wakeup(Subscription sub)
          Called to indicate that there is work to do on a Subscription this will wake up a Dispatch Worker if it is waiting for messages to dispatch
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DispatcherImpl

public DispatcherImpl()
Method Detail

register

public void register(MessageContainerManager mcm)
Register the MessageContainerManager for the Dispatcher

Specified by:
register in interface Dispatcher
Parameters:
mcm -

wakeup

public void wakeup(Subscription sub)
Called to indicate that there is work to do on a Subscription this will wake up a Dispatch Worker if it is waiting for messages to dispatch

Specified by:
wakeup in interface Dispatcher
Parameters:
sub - the Subscription that now has messages to dispatch

wakeup

public void wakeup()
Called to indicate that there is work to do this will wake up a Dispatch Worker if it is waiting for messages to dispatch

Specified by:
wakeup in interface Dispatcher

addActiveSubscription

public void addActiveSubscription(BrokerClient client,
                                  Subscription sub)
Add an active subscription

Specified by:
addActiveSubscription in interface Dispatcher
Parameters:
client -
sub -

removeActiveSubscription

public void removeActiveSubscription(BrokerClient client,
                                     Subscription sub)
remove an active subscription

Specified by:
removeActiveSubscription in interface Dispatcher
Parameters:
client -
sub -

start

public void start()
start the DispatchWorker

Specified by:
start in interface Service
See Also:
Service.start()

stop

public void stop()
stop the DispatchWorker

Specified by:
stop in interface Service
See Also:
Service.stop()


Copyright © 2004-2008 Protique, Ltd.. All Rights Reserved.