|
@@ -45,14 +45,14 @@ import java.util.Map;
|
|
* sendData不传name ,默认发送 index=0的队列
|
|
* sendData不传name ,默认发送 index=0的队列
|
|
*/
|
|
*/
|
|
|
|
|
|
-@Component
|
|
|
|
-@ConditionalOnProperty(prefix = "mf.mq", name = "enable", havingValue = "true", matchIfMissing = false)
|
|
|
|
|
|
+//@Component
|
|
|
|
+//@ConditionalOnProperty(prefix = "mf.mq", name = "enable", havingValue = "true", matchIfMissing = false)
|
|
public class CaeMQ extends CaeViewMFMqDynamic {
|
|
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(),"caeout");//设置监听
|
|
|
|
|
|
+ setLocalMqOp(new CaeMqOp(),"caeout2");//设置监听
|
|
// setDefOp(new CaeMqOp());//设置默认监听
|
|
// setDefOp(new CaeMqOp());//设置默认监听
|
|
}
|
|
}
|
|
|
|
|
|
@@ -63,7 +63,7 @@ public class CaeMQ extends CaeViewMFMqDynamic {
|
|
|
|
|
|
@Override
|
|
@Override
|
|
public String[] declareListenerQueueLocal(){
|
|
public String[] declareListenerQueueLocal(){
|
|
- return new String[]{"caeout"};
|
|
|
|
|
|
+ return new String[]{"caeout2"};
|
|
// return new String[]{};
|
|
// return new String[]{};
|
|
}
|
|
}
|
|
|
|
|