unable to use properties

[khalil-farashiani]

hey, I want to use the x-delayed-message plugin for rabbitmq. the rabbitmq document says:

 AMQP.BasicProperties.Builder props = new AMQP.BasicProperties.Builder();
headers = new HashMap<String, Object>();
headers.put("x-delay", 5000);
props.headers(headers);
channel.basicPublish("my-exchange", "", props.build(), messageBodyBytes);  

How can I do this with the amqp091-go package?

[Gsantomaggio]

I haven't tried but it should be something like that:

headers:= amqp.Table{}
headers["x-delay"] = 5000
if err := channel.Publish(
	exchange,   // publish to an exchange
	routingKey, // routing to 0 or more queues
	false,      // mandatory
	false,      // immediate
	amqp.Publishing{
		Headers:         headers,
		ContentType:     "text/plain",
		ContentEncoding: "",
		Body:            []byte(body),
		DeliveryMode:    amqp.Transient, // 1=non-persistent, 2=persistent
		Priority:        0,              // 0-9
		// a bunch of application/implementation-specific fields
	},
); err != nil {
	return fmt.Errorf("Exchange Publish: %s", err)
}