subscription

type Func func(msg *message.Message)

type Subscription struct {
	common.Common

	// Func is the function to call when a message is received. It handles the
	// message.
	Func Func `json:"-"`

	// Channel is the channel to receive messages.
	Channel chan *message.Message `json:"-"`
}