Class JmsDestinationPollingSource
java.lang.Object
org.springframework.integration.util.AbstractExpressionEvaluator
org.springframework.integration.endpoint.AbstractMessageSource<java.lang.Object>
org.springframework.integration.jms.JmsDestinationPollingSource
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.BeanNameAware,org.springframework.beans.factory.DisposableBean,org.springframework.beans.factory.InitializingBean,org.springframework.integration.core.MessageSource<java.lang.Object>,org.springframework.integration.IntegrationPattern,org.springframework.integration.support.context.NamedComponent,org.springframework.integration.support.management.IntegrationInboundManagement,org.springframework.integration.support.management.IntegrationManagement
public class JmsDestinationPollingSource
extends org.springframework.integration.endpoint.AbstractMessageSource<java.lang.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.-
Nested Class Summary
-
Field Summary
-
Constructor Summary
Constructors Constructor Description JmsDestinationPollingSource(org.springframework.jms.core.JmsTemplate jmsTemplate) -
Method Summary
Modifier and Type Method Description protected java.lang.ObjectdoReceive()Will receive a JMSMessageconverting and returning it as a Spring IntegrationMessage.java.lang.StringgetComponentType()protected voidonInit()voidsetDestination(javax.jms.Destination destination)voidsetDestinationName(java.lang.String destinationName)voidsetExtractPayload(boolean extractPayload)The flag to indicate if we should extractbodyfrom JMS Message, or use the received JMS Message asMessagepayload.voidsetHeaderMapper(JmsHeaderMapper headerMapper)voidsetMessageSelector(java.lang.String messageSelector)Specify a JMS Message Selector expression to use when receiving Messages.voidsetSessionAcknowledgeMode(java.lang.String sessionAcknowledgeMode)Methods inherited from class org.springframework.integration.endpoint.AbstractMessageSource
buildMessage, destroy, getBeanName, getComponentName, getManagedName, getManagedType, getOverrides, isLoggingEnabled, receive, registerMetricsCaptor, setBeanName, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedTypeMethods inherited from class org.springframework.integration.util.AbstractExpressionEvaluator
afterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, setBeanFactory, setConversionServiceMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Constructor Details
-
JmsDestinationPollingSource
public JmsDestinationPollingSource(org.springframework.jms.core.JmsTemplate jmsTemplate)
-
-
Method Details
-
setDestination
public void setDestination(javax.jms.Destination destination) -
setDestinationName
public void setDestinationName(java.lang.String destinationName) -
setExtractPayload
public void setExtractPayload(boolean extractPayload)The flag to indicate if we should extractbodyfrom JMS Message, or use the received JMS Message asMessagepayload.- Parameters:
extractPayload- the boolean flag. Defaults totrue.- Since:
- 3.0.7
-
getComponentType
public java.lang.String getComponentType() -
setMessageSelector
public void setMessageSelector(java.lang.String messageSelector)Specify a JMS Message Selector expression to use when receiving Messages.- Parameters:
messageSelector- The message selector.
-
setHeaderMapper
-
setSessionAcknowledgeMode
public void setSessionAcknowledgeMode(java.lang.String sessionAcknowledgeMode) -
onInit
protected void onInit()- Overrides:
onInitin classorg.springframework.integration.util.AbstractExpressionEvaluator
-
doReceive
protected java.lang.Object doReceive()Will receive a JMSMessageconverting and returning it as a Spring IntegrationMessage. This method will also use the currentJmsHeaderMapperinstance to map JMS properties to the MessageHeaders.- Specified by:
doReceivein classorg.springframework.integration.endpoint.AbstractMessageSource<java.lang.Object>
-