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

java.lang.Object
  extended by org.apache.camel.support.ServiceSupport
      extended by org.apache.camel.impl.DefaultEndpoint
          extended by 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, ActiveMQDestination destination, BrokerConfiguration configuration)
           
 
Method Summary
protected  void addMessageInterceptor(MessageInterceptor messageInterceptor)
           
 org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
           
 org.apache.camel.Producer createProducer()
           
protected  void doStart()
           
protected  void doStop()
           
 ActiveMQDestination getDestination()
           
protected  void inject(ProducerBrokerExchange producerBrokerExchange, Message message)
           
 boolean isMultipleConsumersSupported()
           
 boolean isSingleton()
           
protected  void removeMessageInterceptor(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,
                      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 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(MessageInterceptor messageInterceptor)

removeMessageInterceptor

protected void removeMessageInterceptor(MessageInterceptor messageInterceptor)

inject

protected void inject(ProducerBrokerExchange producerBrokerExchange,
                      Message message)
               throws Exception
Throws:
Exception


Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.