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
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, 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 |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
SchedulerBroker
public SchedulerBroker(Broker next,
java.io.File directory)
throws java.lang.Exception
- Throws:
java.lang.Exception
getJobScheduler
public JobScheduler getJobScheduler()
throws java.lang.Exception
- Throws:
java.lang.Exception
getDirectory
public java.io.File getDirectory()
- Returns:
- the directory
setDirectory
public void setDirectory(java.io.File directory)
- Parameters:
directory
- the directory to set
start
public void start()
throws java.lang.Exception
- Specified by:
start
in interface Service
- Overrides:
start
in class BrokerFilter
- Throws:
java.lang.Exception
stop
public void stop()
throws java.lang.Exception
- Specified by:
stop
in interface Service
- Overrides:
stop
in class BrokerFilter
- Throws:
java.lang.Exception
send
public void send(ProducerBrokerExchange producerExchange,
Message messageSend)
throws java.lang.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:
java.lang.Exception
- TODO
scheduledJob
public void scheduledJob(java.lang.String id,
ByteSequence job)
- Description copied from interface:
JobListener
- A Job that has been scheduled is now ready
- Specified by:
scheduledJob
in interface JobListener
getInternalScheduler
protected JobScheduler getInternalScheduler()
throws java.lang.Exception
- Throws:
java.lang.Exception
sendScheduledJob
protected void sendScheduledJob(ConnectionContext context,
Job job,
ActiveMQDestination replyTo)
throws java.lang.Exception
- Throws:
java.lang.Exception
Copyright © 2005-2016. All Rights Reserved.