common

type Backend interface {
	//Connect(url string, opts interface{}) error
	Get()
	GetDefault() chan Message
}

type Message struct {
	// Source split by path separator
	TS time.Time
	// true if it is TS from actual queue, false if it is just receive time
	TSReliable bool
	Source     []string
	Headers    map[string]interface{}
	Body       []byte
}