mq

type Client struct {
	*amqp.Connection
	// contains filtered or unexported fields
}

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

type DefaultMarshal struct {
	PostprocessPublishing     func(amqp.Publishing) amqp.Publishing
	NotPersistentDeliveryMode bool
	MessageUUIDHeaderKey      string
}

type MarshalAPI interface {
	Marshal(msg *message.Message) (amqp.Publishing, error)
	Unmarshal(amqpMsg *amqp.Delivery) (*message.Message, error)
}

type NoopPublisher struct {
}

type Option struct {
	Config     *amqp.Config
	URI        string
	Marshal    MarshalAPI
	QueueName  func(topic string) string
	Exchange   string
	RoutingKey string
}

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