Update amqp-order-handler.go
This commit is contained in:
@@ -51,13 +51,14 @@ func (h *AmqpOrderHandler) OrderCompleted(body []byte) error {
|
|||||||
defer cancel()
|
defer cancel()
|
||||||
|
|
||||||
return ch.PublishWithContext(ctx,
|
return ch.PublishWithContext(ctx,
|
||||||
"orders", // exchange
|
"", // exchange
|
||||||
"new", // routing key
|
"orders", // routing key
|
||||||
false, // mandatory
|
false, // mandatory
|
||||||
false, // immediate
|
false, // immediate
|
||||||
amqp.Publishing{
|
amqp.Publishing{
|
||||||
ContentType: "application/json",
|
DeliveryMode: amqp.Persistent,
|
||||||
Body: body,
|
ContentType: "application/json",
|
||||||
|
Body: body,
|
||||||
})
|
})
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user