|
|
@ -3,7 +3,6 @@ package cn.estsh.i3plus.core.apiservice.mq;
|
|
|
|
import org.slf4j.Logger;
|
|
|
|
import org.slf4j.Logger;
|
|
|
|
import org.slf4j.LoggerFactory;
|
|
|
|
import org.slf4j.LoggerFactory;
|
|
|
|
import org.springframework.amqp.core.Queue;
|
|
|
|
import org.springframework.amqp.core.Queue;
|
|
|
|
import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression;
|
|
|
|
|
|
|
|
import org.springframework.context.annotation.Bean;
|
|
|
|
import org.springframework.context.annotation.Bean;
|
|
|
|
import org.springframework.context.annotation.Configuration;
|
|
|
|
import org.springframework.context.annotation.Configuration;
|
|
|
|
|
|
|
|
|
|
|
@ -33,6 +32,7 @@ public class I3CoreQueueConfig {
|
|
|
|
/*********** 队列demo ***********/
|
|
|
|
/*********** 队列demo ***********/
|
|
|
|
|
|
|
|
|
|
|
|
public static final String DEMO_STR_QUEUE = "demo_str_queue";
|
|
|
|
public static final String DEMO_STR_QUEUE = "demo_str_queue";
|
|
|
|
|
|
|
|
|
|
|
|
@Bean
|
|
|
|
@Bean
|
|
|
|
public Queue getStrQueue() {
|
|
|
|
public Queue getStrQueue() {
|
|
|
|
//LOGGER.info("【DEMO_STR_QUEUE队列】");
|
|
|
|
//LOGGER.info("【DEMO_STR_QUEUE队列】");
|
|
|
@ -40,6 +40,7 @@ public class I3CoreQueueConfig {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
public static final String DEMO_OBJ_QUEUE = "demo_obj_queue";
|
|
|
|
public static final String DEMO_OBJ_QUEUE = "demo_obj_queue";
|
|
|
|
|
|
|
|
|
|
|
|
@Bean
|
|
|
|
@Bean
|
|
|
|
public Queue getObjQueue() throws Exception {
|
|
|
|
public Queue getObjQueue() throws Exception {
|
|
|
|
//LOGGER.info("【DEMO_OBJ_QUEUE队列】");
|
|
|
|
//LOGGER.info("【DEMO_OBJ_QUEUE队列】");
|
|
|
@ -47,6 +48,7 @@ public class I3CoreQueueConfig {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
public static final String DEMO_HANDLE_QUEUE = "demo_handle_queue";
|
|
|
|
public static final String DEMO_HANDLE_QUEUE = "demo_handle_queue";
|
|
|
|
|
|
|
|
|
|
|
|
@Bean
|
|
|
|
@Bean
|
|
|
|
public Queue getHandleQueue() throws Exception {
|
|
|
|
public Queue getHandleQueue() throws Exception {
|
|
|
|
//LOGGER.info("【DEMO_HANDLE_QUEUE队列】");
|
|
|
|
//LOGGER.info("【DEMO_HANDLE_QUEUE队列】");
|
|
|
@ -54,6 +56,7 @@ public class I3CoreQueueConfig {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
public static final String DEMO_ACK_QUEUE = "ack_queue";
|
|
|
|
public static final String DEMO_ACK_QUEUE = "ack_queue";
|
|
|
|
|
|
|
|
|
|
|
|
@Bean
|
|
|
|
@Bean
|
|
|
|
public Queue getAckQueue() throws Exception {
|
|
|
|
public Queue getAckQueue() throws Exception {
|
|
|
|
//LOGGER.info("【DEMO_ACK_QUEUE队列】");
|
|
|
|
//LOGGER.info("【DEMO_ACK_QUEUE队列】");
|
|
|
@ -61,6 +64,7 @@ public class I3CoreQueueConfig {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
public static final String DEMO_RETURN_QUEUE = "return_queue";
|
|
|
|
public static final String DEMO_RETURN_QUEUE = "return_queue";
|
|
|
|
|
|
|
|
|
|
|
|
@Bean
|
|
|
|
@Bean
|
|
|
|
public Queue getReturnQueue() throws Exception {
|
|
|
|
public Queue getReturnQueue() throws Exception {
|
|
|
|
//LOGGER.info("【DEMO_RETURN_QUEUE队列】");
|
|
|
|
//LOGGER.info("【DEMO_RETURN_QUEUE队列】");
|
|
|
|