fix bug

dmp-alarm/src/main/java/com/persagy/dmp/alarm/jms/JmsConfig.java

@@ -76,7 +76,7 @@ public class JmsConfig {
 		return BindingBuilder.bind(alarmObjQueue()).to(exchange()).with(alarmObjRoutingKey);
 	}
 
-	@RabbitListener(queues = {alarmObjQueue, "${persagy.dmp.alarm.queue}"})    //监听器监听指定的Queue
+	@RabbitListener(queues = {alarmObjQueue})    //监听器监听指定的Queue
 	public void process(String message, Channel channel, Message msg) {
 		log.info("============================== Receive:" + message);
 		DmpMessage dmpMessage = JacksonMapper.toObject(message, DmpMessage.class);
@@ -89,10 +89,16 @@ public class JmsConfig {
 		}
 	}
 
-//	@RabbitListener(queues = "${persagy.dmp.alarm.queue}")    //监听器监听指定的Queue
-//	public void process(DmpMessage message) {
-//		log.info("============================== Receive:" + JacksonMapper.toSimpleJson(message));
-//		messageProcesser.listen(message);
-//	}
+	@RabbitListener(queues = "${persagy.dmp.alarm.queue}")    //监听器监听指定的Queue
+	public void process(DmpMessage message, Channel channel, Message msg) {
+		log.info("============================== Receive:" + JacksonMapper.toSimpleJson(message));
+		messageProcesser.listen(message);
+		// 手动确认消息已消费
+		try {
+			channel.basicAck(msg.getMessageProperties().getDeliveryTag(),false);
+		} catch (IOException e) {
+			log.error("消息消费反馈失败", e);
+		}
+	}
 
 }

dmp-alarm/src/main/resources/bootstrap.yml

@@ -5,8 +5,9 @@ spring:
     active: log-dev
   cloud:
     config:
-      profile: dev
-      uri: http://192.168.100.107:9932
+      profile: dev2
+#      uri: http://192.168.100.107:9932
+      uri: http://192.168.64.18:9932
       #      profile: dev2
 #      uri: http://192.168.64.18:9932
 persagy: