Author: rgodfrey
Date: Thu Nov 24 18:28:56 2016
New Revision: 1771201
URL: http://svn.apache.org/viewvc?rev=1771201&view=rev
Log:
QPID-7546 : Make some more tests run under AMQP 1.0
Modified:
qpid/java/trunk/systests/src/main/java/org/apache/qpid/test/utils/QpidBrokerTestCase.java
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/ack/RecoverTest.java
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/basic/FieldTableMessageTest.java
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/basic/MultipleConnectionTest.java
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/basic/PubSubTwoConnectionTest.java
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/client/QueueSessionFactoryTest.java
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/client/TopicSessionFactoryTest.java
qpid/java/trunk/test-profiles/Java10BrokenTestsExcludes
qpid/java/trunk/test-profiles/Java10Excludes
qpid/java/trunk/test-profiles/Java10UninvestigatedTestsExcludes
Modified:
qpid/java/trunk/systests/src/main/java/org/apache/qpid/test/utils/QpidBrokerTestCase.java
URL:
http://svn.apache.org/viewvc/qpid/java/trunk/systests/src/main/java/org/apache/qpid/test/utils/QpidBrokerTestCase.java?rev=1771201&r1=1771200&r2=1771201&view=diff
==============================================================================
---
qpid/java/trunk/systests/src/main/java/org/apache/qpid/test/utils/QpidBrokerTestCase.java
(original)
+++
qpid/java/trunk/systests/src/main/java/org/apache/qpid/test/utils/QpidBrokerTestCase.java
Thu Nov 24 18:28:56 2016
@@ -444,6 +444,10 @@ public class QpidBrokerTestCase extends
createMessage.setString("name", name);
createMessage.setString("object-path", name);
producer.send(createMessage);
+ if(session.getTransacted())
+ {
+ session.commit();
+ }
}
Modified:
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java
URL:
http://svn.apache.org/viewvc/qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java?rev=1771201&r1=1771200&r2=1771201&view=diff
==============================================================================
---
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java
(original)
+++
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java
Thu Nov 24 18:28:56 2016
@@ -53,7 +53,8 @@ public class QueueBrowserAutoAckTest ext
setupSession();
- _queue = _clientSession.createQueue(getTestQueueName());
+ _queue = createTestQueue(_clientSession);
+
_clientSession.createConsumer(_queue).close();
//Ensure there are no messages on the queue to start with.
@@ -137,16 +138,18 @@ public class QueueBrowserAutoAckTest ext
//Check what the session believes the queue count to be.
long queueDepth = 0;
- try
- {
- queueDepth = ((AMQSession)
_clientSession).getQueueDepth((AMQDestination) _queue);
- }
- catch (QpidException e)
+ if(!isBroker10())
{
- }
-
- assertEquals("Session reports Queue expectedDepth not as expected",
expectedDepth, queueDepth);
+ try
+ {
+ queueDepth = ((AMQSession)
_clientSession).getQueueDepth((AMQDestination) _queue);
+ }
+ catch (QpidException e)
+ {
+ }
+ assertEquals("Session reports Queue expectedDepth not as
expected", expectedDepth, queueDepth);
+ }
// Browse the queue to get a second opinion
int msgCount = 0;
@@ -427,7 +430,8 @@ public class QueueBrowserAutoAckTest ext
{
QueueBrowser browser =
_clientSession.createBrowser(getTestQueue());
Enumeration messages = browser.getEnumeration();
- fail("Expected exception when attempting to browse on a stopped
connection did not occur");
+ // it is not a requirement to fail - but it shouldn't hang... so
failure for this test is simply
+ // non-completion
}
catch(javax.jms.IllegalStateException e)
{
Modified:
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/ack/RecoverTest.java
URL:
http://svn.apache.org/viewvc/qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/ack/RecoverTest.java?rev=1771201&r1=1771200&r2=1771201&view=diff
==============================================================================
---
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/ack/RecoverTest.java
(original)
+++
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/ack/RecoverTest.java
Thu Nov 24 18:28:56 2016
@@ -19,14 +19,8 @@
*/
package org.apache.qpid.test.unit.ack;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import org.apache.qpid.client.AMQConnection;
-import org.apache.qpid.client.AMQQueue;
-import org.apache.qpid.configuration.ClientProperties;
-import org.apache.qpid.jms.Session;
-import org.apache.qpid.test.utils.QpidBrokerTestCase;
+import java.util.concurrent.atomic.AtomicBoolean;
+import java.util.concurrent.atomic.AtomicInteger;
import javax.jms.Connection;
import javax.jms.Destination;
@@ -36,9 +30,14 @@ import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.MessageProducer;
import javax.jms.Queue;
+import javax.jms.Session;
import javax.jms.TextMessage;
-import java.util.concurrent.atomic.AtomicBoolean;
-import java.util.concurrent.atomic.AtomicInteger;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import org.apache.qpid.configuration.ClientProperties;
+import org.apache.qpid.test.utils.QpidBrokerTestCase;
public class RecoverTest extends QpidBrokerTestCase
{
@@ -49,7 +48,7 @@ public class RecoverTest extends QpidBro
private volatile Exception _error;
private AtomicInteger count;
- protected AMQConnection _connection;
+ protected Connection _connection;
protected Session _consumerSession;
protected MessageConsumer _consumer;
static final int SENT_COUNT = 4;
@@ -64,10 +63,10 @@ public class RecoverTest extends QpidBro
protected void initTest() throws Exception
{
- _connection = (AMQConnection) getConnection();
+ _connection = getConnection();
_consumerSession = _connection.createSession(false,
Session.CLIENT_ACKNOWLEDGE);
- Queue queue = _consumerSession.createQueue(getTestQueueName());
+ Queue queue = createTestQueue(_consumerSession);
_consumer = _consumerSession.createConsumer(queue);
@@ -174,19 +173,15 @@ public class RecoverTest extends QpidBro
public void testAcknowledgePerConsumer() throws Exception
{
- AMQConnection con = (AMQConnection) getConnection();
+ Connection con = getConnection();
Session consumerSession = con.createSession(false,
Session.CLIENT_ACKNOWLEDGE);
- Queue queue =
- new AMQQueue(consumerSession.getDefaultQueueExchangeName(),
"Q1", "Q1",
- false, true);
- Queue queue2 =
- new AMQQueue(consumerSession.getDefaultQueueExchangeName(),
"Q2", "Q2",
- false, true);
+ Queue queue = createTestQueue(consumerSession, "Q1");
+ Queue queue2 = createTestQueue(consumerSession, "Q2");
MessageConsumer consumer = consumerSession.createConsumer(queue);
MessageConsumer consumer2 = consumerSession.createConsumer(queue2);
- AMQConnection con2 = (AMQConnection) getConnection();
+ Connection con2 = getConnection();
Session producerSession = con2.createSession(false,
Session.CLIENT_ACKNOWLEDGE);
MessageProducer producer = producerSession.createProducer(queue);
MessageProducer producer2 = producerSession.createProducer(queue2);
@@ -216,12 +211,10 @@ public class RecoverTest extends QpidBro
public void testRecoverInAutoAckListener() throws Exception
{
- AMQConnection con = (AMQConnection) getConnection();
+ Connection con = getConnection();
final Session consumerSession = con.createSession(false,
Session.AUTO_ACKNOWLEDGE);
- Queue queue =
- new AMQQueue(consumerSession.getDefaultQueueExchangeName(),
"Q3", "Q3",
- false, true);
+ Queue queue = createTestQueue(consumerSession, "Q3");
MessageConsumer consumer = consumerSession.createConsumer(queue);
MessageProducer producer = consumerSession.createProducer(queue);
producer.send(consumerSession.createTextMessage("hello"));
@@ -317,9 +310,9 @@ public class RecoverTest extends QpidBro
*/
public void testOrderingWithSyncConsumer() throws Exception
{
- Connection con = (Connection) getConnection();
- javax.jms.Session session = con.createSession(false,
Session.CLIENT_ACKNOWLEDGE);
- Destination topic = session.createTopic("myTopic");
+ Connection con = getConnection();
+ Session session = con.createSession(false, Session.CLIENT_ACKNOWLEDGE);
+ Destination topic = createTopic(con, "myTopic");
MessageConsumer cons = session.createConsumer(topic);
sendMessage(session,topic,8);
@@ -368,9 +361,9 @@ public class RecoverTest extends QpidBro
*/
public void testOrderingWithAsyncConsumer() throws Exception
{
- Connection con = (Connection) getConnection();
- final javax.jms.Session session = con.createSession(false,
Session.CLIENT_ACKNOWLEDGE);
- Destination topic = session.createTopic("myTopic");
+ Connection con = getConnection();
+ final Session session = con.createSession(false,
Session.CLIENT_ACKNOWLEDGE);
+ Destination topic = createTopic(con, "myTopic");
MessageConsumer cons = session.createConsumer(topic);
sendMessage(session,topic,8);
Modified:
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/basic/FieldTableMessageTest.java
URL:
http://svn.apache.org/viewvc/qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/basic/FieldTableMessageTest.java?rev=1771201&r1=1771200&r2=1771201&view=diff
==============================================================================
---
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/basic/FieldTableMessageTest.java
(original)
+++
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/basic/FieldTableMessageTest.java
Thu Nov 24 18:28:56 2016
@@ -20,6 +20,17 @@
*/
package org.apache.qpid.test.unit.basic;
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
+
+import javax.jms.BytesMessage;
+import javax.jms.JMSException;
+import javax.jms.Message;
+import javax.jms.MessageListener;
+import javax.jms.MessageProducer;
+
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -34,17 +45,6 @@ import org.apache.qpid.framing.FieldTabl
import org.apache.qpid.framing.FieldTableFactory;
import org.apache.qpid.test.utils.QpidBrokerTestCase;
-import javax.jms.BytesMessage;
-import javax.jms.JMSException;
-import javax.jms.Message;
-import javax.jms.MessageListener;
-import javax.jms.MessageProducer;
-
-import java.io.IOException;
-import java.util.ArrayList;
-import java.util.concurrent.CountDownLatch;
-import java.util.concurrent.TimeUnit;
-
public class FieldTableMessageTest extends QpidBrokerTestCase implements
MessageListener
{
private static final Logger _logger =
LoggerFactory.getLogger(FieldTableMessageTest.class);
@@ -55,7 +55,6 @@ public class FieldTableMessageTest exten
private final ArrayList<JMSBytesMessage> received = new
ArrayList<JMSBytesMessage>();
private FieldTable _expected;
private int _count = 10;
- private String _connectionString = "vm://:1";
private CountDownLatch _waitForCompletion;
protected void setUp() throws Exception
@@ -154,12 +153,4 @@ public class FieldTableMessageTest exten
return in + System.currentTimeMillis();
}
- public static void main(String[] argv) throws Exception
- {
- FieldTableMessageTest test = new FieldTableMessageTest();
- test._connectionString = (argv.length == 0) ? "vm://:1" : argv[0];
- test.setUp();
- test._count = (argv.length > 1) ? Integer.parseInt(argv[1]) : 5;
- test.test();
- }
}
Modified:
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/basic/MultipleConnectionTest.java
URL:
http://svn.apache.org/viewvc/qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/basic/MultipleConnectionTest.java?rev=1771201&r1=1771200&r2=1771201&view=diff
==============================================================================
---
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/basic/MultipleConnectionTest.java
(original)
+++
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/basic/MultipleConnectionTest.java
Thu Nov 24 18:28:56 2016
@@ -19,48 +19,44 @@
*/
package org.apache.qpid.test.unit.basic;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import org.apache.qpid.client.AMQConnection;
-import org.apache.qpid.client.AMQDestination;
-import org.apache.qpid.client.AMQSession;
-import org.apache.qpid.client.AMQTopic;
-import org.apache.qpid.exchange.ExchangeDefaults;
-import org.apache.qpid.test.utils.QpidBrokerTestCase;
-
+import javax.jms.Connection;
+import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.MessageProducer;
import javax.jms.Session;
+import javax.jms.Topic;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import org.apache.qpid.test.utils.QpidBrokerTestCase;
public class MultipleConnectionTest extends QpidBrokerTestCase
{
private static final Logger _logger =
LoggerFactory.getLogger(MultipleConnectionTest.class);
- public static final String _defaultBroker = "vm://:1";
- public String _connectionString = _defaultBroker;
private class Receiver
{
- private AMQConnection _connection;
+ private Connection _connection;
private Session[] _sessions;
private MessageCounter[] _counters;
- Receiver(String broker, AMQDestination dest, int sessions) throws
Exception
+ Receiver(Destination dest, int sessions) throws Exception
{
- this((AMQConnection) getConnection("guest", "guest"), dest,
sessions);
+ this(getConnection("guest", "guest"), dest, sessions);
}
- Receiver(AMQConnection connection, AMQDestination dest, int sessions)
throws Exception
+ Receiver(Connection connection, Destination dest, int sessions) throws
Exception
{
_connection = connection;
- _sessions = new AMQSession[sessions];
+ _sessions = new Session[sessions];
_counters = new MessageCounter[sessions];
for (int i = 0; i < sessions; i++)
{
- _sessions[i] = _connection.createSession(false,
AMQSession.NO_ACKNOWLEDGE);
+ _sessions[i] = _connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
_counters[i] = new MessageCounter(_sessions[i].toString());
_sessions[i].createConsumer(dest).setMessageListener(_counters[i]);
}
@@ -81,19 +77,19 @@ public class MultipleConnectionTest exte
private class Publisher
{
- private AMQConnection _connection;
+ private Connection _connection;
private Session _session;
private MessageProducer _producer;
- Publisher(String broker, AMQDestination dest) throws Exception
+ Publisher(Destination dest) throws Exception
{
- this((AMQConnection) getConnection("guest", "guest"), dest);
+ this(getConnection("guest", "guest"), dest);
}
- Publisher(AMQConnection connection, AMQDestination dest) throws
Exception
+ Publisher(Connection connection, Destination dest) throws Exception
{
_connection = connection;
- _session = _connection.createSession(false,
AMQSession.NO_ACKNOWLEDGE);
+ _session = _connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
_producer = _session.createProducer(dest);
}
@@ -171,30 +167,15 @@ public class MultipleConnectionTest exte
}
}
- private static String randomize(String in)
- {
- return in + System.currentTimeMillis();
- }
-
- public static void main(String[] argv) throws Exception
- {
- String broker = (argv.length > 0) ? argv[0] : _defaultBroker;
-
- MultipleConnectionTest test = new MultipleConnectionTest();
- test._connectionString = broker;
- test.test();
- }
-
public void test() throws Exception
{
- String broker = _connectionString;
int messages = 10;
- AMQTopic topic = new AMQTopic(ExchangeDefaults.TOPIC_EXCHANGE_NAME,
"amq.topic");
+ Topic topic = createTopic(getConnection(), getTestName());
- Receiver[] receivers = new Receiver[] { new Receiver(broker, topic,
2), new Receiver(broker, topic, 14) };
+ Receiver[] receivers = new Receiver[] { new Receiver(topic, 2), new
Receiver(topic, 14) };
- Publisher publisher = new Publisher(broker, topic);
+ Publisher publisher = new Publisher(topic);
for (int i = 0; i < messages; i++)
{
publisher.send("Message " + (i + 1));
@@ -214,9 +195,4 @@ public class MultipleConnectionTest exte
}
}
}
-
- public static junit.framework.Test suite()
- {
- return new junit.framework.TestSuite(MultipleConnectionTest.class);
- }
}
Modified:
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/basic/PubSubTwoConnectionTest.java
URL:
http://svn.apache.org/viewvc/qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/basic/PubSubTwoConnectionTest.java?rev=1771201&r1=1771200&r2=1771201&view=diff
==============================================================================
---
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/basic/PubSubTwoConnectionTest.java
(original)
+++
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/basic/PubSubTwoConnectionTest.java
Thu Nov 24 18:28:56 2016
@@ -27,7 +27,6 @@ import javax.jms.Session;
import javax.jms.TextMessage;
import javax.jms.Topic;
-import org.apache.qpid.client.AMQSession;
import org.apache.qpid.test.utils.QpidBrokerTestCase;
/**
@@ -56,11 +55,11 @@ public class PubSubTwoConnectionTest ext
Topic topic = createTopic(con1, "MyTopic");
- Session session1 = con1.createSession(false,
AMQSession.NO_ACKNOWLEDGE);
+ Session session1 = con1.createSession(false, Session.AUTO_ACKNOWLEDGE);
MessageProducer producer = session1.createProducer(topic);
Connection con2 = getConnection("guest", "guest") ;
- Session session2 = con2.createSession(false,
AMQSession.NO_ACKNOWLEDGE);
+ Session session2 = con2.createSession(false, Session.AUTO_ACKNOWLEDGE);
MessageConsumer consumer = session2.createConsumer(topic);
con2.start();
producer.send(session1.createTextMessage("Hello"));
Modified:
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/client/QueueSessionFactoryTest.java
URL:
http://svn.apache.org/viewvc/qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/client/QueueSessionFactoryTest.java?rev=1771201&r1=1771200&r2=1771201&view=diff
==============================================================================
---
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/client/QueueSessionFactoryTest.java
(original)
+++
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/client/QueueSessionFactoryTest.java
Thu Nov 24 18:28:56 2016
@@ -54,7 +54,6 @@ public class QueueSessionFactoryTest ext
catch (javax.jms.IllegalStateException s)
{
// PASS
- assertEquals("Cannot call createTemporaryTopic from QueueSession",
s.getMessage());
}
}
@@ -69,7 +68,6 @@ public class QueueSessionFactoryTest ext
catch (javax.jms.IllegalStateException s)
{
// PASS
- assertEquals("Cannot call createTopic from QueueSession",
s.getMessage());
}
}
@@ -86,7 +84,6 @@ public class QueueSessionFactoryTest ext
catch (javax.jms.IllegalStateException s)
{
// PASS
- assertEquals("Cannot call createDurableSubscriber from
QueueSession", s.getMessage());
}
}
@@ -101,7 +98,7 @@ public class QueueSessionFactoryTest ext
catch (javax.jms.IllegalStateException s)
{
// PASS
- assertEquals("Cannot call unsubscribe from QueueSession",
s.getMessage());
+
}
}
Modified:
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/client/TopicSessionFactoryTest.java
URL:
http://svn.apache.org/viewvc/qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/client/TopicSessionFactoryTest.java?rev=1771201&r1=1771200&r2=1771201&view=diff
==============================================================================
---
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/client/TopicSessionFactoryTest.java
(original)
+++
qpid/java/trunk/systests/src/test/java/org/apache/qpid/test/unit/client/TopicSessionFactoryTest.java
Thu Nov 24 18:28:56 2016
@@ -55,7 +55,6 @@ public class TopicSessionFactoryTest ext
catch (javax.jms.IllegalStateException s)
{
// PASS
- assertEquals("Cannot call createBrowser from TopicSession",
s.getMessage());
}
}
@@ -70,7 +69,6 @@ public class TopicSessionFactoryTest ext
catch (javax.jms.IllegalStateException s)
{
// PASS
- assertEquals("Cannot call createQueue from TopicSession",
s.getMessage());
}
}
@@ -85,7 +83,6 @@ public class TopicSessionFactoryTest ext
catch (javax.jms.IllegalStateException s)
{
// PASS
- assertEquals("Cannot call createTemporaryQueue from TopicSession",
s.getMessage());
}
}
Modified: qpid/java/trunk/test-profiles/Java10BrokenTestsExcludes
URL:
http://svn.apache.org/viewvc/qpid/java/trunk/test-profiles/Java10BrokenTestsExcludes?rev=1771201&r1=1771200&r2=1771201&view=diff
==============================================================================
--- qpid/java/trunk/test-profiles/Java10BrokenTestsExcludes (original)
+++ qpid/java/trunk/test-profiles/Java10BrokenTestsExcludes Thu Nov 24 18:28:56
2016
@@ -51,4 +51,20 @@ org.apache.qpid.systest.management.amqp.
// We are allowed to consume from a temporary queue which should have been
deleted
org.apache.qpid.test.unit.client.temporaryqueue.TemporaryQueueTest#testExplictTemporaryQueueDeletion
+// client issue - the other tests demonstrate that it is not fulfilling the
requirements of a TopicSession,
+// so it shouldn't implement it ...
+org.apache.qpid.test.unit.client.QueueSessionFactoryTest#testQueueSessionIsNotATopicSession
+// ... and vice versa
+org.apache.qpid.test.unit.client.QueueSessionFactoryTest#testTopicSessionCannotCreateCreateBrowser
+
+
+// QueueBrowsers appear to be broken
+org.apache.qpid.test.client.QueueBrowserAutoAckTest#testBrowsingWithSelector
+org.apache.qpid.test.client.QueueBrowserAutoAckTest#testMultipleOverlappingGetEnum
+org.apache.qpid.test.client.QueueBrowserClientAckTest#testBrowsingWithSelector
+org.apache.qpid.test.client.QueueBrowserClientAckTest#testMultipleOverlappingGetEnum
+org.apache.qpid.test.client.QueueBrowserDupsOkTest#testBrowsingWithSelector
+org.apache.qpid.test.client.QueueBrowserDupsOkTest#testMultipleOverlappingGetEnum
+org.apache.qpid.test.client.QueueBrowserTransactedTest#testBrowsingWithSelector
+org.apache.qpid.test.client.QueueBrowserTransactedTest#testMultipleOverlappingGetEnum
Modified: qpid/java/trunk/test-profiles/Java10Excludes
URL:
http://svn.apache.org/viewvc/qpid/java/trunk/test-profiles/Java10Excludes?rev=1771201&r1=1771200&r2=1771201&view=diff
==============================================================================
--- qpid/java/trunk/test-profiles/Java10Excludes (original)
+++ qpid/java/trunk/test-profiles/Java10Excludes Thu Nov 24 18:28:56 2016
@@ -34,4 +34,19 @@ org.apache.qpid.client.message.ObjectMes
// This test checks that the client behaves in a non-JMS spec compliant way
org.apache.qpid.test.unit.message.JMSPropertiesTest#testQpidExtensionProperties
+// This test mainly covers the AMQP 0-x client's heartbeating implementation
+org.apache.qpid.client.HeartbeatTest#*
+
+// This is a test of the MapMessage implementation for the 0-x client
+org.apache.qpid.client.message.AMQPEncodedMapMessageTest#*
+
+// Uses an 0-x client API to acknowledge up to a particular message rather
than the most recent
+org.apache.qpid.test.unit.ack.RecoverTest#testRecoverResendsMsgsAckOnEarlier
+// Tests the effect of setting the prefetch value
+org.apache.qpid.test.unit.ack.RecoverTest#testRecoverSessionAfterCreditExhausted
+
+// Tests a message implementation using an 0-9 data type
+org.apache.qpid.test.unit.basic.FieldTableMessageTest#*
+
+
Modified: qpid/java/trunk/test-profiles/Java10UninvestigatedTestsExcludes
URL:
http://svn.apache.org/viewvc/qpid/java/trunk/test-profiles/Java10UninvestigatedTestsExcludes?rev=1771201&r1=1771200&r2=1771201&view=diff
==============================================================================
--- qpid/java/trunk/test-profiles/Java10UninvestigatedTestsExcludes (original)
+++ qpid/java/trunk/test-profiles/Java10UninvestigatedTestsExcludes Thu Nov 24
18:28:56 2016
@@ -21,17 +21,9 @@ org.apache.qpid.test.unit.basic.LargeMes
org.apache.qpid.test.unit.client.connection.ConnectionStartTest#*
org.apache.qpid.test.unit.client.connection.ExceptionListenerTest#*
org.apache.qpid.test.unit.client.DynamicQueueExchangeCreateTest#*
-org.apache.qpid.test.unit.client.QueueSessionFactoryTest#*
-org.apache.qpid.test.unit.client.TopicSessionFactoryTest#*
org.apache.qpid.test.unit.topic.TemporaryTopicTest#*
-org.apache.qpid.test.client.QueueBrowserAutoAckTest#*
-org.apache.qpid.test.client.QueueBrowserClientAckTest#*
-org.apache.qpid.test.client.QueueBrowserDupsOkTest#*
org.apache.qpid.test.client.QueueBrowserNoAckTest#*
org.apache.qpid.test.client.QueueBrowserPreAckTest#*
-org.apache.qpid.test.client.QueueBrowserTransactedTest#*
-org.apache.qpid.client.HeartbeatTest#*
-org.apache.qpid.client.message.AMQPEncodedMapMessageTest#*
org.apache.qpid.client.prefetch.PrefetchBehaviourTest#*
org.apache.qpid.client.redelivered.RedeliveredMessageTest#*
org.apache.qpid.client.SynchReceiveTest#*
@@ -75,13 +67,10 @@ org.apache.qpid.test.unit.client.connect
org.apache.qpid.test.unit.client.channelclose.CloseWithBlockingReceiveTest#*
org.apache.qpid.test.unit.client.AMQSessionTest#*
org.apache.qpid.test.unit.basic.SessionStartTest#*
-org.apache.qpid.test.unit.basic.PubSubTwoConnectionTest#*
org.apache.qpid.test.unit.basic.PropertyValueTest#*
-org.apache.qpid.test.unit.basic.MultipleConnectionTest#*
org.apache.qpid.test.unit.basic.InvalidDestinationTest#*
org.apache.qpid.test.unit.basic.FieldTableMessageTest#*
org.apache.qpid.test.unit.basic.close.CloseTest#*
-org.apache.qpid.test.unit.ack.RecoverTest#*
org.apache.qpid.test.unit.ack.AcknowledgeTest#*
org.apache.qpid.test.unit.ack.AcknowledgeOnMessageTest#*
org.apache.qpid.test.unit.ack.Acknowledge2ConsumersTest#*
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
