Class JmsDestinationPollingSource
java.lang.Object
org.springframework.integration.util.AbstractExpressionEvaluator
org.springframework.integration.endpoint.AbstractMessageSource<Object>
org.springframework.integration.jms.JmsDestinationPollingSource
- All Implemented Interfaces:
Aware
,BeanFactoryAware
,BeanNameAware
,DisposableBean
,InitializingBean
,MessageSource<Object>
,IntegrationPattern
,NamedComponent
,IntegrationInboundManagement
,IntegrationManagement
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, Artem Bilan
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement
IntegrationManagement.ManagementOverrides
-
Field Summary
Fields inherited from class org.springframework.integration.util.AbstractExpressionEvaluator
EXPRESSION_PARSER, logger
Fields inherited from interface org.springframework.integration.support.management.IntegrationManagement
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected Object
protected void
onInit()
void
setDestination
(Destination destination) void
setDestinationName
(String destinationName) void
setExtractPayload
(boolean extractPayload) The flag to indicate if we should extractbody
from JMS Message, or use the received JMS Message asMessage
payload
.void
setHeaderMapper
(JmsHeaderMapper headerMapper) void
setMessageSelector
(String messageSelector) Specify a JMS Message Selector expression to use when receiving Messages.void
setSessionAcknowledgeMode
(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, setManagedType
Methods inherited from class org.springframework.integration.util.AbstractExpressionEvaluator
afterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, setBeanFactory, setConversionService
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.springframework.integration.support.management.IntegrationManagement
getThisAs, isObserved, registerObservationRegistry
Methods inherited from interface org.springframework.integration.core.MessageSource
getIntegrationPatternType
-
Constructor Details
-
JmsDestinationPollingSource
-
-
Method Details
-
setDestination
-
setDestinationName
-
setExtractPayload
public void setExtractPayload(boolean extractPayload) The flag to indicate if we should extractbody
from JMS Message, or use the received JMS Message asMessage
payload
.- Parameters:
extractPayload
- the boolean flag. Defaults totrue
.- Since:
- 3.0.7
-
getComponentType
-
setMessageSelector
Specify a JMS Message Selector expression to use when receiving Messages.- Parameters:
messageSelector
- The message selector.
-
setHeaderMapper
-
setSessionAcknowledgeMode
-
onInit
protected void onInit()- Overrides:
onInit
in classAbstractExpressionEvaluator
-
doReceive
Will receive a JMSMessage
converting and returning it as a Spring IntegrationMessage
. This method will also use the currentJmsHeaderMapper
instance to map JMS properties to the MessageHeaders.- Specified by:
doReceive
in classAbstractMessageSource<Object>
- Returns:
- The value returned.
-