summaryrefslogtreecommitdiff
path: root/java/systests/src/test/java/org/apache/qpid/transport/MaxFrameSizeTest.java
diff options
context:
space:
mode:
authorRobert Godfrey <rgodfrey@apache.org>2014-09-28 16:46:34 +0000
committerRobert Godfrey <rgodfrey@apache.org>2014-09-28 16:46:34 +0000
commit17ff2442352bac23f3776b3a8a6e4e419833e787 (patch)
treeb188a173a65e24e6302dbe12656c174cc2f4590d /java/systests/src/test/java/org/apache/qpid/transport/MaxFrameSizeTest.java
parent9eeb3ec4303c7527e9a9c815278606236e7d701d (diff)
downloadqpid-python-17ff2442352bac23f3776b3a8a6e4e419833e787.tar.gz
Remove redundant interfaces
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6125-ProtocolRefactoring@1628082 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/systests/src/test/java/org/apache/qpid/transport/MaxFrameSizeTest.java')
-rw-r--r--java/systests/src/test/java/org/apache/qpid/transport/MaxFrameSizeTest.java6
1 files changed, 2 insertions, 4 deletions
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 74beb7cd58..639f53e0b6 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,8 +54,6 @@ 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.ConnectionStartOkBodyImpl;
-import org.apache.qpid.framing.ConnectionTuneOkBodyImpl;
import org.apache.qpid.framing.amqp_0_91.MethodRegistry_0_91;
import org.apache.qpid.jms.BrokerDetails;
import org.apache.qpid.server.model.AuthenticationProvider;
@@ -220,12 +218,12 @@ public class MaxFrameSizeTest extends QpidBrokerTestCase
response[i++] = b;
}
- ConnectionStartOkBody startOK = new ConnectionStartOkBodyImpl(new FieldTable(), AMQShortString.valueOf("PLAIN"), response, AMQShortString.valueOf("en_US"));
+ ConnectionStartOkBody startOK = new ConnectionStartOkBody(new FieldTable(), AMQShortString.valueOf("PLAIN"), response, AMQShortString.valueOf("en_US"));
DataOutputStream dos = new DataOutputStream(os);
new AMQFrame(0, startOK).writePayload(dos);
dos.flush();
- ConnectionTuneOkBody tuneOk = new ConnectionTuneOkBodyImpl(256, frameSize, 0);
+ ConnectionTuneOkBody tuneOk = new ConnectionTuneOkBody(256, frameSize, 0);
new AMQFrame(0, tuneOk).writePayload(dos);
dos.flush();
socket.setSoTimeout(5000);