org.apache.camel.component.jms
Class JmsQueueEndpoint

java.lang.Object
  extended by org.apache.camel.impl.ServiceSupport
      extended by org.apache.camel.impl.DefaultEndpoint
          extended by org.apache.camel.component.jms.JmsEndpoint
              extended by org.apache.camel.component.jms.JmsQueueEndpoint
All Implemented Interfaces:
CamelContextAware, Endpoint, IsSingleton, MultipleConsumersSupport, Service, ShutdownableService, BrowsableEndpoint, HasId, HeaderFilterStrategyAware
Direct Known Subclasses:
JmsTemporaryQueueEndpoint

@ManagedResource(description="Managed JMS Queue Endpoint")
public class JmsQueueEndpoint
extends JmsEndpoint
implements BrowsableEndpoint

An endpoint for a JMS Queue which is also browsable

Version:

Field Summary
 
Fields inherited from class org.apache.camel.component.jms.JmsEndpoint
log
 
Constructor Summary
JmsQueueEndpoint(javax.jms.Queue destination)
           
JmsQueueEndpoint(String uri, JmsComponent component, String destination, JmsConfiguration configuration)
           
JmsQueueEndpoint(String uri, JmsComponent component, String destination, JmsConfiguration configuration, QueueBrowseStrategy queueBrowseStrategy)
           
JmsQueueEndpoint(String endpointUri, String destination)
           
JmsQueueEndpoint(String endpointUri, String destination, QueueBrowseStrategy queueBrowseStrategy)
           
 
Method Summary
 String browseExchange(Integer index)
           
 String browseMessageAsXml(Integer index)
           
 String browseMessageBody(Integer index)
           
protected  QueueBrowseStrategy createQueueBrowseStrategy()
           
 List<Exchange> getExchanges()
          Return the exchanges available on this endpoint
 int getMaximumBrowseSize()
           
 long queueSize()
           
 void setMaximumBrowseSize(int maximumBrowseSize)
          If a number is set > 0 then this limits the number of messages that are returned when browsing the queue
 
Methods inherited from class org.apache.camel.component.jms.JmsEndpoint
configureListenerContainer, createConsumer, createConsumer, createEndpointUri, createExchange, createExchange, createInOnlyTemplate, createInOutTemplate, createMessageListenerContainer, createPollingConsumer, createProducer, doStart, doStop, getAcknowledgementMode, getAcknowledgementModeName, getBinding, getCacheLevel, getCacheLevelName, getCamelId, getClientId, getConcurrentConsumers, getConfiguration, getConnectionFactory, getDestination, getDestinationName, getDestinationResolver, getDurableSubscriptionName, getEndpointConfiguredDestinationName, getEndpointUri, getExceptionListener, getHeaderFilterStrategy, getIdleTaskExecutionLimit, getJmsKeyFormatStrategy, getJmsMessageType, getJmsOperations, getListenerConnectionFactory, getMaxConcurrentConsumers, getMaxMessagesPerTask, getMessageConverter, getMetadataJmsOperations, getMetadataJmsOperations, getPriority, getProviderMetadata, getReceiveTimeout, getRecoveryInterval, getReplyManager, getReplyManager, getReplyManagerExecutorService, getReplyTo, getReplyToDestinationSelectorName, getRequestTimeout, getSelector, getState, getTaskExecutor, getTemplateConnectionFactory, getTemporaryQueueType, getTemporaryTopicType, getTimeToLive, getTransactionManager, getTransactionName, getTransactionTimeout, isAcceptMessagesWhileStopping, isAlwaysCopyMessage, isAutoStartup, isDeliveryPersistent, isDisableReplyTo, isEagerLoadingOfProperties, isExplicitQosEnabled, isExposeListenerSession, isForceSendOriginalMessage, isMessageIdEnabled, isMessageTimestampEnabled, isMultipleConsumersSupported, isPreserveMessageQos, isPubSubDomain, isPubSubNoLocal, isReplyToDeliveryPersistent, isRunning, isSingleton, isSubscriptionDurable, isTestConnectionOnStartup, isTransacted, isTransactedInOut, isTransferException, isTransferExchange, isUseMessageIDAsCorrelationID, newInstance, newInstance, setAcceptMessagesWhileStopping, setAcknowledgementMode, setAcknowledgementModeName, setAlwaysCopyMessage, setAutoStartup, setBinding, setCacheLevel, setCacheLevelName, setClientId, setConcurrentConsumers, setConfiguration, setConnectionFactory, setDeliveryPersistent, setDestination, setDestinationName, setDestinationResolver, setDisableReplyTo, setDurableSubscriptionName, setEagerLoadingOfProperties, setExceptionListener, setExplicitQosEnabled, setExposeListenerSession, setForceSendOriginalMessage, setHeaderFilterStrategy, setIdleTaskExecutionLimit, setJmsKeyFormatStrategy, setJmsMessageType, setJmsOperations, setListenerConnectionFactory, setMaxConcurrentConsumers, setMaxMessagesPerTask, setMessageConverter, setMessageIdEnabled, setMessageTimestampEnabled, setMetadataJmsOperations, setPreserveMessageQos, setPriority, setProviderMetadata, setPubSubNoLocal, setReceiveTimeout, setRecoveryInterval, setReplyTo, setReplyToDeliveryPersistent, setReplyToDestinationSelectorName, setRequestTimeout, setSelector, setSubscriptionDurable, setTaskExecutor, setTemplateConnectionFactory, setTestConnectionOnStartup, setTimeToLive, setTransacted, setTransactedInOut, setTransactionManager, setTransactionName, setTransactionTimeout, setTransferException, setTransferExchange, setUseMessageIDAsCorrelationID
 
Methods inherited from class org.apache.camel.impl.DefaultEndpoint
configureProperties, createExchange, createExchange, equals, getCamelContext, getComponent, getEndpointKey, getExchangePattern, getExchangeType, getId, hashCode, isLenientProperties, isSynchronous, sanitizeUri, setCamelContext, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setSynchronous, toString
 
Methods inherited from class org.apache.camel.impl.ServiceSupport
addChildService, doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspended, isSuspending, removeChildService, resume, shutdown, start, 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.Endpoint
configureProperties, createConsumer, createExchange, createExchange, createExchange, createPollingConsumer, createProducer, getCamelContext, getEndpointKey, getEndpointUri, isLenientProperties, setCamelContext
 
Methods inherited from interface org.apache.camel.IsSingleton
isSingleton
 
Methods inherited from interface org.apache.camel.Service
start, stop
 

Constructor Detail

JmsQueueEndpoint

public JmsQueueEndpoint(javax.jms.Queue destination)
                 throws javax.jms.JMSException
Throws:
javax.jms.JMSException

JmsQueueEndpoint

public JmsQueueEndpoint(String uri,
                        JmsComponent component,
                        String destination,
                        JmsConfiguration configuration)

JmsQueueEndpoint

public JmsQueueEndpoint(String uri,
                        JmsComponent component,
                        String destination,
                        JmsConfiguration configuration,
                        QueueBrowseStrategy queueBrowseStrategy)

JmsQueueEndpoint

public JmsQueueEndpoint(String endpointUri,
                        String destination,
                        QueueBrowseStrategy queueBrowseStrategy)

JmsQueueEndpoint

public JmsQueueEndpoint(String endpointUri,
                        String destination)
Method Detail

getMaximumBrowseSize

@ManagedAttribute
public int getMaximumBrowseSize()

setMaximumBrowseSize

@ManagedAttribute
public void setMaximumBrowseSize(int maximumBrowseSize)
If a number is set > 0 then this limits the number of messages that are returned when browsing the queue


getExchanges

public List<Exchange> getExchanges()
Description copied from interface: BrowsableEndpoint
Return the exchanges available on this endpoint

Specified by:
getExchanges in interface BrowsableEndpoint
Returns:
the exchanges on this endpoint

queueSize

@ManagedOperation(description="Current number of Exchanges in Queue")
public long queueSize()

browseExchange

@ManagedOperation(description="Get Exchange from queue by index")
public String browseExchange(Integer index)

browseMessageBody

@ManagedOperation(description="Get message body from queue by index")
public String browseMessageBody(Integer index)

browseMessageAsXml

@ManagedOperation(description="Get message as XML from queue by index")
public String browseMessageAsXml(Integer index)

createQueueBrowseStrategy

protected QueueBrowseStrategy createQueueBrowseStrategy()


Apache CAMEL