File tree Expand file tree Collapse file tree 1 file changed +7
-0
lines changed
order-service/src/main/java/net/adiletkdev/orderservice/publisher Expand file tree Collapse file tree 1 file changed +7
-0
lines changed Original file line number Diff line number Diff line change @@ -18,6 +18,9 @@ public class OrderProducer {
18
18
@ Value ("${rabbitmq.binding.routing.key}" )
19
19
private String orderRoutingKey ;
20
20
21
+ @ Value ("${rabbitmq.binding.email.routing.key}" )
22
+ private String emailRoutingKey ;
23
+
21
24
private RabbitTemplate rabbitTemplate ;
22
25
23
26
public OrderProducer (RabbitTemplate rabbitTemplate ) {
@@ -27,6 +30,10 @@ public OrderProducer(RabbitTemplate rabbitTemplate) {
27
30
public void sendMessage (OrderEvent orderEvent ) {
28
31
LOGGER .info (String .format ("Order event sent to RabbitMQ -> %s" , orderEvent .toString ()));
29
32
33
+ // send an order event to order queue
30
34
rabbitTemplate .convertAndSend (exchange , orderRoutingKey , orderEvent );
35
+
36
+ // send an order event to email queue
37
+ rabbitTemplate .convertAndSend (exchange , emailRoutingKey , orderEvent );
31
38
}
32
39
}
You can’t perform that action at this time.
0 commit comments