broker

type Handler interface {
	PublishInterface
	SubscribeInterface
}

type Message struct {
	Type   string
	Object interface{}
}

type PublishInterface interface {
	Publish(string, interface{}) error
	PublishWithCallback(string, string, interface{}) error
}

type SubscribeInterface interface {
	Subscribe(string, string) error
	SubscribeWithHandler(string, string) error
}