You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rg...@apache.org on 2016/11/30 16:29:50 UTC
svn commit: r1772080 - in /qpid/java/trunk:
systests/src/test/java/org/apache/qpid/client/SyncPublishTest.java
test-profiles/Java10UninvestigatedTestsExcludes
Author: rgodfrey
Date: Wed Nov 30 16:29:50 2016
New Revision: 1772080
URL: http://svn.apache.org/viewvc?rev=1772080&view=rev
Log:
QPID-7546 : SyncPublishTest
Modified:
qpid/java/trunk/systests/src/test/java/org/apache/qpid/client/SyncPublishTest.java
qpid/java/trunk/test-profiles/Java10UninvestigatedTestsExcludes
Modified: qpid/java/trunk/systests/src/test/java/org/apache/qpid/client/SyncPublishTest.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/systests/src/test/java/org/apache/qpid/client/SyncPublishTest.java?rev=1772080&r1=1772079&r2=1772080&view=diff
==============================================================================
--- qpid/java/trunk/systests/src/test/java/org/apache/qpid/client/SyncPublishTest.java (original)
+++ qpid/java/trunk/systests/src/test/java/org/apache/qpid/client/SyncPublishTest.java Wed Nov 30 16:29:50 2016
@@ -23,6 +23,7 @@ package org.apache.qpid.client;
import javax.jms.Connection;
import javax.jms.JMSException;
import javax.jms.MessageProducer;
+import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TemporaryQueue;
@@ -53,7 +54,8 @@ public class SyncPublishTest extends Qpi
MessageProducer producer = session.createProducer(null);
try
{
- producer.send(session.createQueue("direct://amq.direct/unknown/unknown"),session.createTextMessage("hello"));
+ final Queue queue = session.createQueue(isBroker10() ? "amq.direct/unknown" : "direct://amq.direct/unknown/unknown");
+ producer.send(queue, session.createTextMessage("hello"));
fail("Send to unknown destination should result in error");
}
catch (JMSException e)
@@ -69,7 +71,8 @@ public class SyncPublishTest extends Qpi
MessageProducer producer = session.createProducer(null);
try
{
- producer.send(session.createQueue("direct://amq.direct/unknown/unknown"),session.createTextMessage("hello"));
+ final Queue queue = session.createQueue(isBroker10() ? "amq.direct/unknown" : "direct://amq.direct/unknown/unknown");
+ producer.send(queue,session.createTextMessage("hello"));
fail("Send to unknown destination should result in error");
}
catch (JMSException e)
Modified: qpid/java/trunk/test-profiles/Java10UninvestigatedTestsExcludes
URL: http://svn.apache.org/viewvc/qpid/java/trunk/test-profiles/Java10UninvestigatedTestsExcludes?rev=1772080&r1=1772079&r2=1772080&view=diff
==============================================================================
--- qpid/java/trunk/test-profiles/Java10UninvestigatedTestsExcludes (original)
+++ qpid/java/trunk/test-profiles/Java10UninvestigatedTestsExcludes Wed Nov 30 16:29:50 2016
@@ -29,11 +29,9 @@ org.apache.qpid.server.security.auth.man
org.apache.qpid.client.prefetch.PrefetchBehaviourTest#*
org.apache.qpid.client.redelivered.RedeliveredMessageTest#*
org.apache.qpid.client.SynchReceiveTest#*
-org.apache.qpid.client.SyncPublishTest#*
org.apache.qpid.server.security.acl.ExternalACLTest#*
org.apache.qpid.server.security.acl.ExhaustiveACLTest#*
org.apache.qpid.server.queue.ModelTest#*
-//org.apache.qpid.server.queue.LiveQueueOperationsTest#*
org.apache.qpid.test.unit.topic.DurableSubscriptionTest#*
org.apache.qpid.test.unit.close.JavaServerCloseRaceConditionTest#*
org.apache.qpid.test.unit.client.MaxDeliveryCountTest#*
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org