publisher

May 4, 2021

Changes in this version

+ const RabbitMQDelayHeader

+ type KafkaPublisher struct

+ func NewKafkaPublisher(client sarama.Client) *KafkaPublisher

+ func (p *KafkaPublisher) PublishMessage(ctx context.Context, args *candishared.PublisherArgument) (err error)

+ type RabbitMQPublisher struct

+ func NewRabbitMQPublisher(conn *amqp.Connection) *RabbitMQPublisher

+ func (r *RabbitMQPublisher) PublishMessage(ctx context.Context, args *candishared.PublisherArgument) (err error)