Class JmsDestinationPollingSource
java.lang.Object
org.springframework.integration.util.AbstractExpressionEvaluator
org.springframework.integration.endpoint.AbstractMessageSource<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<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<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
Nested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement
org.springframework.integration.support.management.IntegrationManagement.ManagementOverrides -
Field Summary
Fields inherited from class org.springframework.integration.util.AbstractExpressionEvaluator
EXPRESSION_PARSER, loggerFields inherited from interface org.springframework.integration.support.management.IntegrationManagement
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME -
Constructor Summary
ConstructorsConstructorDescriptionJmsDestinationPollingSource(org.springframework.jms.core.JmsTemplate jmsTemplate) -
Method Summary
Modifier and TypeMethodDescriptionprotected ObjectWill receive a JMSMessageconverting and returning it as a Spring IntegrationMessage.protected voidonInit()voidsetDestination(jakarta.jms.Destination destination) voidsetDestinationName(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(String messageSelector) Specify a JMS Message Selector expression to use when receiving Messages.voidsetSessionAcknowledgeMode(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, waitMethods inherited from interface org.springframework.integration.support.management.IntegrationManagement
getThisAs, registerObservationRegistryMethods inherited from interface org.springframework.integration.core.MessageSource
getIntegrationPatternType
-
Constructor Details
-
JmsDestinationPollingSource
public JmsDestinationPollingSource(org.springframework.jms.core.JmsTemplate jmsTemplate)
-
-
Method Details
-
setDestination
public void setDestination(jakarta.jms.Destination destination) -
setDestinationName
-
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
-
setMessageSelector
Specify a JMS Message Selector expression to use when receiving Messages.- Parameters:
messageSelector- The message selector.
-
setHeaderMapper
-
setSessionAcknowledgeMode
-
onInit
protected void onInit()- Overrides:
onInitin classorg.springframework.integration.util.AbstractExpressionEvaluator
-
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<Object>
-