org.springframework.integration.jms

Class JmsDestinationPollingSource

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.jms.JmsDestinationPollingSource

All Implemented Interfaces:

Aware, BeanFactoryAware, BeanNameAware, InitializingBean, ApplicationContextAware, MessageSource<Object>, NamedComponent

public class JmsDestinationPollingSource
extends IntegrationObjectSupport
implements MessageSource<Object>

A source for receiving JMS Messages with a polling listener. This source is only recommended for very low message volume. Otherwise, the JmsMessageDrivenEndpoint that uses Spring's MessageListener container support is a better option.

Author:

Mark Fisher, Oleg Zhurakousky

Field Summary

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

logger

Constructor Summary

Constructors

Constructor and Description
JmsDestinationPollingSource(JmsTemplate jmsTemplate)

Method Summary

Methods

Modifier and Type	Method and Description
String	getComponentType() Subclasses may implement this method to provide component type information.
Message<Object>	receive() Will receive a JMS Message converting and returning it as a Spring Integration Message.
void	setDestination(Destination destination)
void	setDestinationName(String destinationName)
void	setHeaderMapper(JmsHeaderMapper headerMapper)
void	setMessageSelector(String messageSelector) Specify a JMS Message Selector expression to use when receiving Messages.

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, onInit, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setMessageBuilderFactory, setTaskScheduler, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

JmsDestinationPollingSource

public JmsDestinationPollingSource(JmsTemplate jmsTemplate)

Method Detail

setDestination

public void setDestination(Destination destination)

setDestinationName

public void setDestinationName(String destinationName)

getComponentType

public String getComponentType()

Description copied from class: IntegrationObjectSupport

Subclasses may implement this method to provide component type information.

Specified by:

getComponentType in interface NamedComponent

Overrides:

getComponentType in class IntegrationObjectSupport

setMessageSelector

public void setMessageSelector(String messageSelector)

Specify a JMS Message Selector expression to use when receiving Messages.

Parameters:

messageSelector - The message selector.

setHeaderMapper

public void setHeaderMapper(JmsHeaderMapper headerMapper)

receive

public Message<Object> receive()

Will receive a JMS Message converting and returning it as a Spring Integration Message. This method will also use the current JmsHeaderMapper instance to map JMS properties to the MessageHeaders.

Specified by:

receive in interface MessageSource<Object>

Returns:

The messasge or null.