public class SchedulerBroker extends BrokerFilter implements JobListener
next
Constructor and Description |
---|
SchedulerBroker(BrokerService brokerService,
Broker next,
JobSchedulerStore store) |
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() |
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, virtualDestinationAdded, virtualDestinationRemoved
public SchedulerBroker(BrokerService brokerService, Broker next, JobSchedulerStore store) throws Exception
Exception
public JobScheduler getJobScheduler() throws Exception
Exception
public void start() throws Exception
start
in interface Service
start
in class BrokerFilter
Exception
public void stop() throws Exception
stop
in interface Service
stop
in class BrokerFilter
Exception
public void send(ProducerBrokerExchange producerExchange, Message messageSend) throws Exception
Region
send
in interface Region
send
in class BrokerFilter
producerExchange
- the environment the operation is being executed under.Exception
- TODOpublic void scheduledJob(String id, ByteSequence job)
JobListener
scheduledJob
in interface JobListener
job
- The job that is now ready, delivered in byte form.protected JobScheduler getInternalScheduler() throws Exception
Exception
protected void sendScheduledJob(ConnectionContext context, Job job, ActiveMQDestination replyTo) throws Exception
Exception
Copyright © 2005–2019 FuseSource, Corp.. All rights reserved.