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 <[email protected]> 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 <[email protected]> Authored: Thu Aug 11 17:47:22 2016 -0700 Committer: Ashutosh Chauhan <[email protected]> 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());
