add ThreadPoolExecutor

src/main/java/microservice/services/IPubSubServicePulsarImpl.java

@@ -132,8 +132,8 @@ public class IPubSubServicePulsarImpl extends CommonServices.IPubSubService {
                         final PubSubMsgContext msgCtx = getMsgContext(msg);
                         final PubSubMsgContext msgCtx = getMsgContext(msg);
                         if (msgCtx != null) {
                         if (msgCtx != null) {
                             logger.debug(SERVICE_NAME + " > Message received: " + msgCtx.toString());
                             logger.debug(SERVICE_NAME + " > Message received: " + msgCtx.toString());
-//                            consumerExecutorService.execute(() -> dispatchMsgCtx(msgCtx));
-                            dispatchMsgCtx(msgCtx);
+                            consumerExecutorService.execute(() -> dispatchMsgCtx(msgCtx));
+//                            dispatchMsgCtx(msgCtx);
                         } else {
                         } else {
                             logger.warning(SERVICE_NAME + " > Failed to parse Pulsar message: " + msg.getMessageId());
                             logger.warning(SERVICE_NAME + " > Failed to parse Pulsar message: " + msg.getMessageId());
                         }
                         }