diff options
Diffstat (limited to 'java/systests')
| -rw-r--r-- | java/systests/src/test/java/org/apache/qpid/server/logging/ExchangeLoggingTest.java | 23 | ||||
| -rw-r--r-- | java/systests/src/test/java/org/apache/qpid/transport/MaxFrameSizeTest.java | 4 |
2 files changed, 14 insertions, 13 deletions
diff --git a/java/systests/src/test/java/org/apache/qpid/server/logging/ExchangeLoggingTest.java b/java/systests/src/test/java/org/apache/qpid/server/logging/ExchangeLoggingTest.java index edffa7c0c0..d8a1427875 100644 --- a/java/systests/src/test/java/org/apache/qpid/server/logging/ExchangeLoggingTest.java +++ b/java/systests/src/test/java/org/apache/qpid/server/logging/ExchangeLoggingTest.java @@ -20,14 +20,8 @@ */ package org.apache.qpid.server.logging; -import org.apache.qpid.client.AMQConnection; -import org.apache.qpid.client.AMQSession; -import org.apache.qpid.client.AMQSession_0_10; -import org.apache.qpid.framing.AMQFrame; -import org.apache.qpid.framing.AMQShortString; -import org.apache.qpid.framing.ExchangeDeleteBody; -import org.apache.qpid.framing.ExchangeDeleteOkBody; -import org.apache.qpid.framing.amqp_8_0.MethodRegistry_8_0; +import java.io.IOException; +import java.util.List; import javax.jms.Connection; import javax.jms.JMSException; @@ -35,8 +29,15 @@ import javax.jms.MessageProducer; import javax.jms.Queue; import javax.jms.Session; import javax.jms.TextMessage; -import java.io.IOException; -import java.util.List; + +import org.apache.qpid.client.AMQConnection; +import org.apache.qpid.client.AMQSession; +import org.apache.qpid.client.AMQSession_0_10; +import org.apache.qpid.framing.AMQFrame; +import org.apache.qpid.framing.AMQShortString; +import org.apache.qpid.framing.ExchangeDeleteBody; +import org.apache.qpid.framing.ExchangeDeleteOkBody; +import org.apache.qpid.framing.MethodRegistry; /** * Exchange @@ -191,7 +192,7 @@ public class ExchangeLoggingTest extends AbstractTestLogging } else { - MethodRegistry_8_0 registry = new MethodRegistry_8_0(); + MethodRegistry registry = MethodRegistry.registry_8_0; ExchangeDeleteBody body = registry.createExchangeDeleteBody(0, new AMQShortString(_name), false, true); diff --git a/java/systests/src/test/java/org/apache/qpid/transport/MaxFrameSizeTest.java b/java/systests/src/test/java/org/apache/qpid/transport/MaxFrameSizeTest.java index 639f53e0b6..32396158e5 100644 --- a/java/systests/src/test/java/org/apache/qpid/transport/MaxFrameSizeTest.java +++ b/java/systests/src/test/java/org/apache/qpid/transport/MaxFrameSizeTest.java @@ -54,7 +54,7 @@ import org.apache.qpid.framing.ConnectionCloseBody; import org.apache.qpid.framing.ConnectionStartOkBody; import org.apache.qpid.framing.ConnectionTuneOkBody; import org.apache.qpid.framing.FieldTable; -import org.apache.qpid.framing.amqp_0_91.MethodRegistry_0_91; +import org.apache.qpid.framing.MethodRegistry; import org.apache.qpid.jms.BrokerDetails; import org.apache.qpid.server.model.AuthenticationProvider; import org.apache.qpid.server.model.Broker; @@ -238,7 +238,7 @@ public class MaxFrameSizeTest extends QpidBrokerTestCase byte[] serverData = baos.toByteArray(); ByteArrayDataInput badi = new ByteArrayDataInput(serverData); AMQDataBlockDecoder datablockDecoder = new AMQDataBlockDecoder(); - final MethodRegistry_0_91 methodRegistry_0_91 = new MethodRegistry_0_91(); + final MethodRegistry methodRegistry_0_91 = MethodRegistry.registry_0_91; BodyFactory methodBodyFactory = new BodyFactory() { @Override |