queue

type ConsumeHandle func(ctx context.Context, topic string, key, message []byte) error

type ConsumeHandler interface {
	Consume(ctx context.Context, topic string, key, message []byte) error
}

type MessageQueue interface {
	Name() string
	Start(context.Context) error
	Stop(context.Context) error
}

type Pusher interface {
	Name() string
	Push(ctx context.Context, key, value []byte) error
	Close() error
}

type Sender interface {
	Name() string
	Send(ctx context.Context, header map[string]interface{}, exchange string, routeKey string, msg []byte) error
	Close() error
}