public class AmqpMessageSource
extends org.springframework.integration.endpoint.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.
|
| 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 org.springframework.integration.support.AbstractIntegrationMessageBuilder<java.lang.Object> |
doReceive() |
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, getComponentName, getManagedName, getManagedType, getMessageCount, getMessageCountLong, getOverrides, isCountsEnabled, isLoggingEnabled, receive, registerMetricsCaptor, reset, setBeanName, setCountsEnabled, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedTypeafterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, onInit, setBeanFactory, setConversionServicepublic 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 org.springframework.integration.support.AbstractIntegrationMessageBuilder<java.lang.Object> doReceive()
doReceive in class org.springframework.integration.endpoint.AbstractMessageSource<java.lang.Object>