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)) {