org.apache.activemq.camel
Class CamelConnection

java.lang.Object
  extended by org.apache.activemq.ActiveMQConnection
      extended by org.apache.activemq.camel.CamelConnection
All Implemented Interfaces:
Connection, QueueConnection, TopicConnection, Closeable, EnhancedConnection, StatsCapable, StreamConnection, TransportListener, org.apache.camel.CamelContextAware

public class CamelConnection
extends ActiveMQConnection
implements org.apache.camel.CamelContextAware


Field Summary
 
Fields inherited from class org.apache.activemq.ActiveMQConnection
activeTempDestinations, alwaysSessionAsync, DEFAULT_BROKER_URL, DEFAULT_PASSWORD, DEFAULT_THREAD_POOL_SIZE, DEFAULT_USER, dispatchAsync, transportInterruptionProcessingComplete
 
Constructor Summary
protected CamelConnection(Transport transport, IdGenerator clientIdGenerator, IdGenerator connectionIdGenerator, JMSStatsImpl factoryStats)
           
 
Method Summary
 org.apache.camel.CamelContext getCamelContext()
           
 void setCamelContext(org.apache.camel.CamelContext camelContext)
           
 
Methods inherited from class org.apache.activemq.ActiveMQConnection
addConnectionConsumer, addDispatcher, addInputStream, addOutputStream, addProducer, addSession, addTransportListener, asyncSendPacket, changeUserInfo, checkClientIDWasManuallySpecified, checkClosed, checkClosedOrFailed, cleanup, cleanUpTempDestinations, close, createBlobTransferPolicy, createConnectionConsumer, createConnectionConsumer, createConnectionConsumer, createConnectionConsumer, createDurableConnectionConsumer, createDurableConnectionConsumer, createDurableInputStream, createDurableInputStream, createDurableInputStream, createDurableInputStream, createInputStream, createInputStream, createInputStream, createInputStream, createNonPersistentOutputStream, createOutputStream, createOutputStream, createQueueSession, createSession, createTempDestination, createTopicSession, deleteTempDestination, destroyDestination, ensureConnectionInfoSent, finalize, getBlobTransferPolicy, getBrokerInfo, getBrokerName, getClientID, getClientInternalExceptionListener, getCloseTimeout, getConnectionInfo, getConnectionStats, getConsumerFailoverRedeliveryWaitPeriod, getDestinationSource, getExceptionListener, getExecutor, getFirstFailureError, getInitializedClientID, getLocalTransactionIdGenerator, getMaxThreadPoolSize, getMetaData, getNextSessionId, getOptimizeAcknowledgeTimeOut, getOptimizedAckScheduledAckInterval, getPrefetchPolicy, getProducerWindowSize, getProtocolVersion, getRedeliveryPolicy, getRedeliveryPolicyMap, getRejectedTaskHandler, getResourceManagerId, getScheduler, getSendTimeout, getSessionTaskRunner, getStats, getTimeCreated, getTransformer, getTransport, getTransportChannel, getWarnAboutUnstartedConnectionTimeout, isAlwaysSessionAsync, isAlwaysSyncSend, isCheckForDuplicates, isClosed, isClosing, isCopyMessageOnSend, isDeleted, isDisableTimeStampsByDefault, isDispatchAsync, isDuplicate, isExclusiveConsumer, isMessagePrioritySupported, isNestedMapAndListEnabled, isNonBlockingRedelivery, isObjectMessageSerializationDefered, isOptimizeAcknowledge, isOptimizedMessageDispatch, isSendAcksAsync, isStarted, isStatsEnabled, isTransactedIndividualAck, isTransportFailed, isUseAsyncSend, isUseCompression, isUseDedicatedTaskRunner, isUseRetroactiveConsumer, isWatchTopicAdvisories, makeConnection, makeConnection, makeConnection, onAsyncException, onClientInternalException, onCommand, onConnectionControl, onConsumerControl, onControlCommand, onException, onWireFormatInfo, removeConnectionConsumer, removeDispatcher, removeDispatcher, removeInputStream, removeOutputStream, removeProducer, removeSession, removeTransportListener, rollbackDuplicate, setAlwaysSessionAsync, setAlwaysSyncSend, setAuditDepth, setAuditMaximumProducerNumber, setBlobTransferPolicy, setCheckForDuplicates, setClientID, setClientInternalExceptionListener, setCloseTimeout, setConsumerFailoverRedeliveryWaitPeriod, setCopyMessageOnSend, setDefaultClientID, setDisableTimeStampsByDefault, setDispatchAsync, setExceptionListener, setExclusiveConsumer, setMaxThreadPoolSize, setMessagePrioritySupported, setNestedMapAndListEnabled, setNonBlockingRedelivery, setObjectMessageSerializationDefered, setOptimizeAcknowledge, setOptimizeAcknowledgeTimeOut, setOptimizedAckScheduledAckInterval, setOptimizedMessageDispatch, setPassword, setPrefetchPolicy, setProducerWindowSize, setRedeliveryPolicy, setRedeliveryPolicyMap, setRejectedTaskHandler, setSendAcksAsync, setSendTimeout, setSessionTaskRunner, setStatsEnabled, setTransactedIndividualAck, setTransformer, setUseAsyncSend, setUseCompression, setUseDedicatedTaskRunner, setUseRetroactiveConsumer, setUserName, setWarnAboutUnstartedConnectionTimeout, setWatchTopicAdvisories, start, stop, syncSendPacket, syncSendPacket, syncSendPacket, toString, transportFailed, transportInterruptionProcessingComplete, transportInterupted, transportResumed, unsubscribe, waitForTransportInterruptionProcessingToComplete
 
Methods inherited from class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

CamelConnection

protected CamelConnection(Transport transport,
                          IdGenerator clientIdGenerator,
                          IdGenerator connectionIdGenerator,
                          JMSStatsImpl factoryStats)
                   throws Exception
Throws:
Exception
Method Detail

getCamelContext

public org.apache.camel.CamelContext getCamelContext()
Specified by:
getCamelContext in interface org.apache.camel.CamelContextAware

setCamelContext

public void setCamelContext(org.apache.camel.CamelContext camelContext)
Specified by:
setCamelContext in interface org.apache.camel.CamelContextAware


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