bus

type Event struct {
	Flag    string      `json:"flag,omitempty"`
	Topic   string      `json:"topic,omitempty"`
	Message interface{} `json:"message,omitempty"`
	Params  interface{} `json:"params,omitempty"`
	Queue   string      `json:"queue,omitempty"`
	// contains filtered or unexported fields
}

type Handler func(*Event) error

type Subscriber struct {
	// contains filtered or unexported fields
}