Package org.springframework.xd.dirt.integration.bus

Package for DIRT classes that integrate with MessageBus.

See: Description

Interface Summary

Interface	Description
BusProperties	Common bus properties.
ConnectionPropertyNames	MessageBus specific property names that each message bus uses.
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 Summary

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
EmbeddedHeadersMessageConverter	Encodes requested headers into payload with format {@code 0xff, n(1), [ [lenHdr(1), hdr, lenValue(4), value] ...
KafkaConnectionPropertyNames	Kafka message bus specific property names.
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
RabbitConnectionPropertyNames	Rabbit message bus specific property names.
RedisConnectionPropertyNames	Redis message bus specific property names.
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.

Exception Summary

Exception	Description
MessageBusException	Exception thrown to indicate a message bus error (most likely a configuration error).

Package org.springframework.xd.dirt.integration.bus Description

Package for DIRT classes that integrate with MessageBus.