Rabbitmq code formatting

pull/253/head
chen.ma 3 years ago
parent cf22eef039
commit 9b98798164

@ -48,10 +48,11 @@ public class RabbitMQThreadPoolAdapter implements ThreadPoolAdapter, Application
private static final String FiledName = "executorService"; private static final String FiledName = "executorService";
// todo: Configurable name /**
* TODO Configurable name
*/
private static final String RABBITMQ_EXECUTOR_SERVICE = "Rabbitmq_Executor_Service"; private static final String RABBITMQ_EXECUTOR_SERVICE = "Rabbitmq_Executor_Service";
private final AbstractConnectionFactory abstractConnectionFactory; private final AbstractConnectionFactory abstractConnectionFactory;
private final Map<String, ThreadPoolExecutor> RABBITMQ_THREAD_POOL_TASK_EXECUTOR = Maps.newHashMap(); private final Map<String, ThreadPoolExecutor> RABBITMQ_THREAD_POOL_TASK_EXECUTOR = Maps.newHashMap();
@ -73,6 +74,7 @@ public class RabbitMQThreadPoolAdapter implements ThreadPoolAdapter, Application
return threadPoolAdapterState; return threadPoolAdapterState;
} }
@Override
public List<ThreadPoolAdapterState> getThreadPoolStates() { public List<ThreadPoolAdapterState> getThreadPoolStates() {
List<ThreadPoolAdapterState> adapterStateList = Lists.newArrayList(); List<ThreadPoolAdapterState> adapterStateList = Lists.newArrayList();
RABBITMQ_THREAD_POOL_TASK_EXECUTOR.forEach( RABBITMQ_THREAD_POOL_TASK_EXECUTOR.forEach(
@ -110,7 +112,6 @@ public class RabbitMQThreadPoolAdapter implements ThreadPoolAdapter, Application
} else { } else {
log.warn("Custom thread pools only support ThreadPoolExecutor"); log.warn("Custom thread pools only support ThreadPoolExecutor");
} }
} }
} }
} }

@ -51,7 +51,6 @@ public class RabbitMQThreadPoolConfig {
MessageConverter messageConverter, AbstractConnectionFactory abstractConnectionFactory) { MessageConverter messageConverter, AbstractConnectionFactory abstractConnectionFactory) {
DirectRabbitListenerContainerFactory factory = new DirectRabbitListenerContainerFactory(); DirectRabbitListenerContainerFactory factory = new DirectRabbitListenerContainerFactory();
factory.setConnectionFactory(abstractConnectionFactory); factory.setConnectionFactory(abstractConnectionFactory);
// factory.setTaskExecutor(rabbitListenerTaskExecutor);
factory.setMessageConverter(messageConverter); factory.setMessageConverter(messageConverter);
factory.setConsumersPerQueue(10); factory.setConsumersPerQueue(10);
abstractConnectionFactory.setExecutor(rabbitListenerTaskExecutor); abstractConnectionFactory.setExecutor(rabbitListenerTaskExecutor);

@ -23,6 +23,4 @@ package cn.hippo4j.springboot.starter.adapter.rabbitmq.example.constants;
public interface SimpleMQConstant { public interface SimpleMQConstant {
String QUEUE_NAME = "framework_message-center_queue"; String QUEUE_NAME = "framework_message-center_queue";
String QUEUE_NAME1 = "framework_message-center_queue1";
} }

@ -37,22 +37,10 @@ public class MessageConsumer {
@RabbitHandler @RabbitHandler
@RabbitListener(queuesToDeclare = @Queue(SimpleMQConstant.QUEUE_NAME), containerFactory = "defaultRabbitListenerContainerFactory") @RabbitListener(queuesToDeclare = @Queue(SimpleMQConstant.QUEUE_NAME), containerFactory = "defaultRabbitListenerContainerFactory")
// @RabbitListener(queuesToDeclare = @Queue(SimpleMQConstant.QUEUE_NAME))
public void receiveObject(SendMessageDTO simple) throws Exception { public void receiveObject(SendMessageDTO simple) throws Exception {
TimeUnit.SECONDS.sleep(1); TimeUnit.SECONDS.sleep(1);
ObjectMapper objectMapper = new ObjectMapper(); ObjectMapper objectMapper = new ObjectMapper();
String message = objectMapper.writeValueAsString(simple); String message = objectMapper.writeValueAsString(simple);
log.info("consumer1 threadId {} Message: {}", Thread.currentThread().getName(),message); log.info("consumer1 threadId {} Message: {}", Thread.currentThread().getName(), message);
} }
// @RabbitHandler
// @RabbitListener(queuesToDeclare = @Queue(SimpleMQConstant.QUEUE_NAME1))
// public void receiveObject1(SendMessageDTO simple) throws Exception {
// TimeUnit.SECONDS.sleep(1);
// ObjectMapper objectMapper = new ObjectMapper();
// String message = objectMapper.writeValueAsString(simple);
// log.info("consumer threadId {} Message: {}", Thread.currentThread().getName(),message);
// }
} }

@ -33,7 +33,6 @@ import org.springframework.context.annotation.Configuration;
@RequiredArgsConstructor @RequiredArgsConstructor
public class RabbitMQAdapterAutoConfiguration { public class RabbitMQAdapterAutoConfiguration {
private final AbstractConnectionFactory abstractConnectionFactories; private final AbstractConnectionFactory abstractConnectionFactories;
@Bean @Bean

Loading…
Cancel
Save