Uses of Interface
org.springframework.integration.amqp.support.AmqpHeaderMapper
Package
Description
Provides classes related to AMQP-backed channels.
Provides classes for configuration - parsers, namespace handlers, factory beans.
Provides AMQP Component support for the Java DSL.
Provides classes supporting inbound endpoints.
Provides classes supporting outbound endpoints.
Provides AMQP support classes.
-
Uses of AmqpHeaderMapper in org.springframework.integration.amqp.channel
Modifier and TypeMethodDescriptionprotected AmqpHeaderMapper
AbstractAmqpChannel.getInboundHeaderMapper()
ModifierConstructorDescriptionPointToPointSubscribableAmqpChannel
(String channelName, AbstractMessageListenerContainer container, AmqpTemplate amqpTemplate, AmqpHeaderMapper outboundMapper, AmqpHeaderMapper inboundMapper) Construct an instance with the supplied name, container and template; default header mappers will be used if the message is mapped.PollableAmqpChannel
(String channelName, AmqpTemplate amqpTemplate, AmqpHeaderMapper outboundMapper, AmqpHeaderMapper inboundMapper) Construct an instance with the supplied name, template and header mappers.PublishSubscribeAmqpChannel
(String channelName, AbstractMessageListenerContainer container, AmqpTemplate amqpTemplate, AmqpHeaderMapper outboundMapper, AmqpHeaderMapper inboundMapper) Construct an instance with the supplied name, container and template; default header mappers will be used if the message is mapped. -
Uses of AmqpHeaderMapper in org.springframework.integration.amqp.config
Modifier and TypeMethodDescriptionvoid
AmqpChannelFactoryBean.setInboundHeaderMapper
(AmqpHeaderMapper inboundMapper) void
AmqpChannelFactoryBean.setOutboundHeaderMapper
(AmqpHeaderMapper outboundMapper) -
Uses of AmqpHeaderMapper in org.springframework.integration.amqp.dsl
Modifier and TypeMethodDescriptionAmqpBaseInboundChannelAdapterSpec.headerMapper
(AmqpHeaderMapper headerMapper) Configure the adapter'sAmqpHeaderMapper
; defaults toDefaultAmqpHeaderMapper
.AmqpBaseInboundGatewaySpec.headerMapper
(AmqpHeaderMapper headerMapper) Configure the gateway'sAmqpHeaderMapper
; defaults toDefaultAmqpHeaderMapper
.AmqpBaseOutboundEndpointSpec.headerMapper
(AmqpHeaderMapper headerMapper) Set a customAmqpHeaderMapper
for mapping request and reply headers.AmqpInboundPolledChannelAdapterSpec.headerMapper
(AmqpHeaderMapper headerMapper) RabbitStreamMessageHandlerSpec.headerMapper
(AmqpHeaderMapper headerMapper) Set a customAmqpHeaderMapper
for mapping request and reply headers.AmqpPollableMessageChannelSpec.inboundHeaderMapper
(AmqpHeaderMapper mapper) Configure the inbound header mapper to use whenAmqpPollableMessageChannelSpec.extractPayload(boolean)
is true.AmqpPollableMessageChannelSpec.outboundHeaderMapper
(AmqpHeaderMapper mapper) Configure the outbound header mapper to use whenAmqpPollableMessageChannelSpec.extractPayload(boolean)
is true. -
Uses of AmqpHeaderMapper in org.springframework.integration.amqp.inbound
Modifier and TypeMethodDescriptionvoid
AmqpInboundChannelAdapter.setHeaderMapper
(AmqpHeaderMapper headerMapper) void
AmqpInboundGateway.setHeaderMapper
(AmqpHeaderMapper headerMapper) void
AmqpMessageSource.setHeaderMapper
(AmqpHeaderMapper headerMapper) Set a customAmqpHeaderMapper
to replace the defaultDefaultAmqpHeaderMapper.inboundMapper()
. -
Uses of AmqpHeaderMapper in org.springframework.integration.amqp.outbound
Modifier and TypeMethodDescriptionvoid
AbstractAmqpOutboundEndpoint.setHeaderMapper
(AmqpHeaderMapper headerMapper) Set a customAmqpHeaderMapper
for mapping request and reply headers.void
RabbitStreamMessageHandler.setHeaderMapper
(AmqpHeaderMapper headerMapper) Set a customAmqpHeaderMapper
for mapping request and reply headers. -
Uses of AmqpHeaderMapper in org.springframework.integration.amqp.support
Modifier and TypeMethodDescriptionstatic Message
MappingUtils.mapMessage
(Message<?> message, MessageConverter converter, AmqpHeaderMapper headerMapper, boolean headersMappedLast, boolean reply, MessageProperties amqpMessageProperties) Map a reply o.s.m.Message to an o.s.a.core.Message.static Message
MappingUtils.mapMessage
(Message<?> requestMessage, MessageConverter converter, AmqpHeaderMapper headerMapper, MessageDeliveryMode defaultDeliveryMode, boolean headersMappedLast) Map an o.s.m.Message to an o.s.a.core.Message.static Message
MappingUtils.mapReplyMessage
(Message<?> replyMessage, MessageConverter converter, AmqpHeaderMapper headerMapper, MessageDeliveryMode defaultDeliveryMode, boolean headersMappedLast) Map a reply o.s.m.Message to an o.s.a.core.Message.