transport

type InboundMessageHandler func(message []byte) error

type InboundProvider interface {
	InboundMessageHandler() InboundMessageHandler
	Packager() transport.Packager
}

type InboundTransport interface {
	// starts the inbound transport
	Start(prov InboundProvider) error

	// stops the inbound transport
	Stop() error

	// returns the endpoint
	Endpoint() string
}

type OutboundTransport interface {
	// Send send a2a exchange data
	Send(data []byte, destination string) (string, error)
	// Accept url
	Accept(string) bool
}