org.apache.activemq.broker.scheduler
Class SchedulerBroker

java.lang.Object
  extended by org.apache.activemq.broker.BrokerFilter
      extended by 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
SchedulerBroker(Broker next, File directory)
           
 
Method Summary
 File getDirectory()
           
protected  JobScheduler getInternalScheduler()
           
 JobScheduler getJobScheduler()
           
 void scheduledJob(String id, org.apache.kahadb.util.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()
           
 
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
 

Constructor Detail

SchedulerBroker

public SchedulerBroker(Broker next,
                       File directory)
                throws Exception
Throws:
Exception
Method Detail

getJobScheduler

public JobScheduler getJobScheduler()
                             throws Exception
Throws:
Exception

getDirectory

public File getDirectory()
Returns:
the directory

setDirectory

public void setDirectory(File directory)
Parameters:
directory - the directory to set

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,
                         org.apache.kahadb.util.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 Exception
Throws:
Exception

sendScheduledJob

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


Copyright © 2005-2012 The Apache Software Foundation. All Rights Reserved.