NIFI-2630: Changed name of queue in unit test to be unique in order to avoid getting messages from another test if the other tests fails to properly shutdown the connection. This closes #2458.
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/74bb341a Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/74bb341a Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/74bb341a Branch: refs/heads/master Commit: 74bb341abce78d3e4823f47f894ea6122db5213f Parents: 42e6fa4 Author: Mark Payne <marka...@hotmail.com> Authored: Fri Mar 2 09:36:18 2018 -0500 Committer: Mark Payne <marka...@hotmail.com> Committed: Fri Mar 2 09:37:00 2018 -0500 ---------------------------------------------------------------------- .../test/java/org/apache/nifi/jms/processors/PublishJMSTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/74bb341a/nifi-nar-bundles/nifi-jms-bundle/nifi-jms-processors/src/test/java/org/apache/nifi/jms/processors/PublishJMSTest.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-jms-bundle/nifi-jms-processors/src/test/java/org/apache/nifi/jms/processors/PublishJMSTest.java b/nifi-nar-bundles/nifi-jms-bundle/nifi-jms-processors/src/test/java/org/apache/nifi/jms/processors/PublishJMSTest.java index a23da26..281d39d 100644 --- a/nifi-nar-bundles/nifi-jms-bundle/nifi-jms-processors/src/test/java/org/apache/nifi/jms/processors/PublishJMSTest.java +++ b/nifi-nar-bundles/nifi-jms-bundle/nifi-jms-processors/src/test/java/org/apache/nifi/jms/processors/PublishJMSTest.java @@ -145,7 +145,7 @@ public class PublishJMSTest { public void validatePublishTextMessage() throws Exception { ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory("vm://localhost?broker.persistent=false"); - final String destinationName = "fooQueue"; + final String destinationName = "validatePublishTextMessage"; PublishJMS pubProc = new PublishJMS(); TestRunner runner = TestRunners.newTestRunner(pubProc); JMSConnectionFactoryProviderDefinition cs = mock(JMSConnectionFactoryProviderDefinition.class);
