Added one additional thread type to the remote threadpool

morph166955 · Feb 4, 2021 · 8392ab9 · 8392ab9
1 parent 08147c8
commit 8392ab9
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/bundles/org.jupnp/src/main/java/org/jupnp/transport/RouterImpl.java b/bundles/org.jupnp/src/main/java/org/jupnp/transport/RouterImpl.java
@@ -280,7 +280,7 @@ public void received(IncomingDatagramMessage msg) {
                 return;
             }
             log.debug("Received asynchronous message: " + msg);
-            getConfiguration().getAsyncProtocolExecutor("upnp-router").execute(protocol);
+            getConfiguration().getRemoteListenerExecutor("upnp-router-async").execute(protocol);
         } catch (ProtocolCreationException ex) {
             log.warn("Handling received datagram failed - " + Exceptions.unwrap(ex).toString());
         }
@@ -298,7 +298,7 @@ public void received(UpnpStream stream) {
             return;
         }
         log.debug("Received synchronous stream: " + stream);
-        getConfiguration().getSyncProtocolExecutorService("upnp-router").execute(stream);
+        getConfiguration().getSyncProtocolExecutorService("upnp-router-sync").execute(stream);
     }
 
     /**
@@ -419,7 +419,7 @@ protected void startInterfaceBasedTransports(Iterator<NetworkInterface> interfac
 
         for (Map.Entry<NetworkInterface, MulticastReceiver> entry : multicastReceivers.entrySet()) {
             log.debug("Starting multicast receiver on interface: " + entry.getKey().getDisplayName());
-            getConfiguration().getMulticastReceiverExecutor("upnp-router").execute(entry.getValue());
+            getConfiguration().getMulticastReceiverExecutor("upnp-router-multicast").execute(entry.getValue());
         }
     }
 
@@ -478,12 +478,12 @@ protected void startAddressBasedTransports(Iterator<InetAddress> addresses) thro
 
         for (Map.Entry<InetAddress, StreamServer> entry : streamServers.entrySet()) {
             log.debug("Starting stream server on address: " + entry.getKey());
-            getConfiguration().getStreamServerExecutorService("upnp-router").execute(entry.getValue());
+            getConfiguration().getStreamServerExecutorService("upnp-router-stream").execute(entry.getValue());
         }
 
         for (Map.Entry<InetAddress, DatagramIO> entry : datagramIOs.entrySet()) {
             log.debug("Starting datagram I/O on address: " + entry.getKey());
-            getConfiguration().getDatagramIOExecutor("upnp-router").execute(entry.getValue());
+            getConfiguration().getDatagramIOExecutor("upnp-router-datagram").execute(entry.getValue());
         }
     }