|
@@ -46,7 +46,7 @@ public class CaeMQ extends CaeViewMFMqDynamic {
|
|
public CaeMQ(MFMqConfig mfMqConfig) {
|
|
public CaeMQ(MFMqConfig mfMqConfig) {
|
|
super(mfMqConfig);
|
|
super(mfMqConfig);
|
|
// setLocalMqOp(new CaeMqOp(),"caedyout");//设置监听
|
|
// setLocalMqOp(new CaeMqOp(),"caedyout");//设置监听
|
|
- setLocalMqOp(new CaeMqOp(),"caeoutt");//设置监听
|
|
|
|
|
|
+ setLocalMqOp(new CaeMqOp(),"caeout");//设置监听
|
|
// setDefOp(new CaeMqOp());//设置默认监听
|
|
// setDefOp(new CaeMqOp());//设置默认监听
|
|
}
|
|
}
|
|
|
|
|
|
@@ -57,7 +57,7 @@ public class CaeMQ extends CaeViewMFMqDynamic {
|
|
|
|
|
|
@Override
|
|
@Override
|
|
public String[] declareListenerQueueLocal(){
|
|
public String[] declareListenerQueueLocal(){
|
|
- return new String[]{"caeoutt"};
|
|
|
|
|
|
+ return new String[]{"caeout"};
|
|
// return new String[]{};
|
|
// return new String[]{};
|
|
}
|
|
}
|
|
|
|
|
|
@@ -67,8 +67,8 @@ public class CaeMQ extends CaeViewMFMqDynamic {
|
|
//TTLMS: 0,不设置x-message-ttl 参数
|
|
//TTLMS: 0,不设置x-message-ttl 参数
|
|
//enableDlx : false 不申明dlx queue
|
|
//enableDlx : false 不申明dlx queue
|
|
List<MFMqInfo> mfMqInfoList=new ArrayList<>();
|
|
List<MFMqInfo> mfMqInfoList=new ArrayList<>();
|
|
- mfMqInfoList.add(new MFMqInfo("caeint","caeint",0,false,MFMqInfo.MFMQExchangeType.GLOBAL_DATA));
|
|
|
|
- mfMqInfoList.add(new MFMqInfo("caeoutt","caeoutt",0,false,MFMqInfo.MFMQExchangeType.GLOBAL_DATA));
|
|
|
|
|
|
+ mfMqInfoList.add(new MFMqInfo("caein","caein",0,false,MFMqInfo.MFMQExchangeType.GLOBAL_DATA));
|
|
|
|
+ mfMqInfoList.add(new MFMqInfo("caeout","caeout",0,false,MFMqInfo.MFMQExchangeType.GLOBAL_DATA));
|
|
return mfMqInfoList;
|
|
return mfMqInfoList;
|
|
}
|
|
}
|
|
|
|
|
|
@@ -77,14 +77,14 @@ public class CaeMQ extends CaeViewMFMqDynamic {
|
|
* @param data
|
|
* @param data
|
|
*/
|
|
*/
|
|
public void sendCaein(String data){
|
|
public void sendCaein(String data){
|
|
- sendData("caeint",data);
|
|
|
|
|
|
+ sendData("caein",data);
|
|
}
|
|
}
|
|
/**
|
|
/**
|
|
* 向未处理信息队列 发送消息
|
|
* 向未处理信息队列 发送消息
|
|
* @param data
|
|
* @param data
|
|
*/
|
|
*/
|
|
public void sendCaeout(String data){
|
|
public void sendCaeout(String data){
|
|
- sendData("caeoutt",data);
|
|
|
|
|
|
+ sendData("caeout",data);
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -93,14 +93,14 @@ public class CaeMQ extends CaeViewMFMqDynamic {
|
|
public static class CaeMqOp implements IMFMqOp {
|
|
public static class CaeMqOp implements IMFMqOp {
|
|
@Override
|
|
@Override
|
|
public boolean handle(String data, long deliveryTag, Map<String, Object> headers, Channel channel) throws Exception {
|
|
public boolean handle(String data, long deliveryTag, Map<String, Object> headers, Channel channel) throws Exception {
|
|
- System.out.println("Queue : "+getAMQPConsumerQueue(headers)+", Data : "+ data);
|
|
|
|
- try {
|
|
|
|
- ActionMsg msg= XiJsonUtil.jsonToPojo(data, ActionMsg.class);
|
|
|
|
- WebsocketEndPoint point = (WebsocketEndPoint) UtilTools.getBean("websocketEndPoint");
|
|
|
|
- point.sendMessageToUser(msg.getProId(),data);
|
|
|
|
- }catch (Exception e){
|
|
|
|
- e.printStackTrace();
|
|
|
|
- }
|
|
|
|
|
|
+// System.out.println("Queue : "+getAMQPConsumerQueue(headers)+", Data : "+ data);
|
|
|
|
+ try {
|
|
|
|
+ ActionMsg msg= XiJsonUtil.jsonToPojo(data, ActionMsg.class);
|
|
|
|
+ WebsocketEndPoint point = (WebsocketEndPoint) UtilTools.getBean("websocketEndPoint");
|
|
|
|
+ point.sendMessageToUser(msg.getProId(),data);
|
|
|
|
+ }catch (Exception e){
|
|
|
|
+ e.printStackTrace();
|
|
|
|
+ }
|
|
|
|
|
|
return true;
|
|
return true;
|
|
}
|
|
}
|