diff options
author | Robert Godfrey <rgodfrey@apache.org> | 2014-09-28 16:46:34 +0000 |
---|---|---|
committer | Robert Godfrey <rgodfrey@apache.org> | 2014-09-28 16:46:34 +0000 |
commit | 17ff2442352bac23f3776b3a8a6e4e419833e787 (patch) | |
tree | b188a173a65e24e6302dbe12656c174cc2f4590d /java/systests/src/test/java/org/apache/qpid/transport/MaxFrameSizeTest.java | |
parent | 9eeb3ec4303c7527e9a9c815278606236e7d701d (diff) | |
download | qpid-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.java | 6 |
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); |