Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix for unit tests that are causing build failures in certain environments

This commit is contained in:
Mark Payne 2018-02-07 14:13:06 -05:00
parent 2b062e211f
commit d7da04209a
2 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
nifi-nar-bundles/nifi-jms-bundle/nifi-jms-processors/src/test/java/org/apache/nifi/jms/processors/JMSPublisherConsumerTest.java
View File

@ -154,8 +154,7 @@ public class JMSPublisherConsumerTest {
} }
} }
@Test(timeout = 20000)
@Test(timeout = 2000000)
public void testMultipleThreads() throws Exception { public void testMultipleThreads() throws Exception {
String destinationName = "testQueue"; String destinationName = "testQueue";
JmsTemplate publishTemplate = CommonTest.buildJmsTemplateForDestination(false); JmsTemplate publishTemplate = CommonTest.buildJmsTemplateForDestination(false);

4
nifi-nar-bundles/nifi-jms-bundle/nifi-jms-processors/src/test/java/org/apache/nifi/jms/processors/PublishJMSTest.java
View File

@ -73,7 +73,7 @@ public class PublishJMSTest {
assertEquals("cooQueue", ((Queue) message.getJMSReplyTo()).getQueueName()); assertEquals("cooQueue", ((Queue) message.getJMSReplyTo()).getQueueName());
assertEquals("foo", message.getStringProperty("foo")); assertEquals("foo", message.getStringProperty("foo"));
runner.run(1, true); // Run once just so that we can trigger the shutdown of the Connection Factory runner.run(1, true, false); // Run once just so that we can trigger the shutdown of the Connection Factory
} }
@Test @Test
@ -111,7 +111,7 @@ public class PublishJMSTest {
assertEquals("cooQueue", ((Queue) message.getJMSReplyTo()).getQueueName()); assertEquals("cooQueue", ((Queue) message.getJMSReplyTo()).getQueueName());
assertEquals("foo", message.getStringProperty("foo")); assertEquals("foo", message.getStringProperty("foo"));
runner.run(1, true); // Run once just so that we can trigger the shutdown of the Connection Factory runner.run(1, true, false); // Run once just so that we can trigger the shutdown of the Connection Factory
} }
@Test @Test