messaging

type MessageHandler interface {
	Handle(msg []byte) error
}

type Receiver interface {
	Start(h MessageHandler) error
	Stop() error
}

type Sender interface {
	Send([]byte) error
}