org.apache.activemq.camel.component.broker
Class BrokerEndpoint

java.lang.Object
  org.apache.camel.support.ServiceSupport
      org.apache.camel.impl.DefaultEndpoint
          org.apache.activemq.camel.component.broker.BrokerEndpoint

All Implemented Interfaces:

org.apache.camel.CamelContextAware, org.apache.camel.Endpoint, org.apache.camel.IsSingleton, org.apache.camel.MultipleConsumersSupport, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.HasId, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

@ManagedResource(description="Managed Camel Broker Endpoint")
@UriEndpoint(scheme="broker",
             consumerClass=BrokerConsumer.class)
public class BrokerEndpoint
extends org.apache.camel.impl.DefaultEndpoint
implements org.apache.camel.MultipleConsumersSupport, org.apache.camel.Service

Field Summary

Fields inherited from class org.apache.camel.support.ServiceSupport

shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending

Constructor Summary

BrokerEndpoint(String uri, BrokerComponent component, org.apache.activemq.command.ActiveMQDestination destination, BrokerConfiguration configuration)

Method Summary

protected void	addMessageInterceptor(org.apache.activemq.broker.inteceptor.MessageInterceptor messageInterceptor)
org.apache.camel.Consumer	createConsumer(org.apache.camel.Processor processor)
org.apache.camel.Producer	createProducer()
protected void	doStart()
protected void	doStop()
org.apache.activemq.command.ActiveMQDestination	getDestination()
protected void	inject(org.apache.activemq.broker.ProducerBrokerExchange producerBrokerExchange, org.apache.activemq.command.Message message)
boolean	isMultipleConsumersSupported()
boolean	isSingleton()
protected void	removeMessageInterceptor(org.apache.activemq.broker.inteceptor.MessageInterceptor messageInterceptor)

Methods inherited from class org.apache.camel.impl.DefaultEndpoint

configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExchangePattern, getId, hashCode, isLenientProperties, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setSynchronous, toString

Methods inherited from class org.apache.camel.support.ServiceSupport

doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.camel.Service

start, stop

Constructor Detail

BrokerEndpoint

public BrokerEndpoint(String uri,
                      BrokerComponent component,
                      org.apache.activemq.command.ActiveMQDestination destination,
                      BrokerConfiguration configuration)

Method Detail

createProducer

public org.apache.camel.Producer createProducer()
                                         throws Exception

Specified by:

createProducer in interface org.apache.camel.Endpoint

Throws:

Exception

createConsumer

public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
                                         throws Exception

Specified by:

createConsumer in interface org.apache.camel.Endpoint

Throws:

Exception

isSingleton

public boolean isSingleton()

Specified by:

isSingleton in interface org.apache.camel.IsSingleton

isMultipleConsumersSupported

public boolean isMultipleConsumersSupported()

Specified by:

isMultipleConsumersSupported in interface org.apache.camel.MultipleConsumersSupport

getDestination

public org.apache.activemq.command.ActiveMQDestination getDestination()

doStart

protected void doStart()
                throws Exception

Overrides:

doStart in class org.apache.camel.impl.DefaultEndpoint

Throws:

Exception

doStop

protected void doStop()
               throws Exception

Overrides:

doStop in class org.apache.camel.impl.DefaultEndpoint

Throws:

Exception

addMessageInterceptor

protected void addMessageInterceptor(org.apache.activemq.broker.inteceptor.MessageInterceptor messageInterceptor)

removeMessageInterceptor

protected void removeMessageInterceptor(org.apache.activemq.broker.inteceptor.MessageInterceptor messageInterceptor)

inject

protected void inject(org.apache.activemq.broker.ProducerBrokerExchange producerBrokerExchange,
                      org.apache.activemq.command.Message message)
               throws Exception

Throws:

Exception