Resolve changes, now retries if failing to join multicast group

cartwrightian · Jun 6, 2018 · 4932895 · 4932895
1 parent dc5ca79
commit 4932895
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 12 deletions.
diff --git a/src/main/tw/com/owllistener/network/EnergyMonitor.java b/src/main/tw/com/owllistener/network/EnergyMonitor.java
@@ -1,19 +1,13 @@
 package tw.com.owllistener.network;
 
-import java.io.IOException;
-import java.util.LinkedList;
-import java.util.Optional;
-import java.util.Queue;
-
-import javax.xml.parsers.ParserConfigurationException;
-import javax.xml.xpath.XPathExpressionException;
-
-import jersey.repackaged.com.google.common.collect.Lists;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.xml.sax.SAXException;
 import tw.com.owllistener.network.initialState.MarshalToJson;
 
+import java.util.LinkedList;
+import java.util.Optional;
+import java.util.Queue;
+
 public class EnergyMonitor  {
 	private static final Logger logger = LoggerFactory.getLogger(EnergyMonitor.class);
 	private ReceiveMessages receiver;

diff --git a/src/test/tw/com/owllistener/integration/TestReceiveMessages.java b/src/test/tw/com/owllistener/integration/TestReceiveMessages.java
@@ -21,7 +21,7 @@ public class TestReceiveMessages {
 
 	@Test
 	@Category(IntegrationTest.class)
-	public void shouldReceiveAndParseMessage() throws IOException {
+	public void shouldReceiveAndParseMessage() throws InterruptedException {
 		ReceiveMessages receiver = new ReceiveMessages(new TestConfiguration("url","bucketKey", "accessKey"),
 				new CurrentTime());
 

diff --git a/src/test/tw/com/owllistener/unit/TestEnergyMonitor.java b/src/test/tw/com/owllistener/unit/TestEnergyMonitor.java
@@ -30,7 +30,7 @@ public void beforeEachTestRuns() {
     }
 
     @Test
-    public void shouldRecordMessageAndStopIfRequested() throws SAXException, ParserConfigurationException, XPathExpressionException, IOException {
+    public void shouldRecordMessageAndStopIfRequested() throws InterruptedException {
 
         EnergyMessage messageA = new EnergyMessage("idA", 1223);
         EnergyMessage messageB = new EnergyMessage("idB", 1224);