Repository: hive Updated Branches: refs/heads/branch-2.1 2e2b3d664 -> 59c4d060b
HIVE-14520 : We should set a timeout for the blocking calls in TestMsgBusConnection (Hari Sankar Subramanyiam via Ashutosh Chauhan) Signed-off-by: Ashutosh Chauhan <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/0369085a Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/0369085a Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/0369085a Branch: refs/heads/branch-2.1 Commit: 0369085a762800902334008014d0772cb3a982e5 Parents: 2e2b3d6 Author: Hari Subramaniyan <[email protected]> Authored: Thu Aug 11 17:47:22 2016 -0700 Committer: Sergio Pena <[email protected]> Committed: Thu Nov 10 13:59:49 2016 -0600 ---------------------------------------------------------------------- .../apache/hive/hcatalog/listener/TestMsgBusConnection.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/0369085a/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());
