|
@@ -1,29 +1,29 @@
|
|
|
-//package org.jeecg.modules.cloud.rabbitmq;
|
|
|
-//
|
|
|
-//import com.rabbitmq.client.Channel;
|
|
|
-//import org.jeecg.boot.starter.rabbitmq.core.BaseRabbiMqHandler;
|
|
|
-//import org.jeecg.boot.starter.rabbitmq.listenter.MqListener;
|
|
|
-//import org.jeecg.common.annotation.RabbitComponent;
|
|
|
-//import org.jeecg.common.base.BaseMap;
|
|
|
-//import org.springframework.amqp.rabbit.annotation.RabbitHandler;
|
|
|
-//import org.springframework.amqp.rabbit.annotation.RabbitListener;
|
|
|
-//import org.springframework.amqp.support.AmqpHeaders;
|
|
|
-//import org.springframework.messaging.handler.annotation.Header;
|
|
|
-//
|
|
|
-//@RabbitListener(queues = "jeecg_place_order_time")
|
|
|
-//@RabbitComponent(value = "helloTimeReceiver")
|
|
|
-//public class HelloTimeReceiver extends BaseRabbiMqHandler<BaseMap> {
|
|
|
-//
|
|
|
-// @RabbitHandler
|
|
|
-// public void onMessage(BaseMap baseMap, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long deliveryTag) {
|
|
|
-// super.onMessage(baseMap, deliveryTag, channel, new MqListener<BaseMap>() {
|
|
|
-// @Override
|
|
|
-// public void handler(BaseMap map, Channel channel) {
|
|
|
-// //业务处理
|
|
|
-// String orderId = map.get("orderId").toString();
|
|
|
-// System.out.println("Receiver1 : " + orderId);
|
|
|
-// }
|
|
|
-// });
|
|
|
-// }
|
|
|
-//
|
|
|
-//}
|
|
|
+package org.jeecg.modules.cloud.rabbitmq;
|
|
|
+
|
|
|
+import com.rabbitmq.client.Channel;
|
|
|
+import org.jeecg.boot.starter.rabbitmq.core.BaseRabbiMqHandler;
|
|
|
+import org.jeecg.boot.starter.rabbitmq.listenter.MqListener;
|
|
|
+import org.jeecg.common.annotation.RabbitComponent;
|
|
|
+import org.jeecg.common.base.BaseMap;
|
|
|
+import org.springframework.amqp.rabbit.annotation.RabbitHandler;
|
|
|
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
|
|
|
+import org.springframework.amqp.support.AmqpHeaders;
|
|
|
+import org.springframework.messaging.handler.annotation.Header;
|
|
|
+
|
|
|
+@RabbitListener(queues = "jeecg_place_order_time")
|
|
|
+@RabbitComponent(value = "helloTimeReceiver")
|
|
|
+public class HelloTimeReceiver extends BaseRabbiMqHandler<BaseMap> {
|
|
|
+
|
|
|
+ @RabbitHandler
|
|
|
+ public void onMessage(BaseMap baseMap, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long deliveryTag) {
|
|
|
+ super.onMessage(baseMap, deliveryTag, channel, new MqListener<BaseMap>() {
|
|
|
+ @Override
|
|
|
+ public void handler(BaseMap map, Channel channel) {
|
|
|
+ //业务处理
|
|
|
+ String orderId = map.get("orderId").toString();
|
|
|
+ System.out.println("Receiver1 : " + orderId);
|
|
|
+ }
|
|
|
+ });
|
|
|
+ }
|
|
|
+
|
|
|
+}
|