X-Git-Url: http://wamblee.org/gitweb/?a=blobdiff_plain;f=monitor%2Fsrc%2Fmain%2Fjava%2Forg%2Fwamblee%2Fupnpmonitor%2FMonitor.java;fp=monitor%2Fsrc%2Fmain%2Fjava%2Forg%2Fwamblee%2Fupnpmonitor%2FMonitor.java;h=3049144fd970d1497948fc20acf1ddf5f2dc10ce;hb=9fcdbb28f7e1f5e2e2d0e0729271cb1305df5928;hp=fab9fe643b66292103c5472ce33db7d8bd2939cd;hpb=c2b0bc89067fda22755e884a771b809463ea8e30;p=upnpmonitor diff --git a/monitor/src/main/java/org/wamblee/upnpmonitor/Monitor.java b/monitor/src/main/java/org/wamblee/upnpmonitor/Monitor.java index fab9fe6..3049144 100644 --- a/monitor/src/main/java/org/wamblee/upnpmonitor/Monitor.java +++ b/monitor/src/main/java/org/wamblee/upnpmonitor/Monitor.java @@ -26,6 +26,23 @@ public class Monitor implements Runnable { public void start() { serviceFound = true; + stack = new UpnpStack(new UpnpStack.Listener() { + @Override + public void deviceAdded(String aDeviceString) { + LOGGER.fine("Device added: " + aDeviceString); + if (aDeviceString.toLowerCase().contains( + config.getPattern().toLowerCase())) { + synchronized (Monitor.this) { + setServiceFound(true); + } + } + } + + @Override + public void deviceRemoved(String aDeviceString) { + LOGGER.fine("Device removed:" + aDeviceString); + } + }); executor.scheduleWithFixedDelay(this, 0, config.getIntervalSeconds(), TimeUnit.SECONDS); executeCommand(config.getStartupCommand()); @@ -47,27 +64,7 @@ public class Monitor implements Runnable { return; } - shutdownStack(); - setServiceFound(false); - - stack = new UpnpStack(new UpnpStack.Listener() { - @Override - public void deviceAdded(String aDeviceString) { - LOGGER.fine("Device added: " + aDeviceString); - if (aDeviceString.toLowerCase().contains( - config.getPattern().toLowerCase())) { - synchronized (Monitor.this) { - setServiceFound(true); - } - } - } - - @Override - public void deviceRemoved(String aDeviceString) { - LOGGER.fine("Device removed:" + aDeviceString); - } - }); stack.search(); }