public class SchedulerBroker extends BrokerFilter implements JobListener
next
Constructor and Description |
---|
SchedulerBroker(Broker next,
File directory) |
Modifier and Type | Method and Description |
---|---|
File |
getDirectory() |
protected JobScheduler |
getInternalScheduler() |
JobScheduler |
getJobScheduler() |
void |
scheduledJob(String id,
ByteSequence job)
A Job that has been scheduled is now ready
|
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 |
setDirectory(File directory) |
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, 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, removeBroker, removeConnection, removeConsumer, removeDestination, removeDestinationInfo, removeProducer, removeSession, removeSubscription, rollbackTransaction, sendToDeadLetterQueue, setAdminConnectionContext, slowConsumer
public JobScheduler getJobScheduler() throws Exception
Exception
public File getDirectory()
public void setDirectory(File directory)
directory
- the directory to setpublic 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
protected JobScheduler getInternalScheduler() throws Exception
Exception
protected void sendScheduledJob(ConnectionContext context, Job job, ActiveMQDestination replyTo) throws Exception
Exception
Copyright © 2005–2014 The Apache Software Foundation. All rights reserved.