You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ha...@apache.org on 2016/08/12 00:48:16 UTC
hive git commit: HIVE-14520 : We should set a timeout for the
blocking calls in TestMsgBusConnection (Hari Sankar Subramanyiam via Ashutosh
Chauhan)
Repository: hive
Updated Branches:
refs/heads/master 09272628e -> b3c5296d7
HIVE-14520 : We should set a timeout for the blocking calls in TestMsgBusConnection (Hari Sankar Subramanyiam via Ashutosh Chauhan)
Signed-off-by: Ashutosh Chauhan <ha...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/b3c5296d
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/b3c5296d
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/b3c5296d
Branch: refs/heads/master
Commit: b3c5296d79c0c20dcb6ae3d0be3f0b296e38eecb
Parents: 0927262
Author: Hari Subramaniyan <ha...@apache.org>
Authored: Thu Aug 11 17:47:22 2016 -0700
Committer: Ashutosh Chauhan <ha...@apache.org>
Committed: Thu Aug 11 17:47:22 2016 -0700
----------------------------------------------------------------------
.../apache/hive/hcatalog/listener/TestMsgBusConnection.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/b3c5296d/hcatalog/server-extensions/src/test/java/org/apache/hive/hcatalog/listener/TestMsgBusConnection.java
----------------------------------------------------------------------
diff --git a/hcatalog/server-extensions/src/test/java/org/apache/hive/hcatalog/listener/TestMsgBusConnection.java b/hcatalog/server-extensions/src/test/java/org/apache/hive/hcatalog/listener/TestMsgBusConnection.java
index 3279da1..3c4e50b 100644
--- a/hcatalog/server-extensions/src/test/java/org/apache/hive/hcatalog/listener/TestMsgBusConnection.java
+++ b/hcatalog/server-extensions/src/test/java/org/apache/hive/hcatalog/listener/TestMsgBusConnection.java
@@ -48,7 +48,7 @@ public class TestMsgBusConnection extends TestCase {
private Driver driver;
private BrokerService broker;
private MessageConsumer consumer;
-
+ private static final int TIMEOUT = 2000;
@Override
protected void setUp() throws Exception {
@@ -88,7 +88,7 @@ public class TestMsgBusConnection extends TestCase {
try {
driver.run("create database testconndb");
- Message msg = consumer.receive();
+ Message msg = consumer.receive(TIMEOUT);
assertTrue("Expected TextMessage", msg instanceof TextMessage);
assertEquals(HCatConstants.HCAT_CREATE_DATABASE_EVENT,
msg.getStringProperty(HCatConstants.HCAT_EVENT));
@@ -100,13 +100,13 @@ public class TestMsgBusConnection extends TestCase {
broker.start(true);
connectClient();
driver.run("create database testconndb");
- msg = consumer.receive();
+ msg = consumer.receive(TIMEOUT);
assertEquals(HCatConstants.HCAT_CREATE_DATABASE_EVENT,
msg.getStringProperty(HCatConstants.HCAT_EVENT));
assertEquals("topic://planetlab.hcat", msg.getJMSDestination().toString());
assertEquals("testconndb", messageObject.getDB());
driver.run("drop database testconndb cascade");
- msg = consumer.receive();
+ msg = consumer.receive(TIMEOUT);
assertEquals(HCatConstants.HCAT_DROP_DATABASE_EVENT,
msg.getStringProperty(HCatConstants.HCAT_EVENT));
assertEquals("topic://planetlab.hcat", msg.getJMSDestination().toString());