org.apache.activemq.broker.scheduler

Class SchedulerBroker

java.lang.Object

org.apache.activemq.broker.BrokerFilter

org.apache.activemq.broker.scheduler.SchedulerBroker

All Implemented Interfaces:

Broker, Region, JobListener, Service

public class SchedulerBroker
extends BrokerFilter
implements JobListener

Field Summary

Fields inherited from class org.apache.activemq.broker.BrokerFilter

next

Constructor Summary

Constructors

Constructor and Description
SchedulerBroker(BrokerService brokerService, Broker next, JobSchedulerStore store)

Method Summary

Modifier and Type	Method and Description
protected JobScheduler	getInternalScheduler()
JobScheduler	getJobScheduler()
void	scheduledJob(String id, ByteSequence job) A Job that has been scheduled is now ready to be fired.
void	send(ProducerBrokerExchange producerExchange, Message messageSend) Send a message to the broker to using the specified destination.
protected void	sendScheduledJob(ConnectionContext context, Job job, ActiveMQDestination replyTo)
void	start()
void	stop()

Methods inherited from class org.apache.activemq.broker.BrokerFilter

acknowledge, addBroker, addConnection, addConsumer, addDestination, addDestinationInfo, addProducer, addSession, beginTransaction, brokerServiceStarted, commitTransaction, fastProducer, forgetTransaction, gc, getAdaptor, getAdminConnectionContext, getBrokerId, getBrokerName, getBrokerSequenceId, getBrokerService, getClients, getDestinationMap, getDestinationMap, getDestinations, getDestinations, getDurableDestinations, getExecutor, getPeerBrokerInfos, getPreparedTransactions, getRoot, getScheduler, getTempDataStore, getVmConnectorURI, isExpired, isFaultTolerantConfiguration, isFull, isStopped, messageConsumed, messageDelivered, messageDiscarded, messageExpired, messagePull, networkBridgeStarted, networkBridgeStopped, nowMasterBroker, postProcessDispatch, prepareTransaction, preProcessDispatch, processConsumerControl, processDispatchNotification, reapplyInterceptor, removeBroker, removeConnection, removeConsumer, removeDestination, removeDestinationInfo, removeProducer, removeSession, removeSubscription, rollbackTransaction, sendToDeadLetterQueue, setAdminConnectionContext, slowConsumer

Methods inherited from class java.lang.Object

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

Constructor Detail

SchedulerBroker

public SchedulerBroker(BrokerService brokerService,
                       Broker next,
                       JobSchedulerStore store)
                throws Exception

Throws:

Exception

Method Detail

getJobScheduler

public JobScheduler getJobScheduler()
                             throws Exception

Throws:

Exception

start

public void start()
           throws Exception

Specified by:

start in interface Service

Overrides:

start in class BrokerFilter

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface Service

Overrides:

stop in class BrokerFilter

Throws:

Exception

send

public void send(ProducerBrokerExchange producerExchange,
                 Message messageSend)
          throws Exception

Description copied from interface: Region

Send a message to the broker to using the specified destination. The destination specified in the message does not need to match the destination the message is sent to. This is handy in case the message is being sent to a dead letter destination.

Specified by:

send in interface Region

Overrides:

send in class BrokerFilter

Parameters:

producerExchange - the environment the operation is being executed under.

Throws:

Exception - TODO

scheduledJob

public void scheduledJob(String id,
                         ByteSequence job)

Description copied from interface: JobListener

A Job that has been scheduled is now ready to be fired. The Job is passed in its raw byte form and must be un-marshaled before being delivered.

Specified by:

scheduledJob in interface JobListener

job - The job that is now ready, delivered in byte form.

getInternalScheduler

protected JobScheduler getInternalScheduler()
                                     throws Exception

Throws:

Exception

sendScheduledJob

protected void sendScheduledJob(ConnectionContext context,
                                Job job,
                                ActiveMQDestination replyTo)
                         throws Exception

Throws:

Exception