Updated to support turning off entity or event topics

Author: keithwilliams324

TAK Server Plugin/Plugin/src/takserver-sender-plugin-mcs/src/main/java/tak/server/plugins/messagebroker/RabbitMQClient.java

@@ -20,6 +20,8 @@
 public class RabbitMQClient {
     private MessageProducer _producer;
     private String _exchangeName = "dragonfly";
+    private Boolean _enableEntityRouting = true;
+    private Boolean _enableEventRouting = true;
     private String _entityRoutingKey = "dragonfly.demo_entities";
     private String _eventRoutingKey = "dragonfly.events";
     private String _rabbitHost = "some-rabbit";
@@ -55,8 +57,15 @@ public void SetupConsumption(MessageProducer producer, PluginConfiguration confi
             _channel.exchangeDeclare(_exchangeName, "topic", true);
             String queueName = _channel.queueDeclare().getQueue();
 
-            _channel.queueBind(queueName, _exchangeName, _eventRoutingKey);
-            _channel.queueBind(queueName, _exchangeName, _entityRoutingKey);
+            if (_enableEventRouting == true)
+                _channel.queueBind(queueName, _exchangeName, _eventRoutingKey);
+            else
+                logger.info("Event Routing disabled");
+           
+            if (_enableEntityRouting == true)
+                _channel.queueBind(queueName, _exchangeName, _entityRoutingKey);
+            else
+                logger.info("Entity Routing disabled");
 
             DeliverCallback deliverCallback = (consumerTag, delivery) -> {
                 String message = new String(delivery.getBody(), "UTF-8");
@@ -140,5 +149,13 @@ private void SetupConfiguration(PluginConfiguration configuration) {
         if (configuration.containsProperty("useRapidX")) {
             _useRapidX = (boolean)configuration.getProperty("useRapidX");
         }
+
+        if (configuration.containsProperty("rabbitmq.enableEntityRouting")) {
+            _enableEntityRouting = (boolean)configuration.getProperty("rabbitmq.enableEntityRouting");
+        }
+
+        if (configuration.containsProperty("rabbitmq.enableEventRouting")) {
+            _enableEventRouting = (boolean)configuration.getProperty("rabbitmq.enableEventRouting");
+        }
     }
 }

TAK Server Plugin/Plugin/src/takserver-sender-plugin-mcs/tak.server.plugins.McsSenderPlugin.yaml

@@ -7,5 +7,7 @@ rabbitmq:
   username: "rapidx"
   password: "dragonfly"
   entityKey: "dragonfly.demo_entities"
+  enableEntityRouting: true
   eventKey: "dragonfly.events"
+  enableEventRouting: true
 

TAK Server Plugin/RabbitMQ Client/Program.cs

@@ -17,7 +17,7 @@ class Program
         private static string USERNAME = "rapidx";
         private static bool USE_RAPIDX = true;
 
-        private static string MESSAGE = "{\"uid\":\"ExampleCompany.12345-abcde-6789-fghij\",\"type\":\"a-f-G-U-C\",\"time\":\"1614187736429\",\"start\":\"1614187736429\",\"stale\":\"1614191352000\",\"how\":\"m-g\",\"point\":{\"lat\":\"39.0495\",\"lon\":\"-85.7445\",\"hae\":\"9999999\",\"ce\":\"9999999\",\"le\":\"9999999\"},\"detail\":{\"milsym2525C\":\"SFGPUCI*****\"}}";
+        private static string MESSAGE = "{\"uid\":\"ExampleCompany.12345-abcde-6789-fghij\",\"type\":\"a-f-G-U-C\",\"time\":\"1614187736429\",\"start\":\"1614187736429\",\"stale\":\"1614191352000\",\"how\":\"m-g\",\"point\":{\"lat\":\"39.0495\",\"lon\":\"-85.7445\",\"hae\":\"9999999\",\"ce\":\"9999999\",\"le\":\"9999999\"},\"detail\":{\"milsym2525C\":\"SFGPUCI*****\", \"video\":\"https://cdn.bitdegree.org/learn/Pexels%20Videos%203373.mp4?raw=true\", \"feedType\":\"OSH_SENSOR\",\"serviceDetails\":{\"serviceUrl\":\"THE SERVICE URL\",\"provider\":{\"providerName\":\"SOME NAME\",\"providerData\":\"SOME DATA\"},\"offeringID\":\"THE OFFERING ID\",\"temporalData\":\"THE TEMPORAL DATA\"}}}";
 
         private static string EVENT_MESSAGE = "{\"cot_uid\":\"b5034f03-b209-47a8-aa39-31d32e8ee337\",\"message\":\"This is a demo alert\",\"type\":\"warning\"}";