Typed bus
bus.publish<OrderPlaced>('OrderPlaced', ...) — message type carried in the type system, not just at runtime.
Typed bus
bus.publish<OrderPlaced>('OrderPlaced', ...) — message type carried in the type system, not just at runtime.
Every pattern
Pub/sub, point-to-point, request/reply, scatter-gather, polymorphic, sagas, aggregators, routing slips, streaming — all first class.
Pluggable transport
Ship with @serviceconnect/rabbitmq. Bring your own transport via ITransportProducer + ITransportConsumer.
Wire-compatible with .NET
Same envelope, same headers, same exchange topology. Mix Node.js and .NET services on the same bus.
npm install @serviceconnect/core @serviceconnect/rabbitmqawait bus.start() and publish.The Getting Started walkthrough takes you from zero to a running consumer in about ten minutes.