MessageBus
.See: Description
Interface | Description |
---|---|
BusCleaner |
Interface for implementations that perform cleanup for message buses.
|
BusProperties |
Common bus properties.
|
MessageBus |
A strategy interface used to bind a
MessageChannel to a logical name. |
PartitionKeyExtractorStrategy |
Strategy for extracting a partition key from a Message.
|
PartitionSelectorStrategy |
Strategy for determining the partition to which a message should be sent.
|
Class | Description |
---|---|
AbstractBusPropertiesAccessor |
Base class for bus-specific property accessors; common properties
are defined here.
|
Binding |
Represents a binding between a module's channel and an adapter endpoint that connects to the MessageBus.
|
BusTestUtils | |
BusUtils |
Message Bus utilities.
|
EmbeddedHeadersMessageConverter |
Encodes requested headers into payload with format
{@code 0xff, n(1), [ [lenHdr(1), hdr, lenValue(4), value] ...
|
MessageBusAwareChannelResolver |
A
DestinationResolver implementation that first checks for any channel
whose name begins with a colon in the MessageBus . |
MessageBusAwareRouterBeanPostProcessor |
A
BeanPostProcessor that sets a MessageBusAwareChannelResolver on any bean of type
AbstractMappingMessageRouter within the context. |
MessageBusSupport | |
MessageBusSupport.DirectHandler | |
MessageBusSupport.PartitioningMetadata | |
MessageBusSupport.SetBuilder | |
MessageValues |
A mutable type for allowing
MessageBus implementations to transform and enrich message content more
efficiently. |
RabbitManagementUtils | |
StrictContentTypeResolver |
A
StringConvertingContentTypeResolver that requires a the content-type to be present. |
StringConvertingContentTypeResolver |
A
DefaultContentTypeResolver that can parse String values. |
XdHeaders |
Spring Integration message headers for XD.
|
Enum | Description |
---|---|
MessageBus.Capability |
Exception | Description |
---|---|
MessageBusException |
Exception thrown to indicate a message bus error (most
likely a configuration error).
|
RabbitAdminException |
Exceptions thrown while interfacing with the RabbitMQ admin plugin.
|
SerializationException |
Thrown when something goes wrong with inter-module communication.
|
MessageBus
.