contract

type Bus interface {
	Dispatch(runtimeInstance runtimecontract.Runtime, message any, stamps ...Stamp) (Envelope, error)
}

type Envelope interface {
	Message() any

	Stamps() []Stamp

	WithStamp(stamps ...Stamp) Envelope
}

type HandlerLocator interface {
	HandlersFor(message any) []MessageHandler
}

type MessageHandler interface {
	Handle(runtimeInstance runtimecontract.Runtime, message any) error
}

type Middleware func(runtimeInstance runtimecontract.Runtime, envelope Envelope, next StackNext) (Envelope, error)

type StackNext func(runtimeInstance runtimecontract.Runtime, envelope Envelope) (Envelope, error)

type Stamp interface {
	StampName() string
}

type Transport interface {
	Send(runtimeInstance runtimecontract.Runtime, envelope Envelope) error

	Receive(runtimeInstance runtimecontract.Runtime) (<-chan Envelope, error)

	Ack(runtimeInstance runtimecontract.Runtime, envelope Envelope) error

	Nack(runtimeInstance runtimecontract.Runtime, envelope Envelope, requeue bool) error

	Close(runtimeInstance runtimecontract.Runtime) error
}