bus

type BusData struct {
	Topic string `json:"topic" yaml:"topic"`
	Data  []byte `json:"data" yaml:"data"`
}

type CallBackFunc func(data *BusData)

type Plugin interface {
	Name() string
	Close() error
	Publish(topic string, data interface{}) error
	Subscribe(topic string, handler CallBackFunc) (int64, error)
	Unsubscribe(topic string, subscriptionID int64) error
	QueueSubscribe(topic, queueName string, handler CallBackFunc) (int64, error)
	QueueUnsubscribe(topic, queueName string, subscriptionID int64) error
	UnsubscribeAll(topic string) error
	PausePublish()
	ResumePublish()
	TopicPrefix() string
}