org.apache.camel.component.jms
Class JmsQueueEndpoint

java.lang.Object
  org.apache.camel.impl.ServiceSupport
      org.apache.camel.impl.DefaultEndpoint
          org.apache.camel.component.jms.JmsEndpoint
              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()