commit a7756f1036825653b02c9a9d8ed96758fe24dd34
author Steven Glenn Jacobs <sjaco002@ucr.edu> Fri Mar 16 12:36:49 2018 -0700
committer Steven Glenn Jacobs <sjaco002@ucr.edu> Fri Mar 16 12:36:49 2018 -0700
tree b271a305108241183d180c9b416c407e102b8119
parent 185b63d4f08ccc10989b0f7137bc7d079432b980

Add timeout to Broker connection for notifications

Change-Id: Ic2803bdba15e6742a084a84d483996ab7ab45a8e

asterix-bad/src/main/java/org/apache/asterix/bad/ChannelJobService.java

diff --git a/asterix-bad/src/main/java/org/apache/asterix/bad/ChannelJobService.java b/asterix-bad/src/main/java/org/apache/asterix/bad/ChannelJobService.java
index 1db0669..41853b9 100644
--- a/asterix-bad/src/main/java/org/apache/asterix/bad/ChannelJobService.java
+++ b/asterix-bad/src/main/java/org/apache/asterix/bad/ChannelJobService.java
@@ -106,6 +106,7 @@
 
             connection.setUseCaches(false);
             connection.setDoOutput(true);
+            connection.setConnectTimeout(500);
 
             if (connection.getOutputStream() != null) {
                 //Send message
@@ -113,7 +114,7 @@
                 wr.writeBytes(urlParameters);
                 wr.close();
             } else {
-                LOGGER.log(Level.WARNING, "Channel Failed to connect to Broker.");
+                throw new Exception();
             }
 
             if (LOGGER.isLoggable(Level.INFO)) {