动态 Table 功能优化

yun-zuoyi
wei.peng 7 years ago
parent fde15ef528
commit b52cc541a0

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

Loading…
Cancel
Save