Merge pull request #97 from HongDam-org/feat/thread-pool-retry-backoff

[FEAT] stomp thread pool size
HongDam-org · Oct 25, 2024 · 5132e6a · 5132e6a
2 parents aafed66 + a54cd67
commit 5132e6a
Show file tree

Hide file tree

Showing 2 changed files with 27 additions and 4 deletions.
diff --git a/backend/src/main/java/com/twtw/backend/config/rabbitmq/RabbitMQConfig.java b/backend/src/main/java/com/twtw/backend/config/rabbitmq/RabbitMQConfig.java
@@ -155,8 +155,21 @@ public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(
         final SimpleRabbitListenerContainerFactory factory =
                 new SimpleRabbitListenerContainerFactory();
         factory.setConnectionFactory(connectionFactory);
+<<<<<<< Updated upstream
         factory.setConcurrentConsumers(20);
         factory.setMaxConcurrentConsumers(200);
+<<<<<<< HEAD
+<<<<<<< HEAD
+=======
+=======
+        factory.setConcurrentConsumers(10);
+        factory.setMaxConcurrentConsumers(50);
+>>>>>>> 8093b8b ([FIX] thread pool size setting)
+=======
+=======
+        factory.setConcurrentConsumers(10);
+        factory.setMaxConcurrentConsumers(50);
+>>>>>>> origin/feat/thread-pool-retry-backoff
         return factory;
     }
 
@@ -167,7 +180,17 @@ public SimpleRabbitListenerContainerFactory retryRabbitListenerContainerFactory(
                 new SimpleRabbitListenerContainerFactory();
         factory.setConnectionFactory(connectionFactory);
         factory.setConcurrentConsumers(5);
+<<<<<<< HEAD
+<<<<<<< HEAD
         factory.setMaxConcurrentConsumers(50);
+=======
+        factory.setMaxConcurrentConsumers(25);
+>>>>>>> Stashed changes
+>>>>>>> 8093b8b ([FIX] thread pool size setting)
+=======
+        factory.setMaxConcurrentConsumers(25);
+>>>>>>> Stashed changes
+>>>>>>> origin/feat/thread-pool-retry-backoff
         factory.setRetryTemplate(retryTemplate());
         return factory;
     }

diff --git a/backend/src/main/java/com/twtw/backend/config/socket/StompConfig.java b/backend/src/main/java/com/twtw/backend/config/socket/StompConfig.java
@@ -55,8 +55,8 @@ public void configureClientOutboundChannel(final ChannelRegistration registratio
     @Bean
     public ThreadPoolTaskExecutor inboundTaskExecutor() {
         final ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
-        executor.setCorePoolSize(15);
-        executor.setMaxPoolSize(150);
+        executor.setCorePoolSize(10);
+        executor.setMaxPoolSize(20);
         executor.setThreadNamePrefix("stomp-inbound-");
         executor.initialize();
         return executor;
@@ -65,8 +65,8 @@ public ThreadPoolTaskExecutor inboundTaskExecutor() {
     @Bean
     public ThreadPoolTaskExecutor outboundTaskExecutor() {
         final ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
-        executor.setCorePoolSize(20);
-        executor.setMaxPoolSize(200);
+        executor.setCorePoolSize(10);
+        executor.setMaxPoolSize(20);
         executor.setThreadNamePrefix("stomp-outbound-");
         executor.initialize();
         return executor;