Class AmqpMessageSource
java.lang.Object
org.springframework.integration.util.AbstractExpressionEvaluator
org.springframework.integration.endpoint.AbstractMessageSource<Object>
org.springframework.integration.amqp.inbound.AmqpMessageSource
- 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 AmqpMessageSource
extends org.springframework.integration.endpoint.AbstractMessageSource<Object>
A pollable
MessageSource for RabbitMQ.- Since:
- 5.0.1
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic classstatic classstatic classInformation for building an AmqpAckCallback.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
ConstructorsConstructorDescriptionAmqpMessageSource(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, String queue) AmqpMessageSource(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, AmqpMessageSource.AmqpAckCallbackFactory ackCallbackFactory, String queue) -
Method Summary
Modifier and TypeMethodDescriptionprotected org.springframework.integration.support.AbstractIntegrationMessageBuilder<Object>protected org.springframework.amqp.rabbit.batch.BatchingStrategyprotected AmqpHeaderMapperprotected org.springframework.amqp.support.converter.MessageConverterprotected org.springframework.amqp.rabbit.support.MessagePropertiesConverterprotected booleanprotected booleanvoidsetBatchingStrategy(org.springframework.amqp.rabbit.batch.BatchingStrategy batchingStrategy) Set a batching strategy to use when de-batching messages.voidsetHeaderMapper(AmqpHeaderMapper headerMapper) Set a customAmqpHeaderMapperto replace the defaultDefaultAmqpHeaderMapper.inboundMapper().voidsetMessageConverter(org.springframework.amqp.support.converter.MessageConverter messageConverter) Set a customMessageConverterto replace the defaultSimpleMessageConverter.voidsetPropertiesConverter(org.springframework.amqp.rabbit.support.MessagePropertiesConverter propertiesConverter) Set a customMessagePropertiesConverterto replace the defaultDefaultMessagePropertiesConverter.voidsetRawMessageHeader(boolean rawMessageHeader) Set to true to include the raw spring-amqp message as a header with keyAmqpMessageHeaderErrorMessageStrategy.AMQP_RAW_MESSAGE, enabling callers to have access to the message to process errors.voidsetTransacted(boolean transacted) Set to true to use a transacted channel for the ack.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, onInit, 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
-
AmqpMessageSource
public AmqpMessageSource(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, String queue) -
AmqpMessageSource
public AmqpMessageSource(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, AmqpMessageSource.AmqpAckCallbackFactory ackCallbackFactory, String queue)
-
-
Method Details
-
isTransacted
protected boolean isTransacted() -
setTransacted
public void setTransacted(boolean transacted) Set to true to use a transacted channel for the ack.- Parameters:
transacted- true for transacted.
-
getPropertiesConverter
protected org.springframework.amqp.rabbit.support.MessagePropertiesConverter getPropertiesConverter() -
setPropertiesConverter
public void setPropertiesConverter(org.springframework.amqp.rabbit.support.MessagePropertiesConverter propertiesConverter) Set a customMessagePropertiesConverterto replace the defaultDefaultMessagePropertiesConverter.- Parameters:
propertiesConverter- the converter.
-
getHeaderMapper
-
setHeaderMapper
Set a customAmqpHeaderMapperto replace the defaultDefaultAmqpHeaderMapper.inboundMapper().- Parameters:
headerMapper- the header mapper.
-
getMessageConverter
protected org.springframework.amqp.support.converter.MessageConverter getMessageConverter() -
setMessageConverter
public void setMessageConverter(org.springframework.amqp.support.converter.MessageConverter messageConverter) Set a customMessageConverterto replace the defaultSimpleMessageConverter.- Parameters:
messageConverter- the converter.
-
isRawMessageHeader
protected boolean isRawMessageHeader() -
setRawMessageHeader
public void setRawMessageHeader(boolean rawMessageHeader) Set to true to include the raw spring-amqp message as a header with keyAmqpMessageHeaderErrorMessageStrategy.AMQP_RAW_MESSAGE, enabling callers to have access to the message to process errors. The raw message is also added to the common headerIntegrationMessageHeaderAccessor.SOURCE_DATA.- Parameters:
rawMessageHeader- true to include the headers.
-
getBatchingStrategy
protected org.springframework.amqp.rabbit.batch.BatchingStrategy getBatchingStrategy() -
setBatchingStrategy
public void setBatchingStrategy(org.springframework.amqp.rabbit.batch.BatchingStrategy batchingStrategy) Set a batching strategy to use when de-batching messages. Default isSimpleBatchingStrategy.- Parameters:
batchingStrategy- the strategy.- Since:
- 5.2
-
getComponentType
-
doReceive
protected org.springframework.integration.support.AbstractIntegrationMessageBuilder<Object> doReceive()- Specified by:
doReceivein classorg.springframework.integration.endpoint.AbstractMessageSource<Object>
-