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:

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.BrowsableEndpoint, org.apache.camel.spi.HasId, org.apache.camel.spi.HeaderFilterStrategyAware

Direct Known Subclasses:

JmsTemporaryQueueEndpoint

@ManagedResource(description="Managed JMS Queue Endpoint")
public class JmsQueueEndpoint
extends JmsEndpoint
implements org.apache.camel.spi.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)
protected QueueBrowseStrategy	createQueueBrowseStrategy()
List<org.apache.camel.Exchange>	getExchanges()
int	getMaximumBrowseSize()
long	qeueSize()
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, 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<org.apache.camel.Exchange> getExchanges()

Specified by:

getExchanges in interface org.apache.camel.spi.BrowsableEndpoint

qeueSize

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

browseExchange

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

createQueueBrowseStrategy

protected QueueBrowseStrategy createQueueBrowseStrategy()