Merge pull request #3862 from Abyss777/switch_queueing

Make Commands queueing switchable

3 files changed, 9 insertions, 2 deletions

diff --git a/setup/default.xml b/setup/default.xml
index 6bab81401..6fdfb2a95 100644
--- a/setup/default.xml
+++ b/setup/default.xml
@@ -29,6 +29,8 @@
 
     <entry key='server.statistics'>https://www.traccar.org/analytics/</entry>
 
+    <entry key='commands.queueing'>true</entry>
+
     <!-- DATABASE CONFIG -->
 
     <entry key='database.ignoreUnknown'>true</entry>
diff --git a/src/org/traccar/Context.java b/src/org/traccar/Context.java
index 67fd02f75..30e6ca713 100644
--- a/src/org/traccar/Context.java
+++ b/src/org/traccar/Context.java
@@ -391,7 +391,7 @@ public final class Context {
 
         driversManager = new DriversManager(dataManager);
 
-        commandsManager = new CommandsManager(dataManager);
+        commandsManager = new CommandsManager(dataManager, config.getBoolean("commands.queueing"));
 
         statisticsManager = new StatisticsManager();
 
diff --git a/src/org/traccar/database/CommandsManager.java b/src/org/traccar/database/CommandsManager.java
index 9ceb995ef..8ddced5f7 100644
--- a/src/org/traccar/database/CommandsManager.java
+++ b/src/org/traccar/database/CommandsManager.java
@@ -37,8 +37,11 @@ public class CommandsManager  extends ExtendedObjectManager<Command> {
 
     private final Map<Long, Queue<Command>> deviceQueues = new ConcurrentHashMap<>();
 
-    public CommandsManager(DataManager dataManager) {
+    private boolean queueing;
+
+    public CommandsManager(DataManager dataManager, boolean queueing) {
         super(dataManager, Command.class);
+        this.queueing = queueing;
     }
 
     public boolean checkDeviceCommand(long deviceId, long commandId) {
@@ -70,6 +73,8 @@ public class CommandsManager  extends ExtendedObjectManager<Command> {
             ActiveDevice activeDevice = Context.getConnectionManager().getActiveDevice(deviceId);
             if (activeDevice != null) {
                 activeDevice.sendCommand(command);
+            } else if (!queueing) {
+                throw new RuntimeException("Device is not online");
             } else {
                 getDeviceQueue(deviceId).add(command);
                 return false;