checking what flow control can do

CrescoEdge · May 30, 2024 · 7d628b7 · 7d628b7
1 parent 945a3fb
commit 7d628b7
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/src/main/java/io/cresco/agent/controller/communication/ActiveBroker.java b/src/main/java/io/cresco/agent/controller/communication/ActiveBroker.java
@@ -87,6 +87,7 @@ public ActiveBroker(ControllerEngine controllerEngine, String brokerName) {
 				entry.setQueue(">");
 				//enable prioritization of messages in queues
 				entry.setPrioritizedMessages(true);
+				entry.setProducerFlowControl(true);
 
 				entry.setTopic(">");
 				//enable prioritization of messages in queues
@@ -102,6 +103,7 @@ public ActiveBroker(ControllerEngine controllerEngine, String brokerName) {
 				boolean allConsumersExclusive = plugin.getConfig().getBooleanParam("all_consumers_exclusive",true);
 				entry.setAllConsumersExclusiveByDefault(allConsumersExclusive);
 
+				entry.setProducerFlowControl(true);
 				//entry.setOptimizedDispatch(true);
 				//entry.setProducerFlowControl(true);
 				//entry.setAdvisoryWhenFull(true);

diff --git a/src/main/java/io/cresco/agent/controller/communication/MsgRouter.java b/src/main/java/io/cresco/agent/controller/communication/MsgRouter.java
@@ -317,7 +317,7 @@ public void route(MsgEvent rm) {
                         logger.trace(rm.getParams().toString());
                         forwardToLocalPlugin(rm);
                         break;
-                        
+
                     case 12671:
                         logger.debug("remote agent sending message to local agent");
                         logger.trace(rm.getParams().toString());