Skip to content
CephalonEngine

Namespace Cephalon.Behaviors.Messaging.Bindings

Classes

Section titled “Classes”

InMemoryTransportBinding

In-memory messaging transport binding (transport ID: “in-memory”). Uses a bounded with backpressure internally. No external dependencies — suitable for testing and local development.

KafkaTransportBinding

Kafka messaging transport binding (transport ID: “kafka”). Consumes messages from a Kafka topic and dispatches them through the ABT behavior dispatcher. Manually commits offsets after successful dispatch. Supports partition assignment/revocation logging.

RabbitMqTransportBinding

RabbitMQ messaging transport binding (transport ID: “rabbitmq”). Uses a lazy connection strategy — the broker connection is established only on , not at construction time.