rabbitmq

type Client interface {
	Connect() error
	Init(initializer TopologyInitializer) error
	Cast(ctx context.Context, request Delivery) error
	Call(ctx context.Context, request Delivery) (Response, error)
	Listen(ctx context.Context, queue string, autoAck, exclusive, noLocal, noWait bool, args amqp.Table, handler MessageHandler) chan error
	Stop() error
}

type Delivery struct {
	Headers    amqp.Table
	Body       []byte
	Exchange   string
	RoutingKey string
}

type MessageHandler func(ctx context.Context, delivery Delivery, reply ReplyFunc) error

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

type ReplyFunc func(ctx context.Context, response Response) error

type Response struct {
	Headers amqp.Table
	Body    []byte
}

type TopologyInitializer func(builder topology.Builder) error