public class AmqpMessageSource extends AbstractMessageSource<java.lang.Object>
MessageSource
for RabbitMQ.Modifier and Type | Class and Description |
---|---|
static class |
AmqpMessageSource.AmqpAckCallback |
static class |
AmqpMessageSource.AmqpAckCallbackFactory |
static class |
AmqpMessageSource.AmqpAckInfo
Information for building an AmqpAckCallback.
|
IntegrationManagement.ManagementOverrides
EXPRESSION_PARSER, logger
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
Constructor and Description |
---|
AmqpMessageSource(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory,
AmqpMessageSource.AmqpAckCallbackFactory ackCallbackFactory,
java.lang.String queue) |
AmqpMessageSource(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory,
java.lang.String queue) |
Modifier and Type | Method and Description |
---|---|
protected AbstractIntegrationMessageBuilder<java.lang.Object> |
doReceive()
Subclasses must implement this method.
|
java.lang.String |
getComponentType() |
protected AmqpHeaderMapper |
getHeaderMapper() |
protected org.springframework.amqp.support.converter.MessageConverter |
getMessageConverter() |
protected org.springframework.amqp.rabbit.support.MessagePropertiesConverter |
getPropertiesConverter() |
protected boolean |
isRawMessageHeader() |
protected boolean |
isTransacted() |
void |
setHeaderMapper(AmqpHeaderMapper headerMapper)
Set a custom
AmqpHeaderMapper to replace the default
DefaultAmqpHeaderMapper.inboundMapper() . |
void |
setMessageConverter(org.springframework.amqp.support.converter.MessageConverter messageConverter)
Set a custom
MessageConverter to replace the default
SimpleMessageConverter . |
void |
setPropertiesConverter(org.springframework.amqp.rabbit.support.MessagePropertiesConverter propertiesConverter)
Set a custom
MessagePropertiesConverter to replace the default
DefaultMessagePropertiesConverter . |
void |
setRawMessageHeader(boolean rawMessageHeader)
Set to true to include the raw spring-amqp message as a header
with key
AmqpMessageHeaderErrorMessageStrategy.AMQP_RAW_MESSAGE ,
enabling callers to have access to the message to process errors. |
void |
setTransacted(boolean transacted)
Set to true to use a transacted channel for the ack.
|
buildMessage, destroy, getComponentName, getManagedName, getManagedType, getMessageCount, getMessageCountLong, getOverrides, isCountsEnabled, isLoggingEnabled, receive, registerMetricsCaptor, reset, setBeanName, setCountsEnabled, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedType
afterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, onInit, setBeanFactory, setConversionService
public AmqpMessageSource(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, java.lang.String queue)
public AmqpMessageSource(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, AmqpMessageSource.AmqpAckCallbackFactory ackCallbackFactory, java.lang.String queue)
protected boolean isTransacted()
public void setTransacted(boolean transacted)
transacted
- true for transacted.protected org.springframework.amqp.rabbit.support.MessagePropertiesConverter getPropertiesConverter()
public void setPropertiesConverter(org.springframework.amqp.rabbit.support.MessagePropertiesConverter propertiesConverter)
MessagePropertiesConverter
to replace the default
DefaultMessagePropertiesConverter
.propertiesConverter
- the converter.protected AmqpHeaderMapper getHeaderMapper()
public void setHeaderMapper(AmqpHeaderMapper headerMapper)
AmqpHeaderMapper
to replace the default
DefaultAmqpHeaderMapper.inboundMapper()
.headerMapper
- the header mapper.protected org.springframework.amqp.support.converter.MessageConverter getMessageConverter()
public void setMessageConverter(org.springframework.amqp.support.converter.MessageConverter messageConverter)
MessageConverter
to replace the default
SimpleMessageConverter
.messageConverter
- the converter.protected boolean isRawMessageHeader()
public void setRawMessageHeader(boolean rawMessageHeader)
AmqpMessageHeaderErrorMessageStrategy.AMQP_RAW_MESSAGE
,
enabling callers to have access to the message to process errors.rawMessageHeader
- true to include the header.public java.lang.String getComponentType()
protected AbstractIntegrationMessageBuilder<java.lang.Object> doReceive()
AbstractMessageSource
payload
of
type T, but the returned value may also be a Message
instance whose payload is of type T;
also can be AbstractIntegrationMessageBuilder
which is used for additional headers population.doReceive
in class AbstractMessageSource<java.lang.Object>