Steven Jacobs has submitted this change and it was merged.
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(-)
Approvals:
Jenkins: Verified
Xikui Wang: Looks good to me, approved
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: merged
Gerrit-Change-Id: Ic2803bdba15e6742a084a84d483996ab7ab45a8e
Gerrit-PatchSet: 1
Gerrit-Project: asterixdb-bad
Gerrit-Branch: master
Gerrit-Owner: Steven Jacobs <[email protected]>
Gerrit-Reviewer: Jenkins <[email protected]>
Gerrit-Reviewer: Steven Jacobs <[email protected]>
Gerrit-Reviewer: Xikui Wang <[email protected]>
