Steven Jacobs has uploaded a new change for review.
https://asterix-gerrit.ics.uci.edu/2497
Change subject: Add timeout to Broker connection for notifications
......................................................................
Add timeout to Broker connection for notifications
Change-Id: Ic2803bdba15e6742a084a84d483996ab7ab45a8e
---
M asterix-bad/src/main/java/org/apache/asterix/bad/ChannelJobService.java
1 file changed, 2 insertions(+), 1 deletion(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb-bad
refs/changes/97/2497/1
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)) {
--
To view, visit https://asterix-gerrit.ics.uci.edu/2497
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: Ic2803bdba15e6742a084a84d483996ab7ab45a8e
Gerrit-PatchSet: 1
Gerrit-Project: asterixdb-bad
Gerrit-Branch: master
Gerrit-Owner: Steven Jacobs <[email protected]>
