Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeBoundBodyImpl.java (from r1628068, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/ExchangeBoundBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeBoundBodyImpl.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeBoundBodyImpl.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/ExchangeBoundBodyImpl.java&r1=1628068&r2=1628074&rev=1628074&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/ExchangeBoundBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeBoundBodyImpl.java Sun Sep 28 15:22:03 2014 @@ -25,16 +25,15 @@ * 8-0 */ -package org.apache.qpid.framing.amqp_8_0; +package org.apache.qpid.framing; -import org.apache.qpid.codec.MarkableDataInput; import java.io.DataOutput; import java.io.IOException; -import org.apache.qpid.framing.*; import org.apache.qpid.AMQException; +import org.apache.qpid.codec.MarkableDataInput; -public class ExchangeBoundBodyImpl extends AMQMethodBody_8_0 implements ExchangeBoundBody +public class ExchangeBoundBodyImpl extends AMQMethodBodyImpl implements ExchangeBoundBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { @@ -117,7 +116,7 @@ public class ExchangeBoundBodyImpl exten public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException { - return ((MethodDispatcher_8_0)dispatcher).dispatchExchangeBound(this, channelId); + return dispatcher.dispatchExchangeBound(this, channelId); } public String toString()
Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeBoundOkBodyImpl.java (from r1628068, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/ExchangeBoundOkBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeBoundOkBodyImpl.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeBoundOkBodyImpl.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/ExchangeBoundOkBodyImpl.java&r1=1628068&r2=1628074&rev=1628074&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/ExchangeBoundOkBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeBoundOkBodyImpl.java Sun Sep 28 15:22:03 2014 @@ -25,16 +25,15 @@ * 8-0 */ -package org.apache.qpid.framing.amqp_8_0; +package org.apache.qpid.framing; -import org.apache.qpid.codec.MarkableDataInput; import java.io.DataOutput; import java.io.IOException; -import org.apache.qpid.framing.*; import org.apache.qpid.AMQException; +import org.apache.qpid.codec.MarkableDataInput; -public class ExchangeBoundOkBodyImpl extends AMQMethodBody_8_0 implements ExchangeBoundOkBody +public class ExchangeBoundOkBodyImpl extends AMQMethodBodyImpl implements ExchangeBoundOkBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { @@ -106,7 +105,7 @@ public class ExchangeBoundOkBodyImpl ext public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException { - return ((MethodDispatcher_8_0)dispatcher).dispatchExchangeBoundOk(this, channelId); + return dispatcher.dispatchExchangeBoundOk(this, channelId); } public String toString() Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeclareBodyImpl.java (from r1628068, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/ExchangeDeclareBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeclareBodyImpl.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeclareBodyImpl.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/ExchangeDeclareBodyImpl.java&r1=1628068&r2=1628074&rev=1628074&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/ExchangeDeclareBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeclareBodyImpl.java Sun Sep 28 15:22:03 2014 @@ -25,16 +25,15 @@ * 8-0 */ -package org.apache.qpid.framing.amqp_8_0; +package org.apache.qpid.framing; -import org.apache.qpid.codec.MarkableDataInput; import java.io.DataOutput; import java.io.IOException; -import org.apache.qpid.framing.*; import org.apache.qpid.AMQException; +import org.apache.qpid.codec.MarkableDataInput; -public class ExchangeDeclareBodyImpl extends AMQMethodBody_8_0 implements ExchangeDeclareBody +public class ExchangeDeclareBodyImpl extends AMQMethodBodyImpl implements ExchangeDeclareBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { @@ -181,7 +180,7 @@ public class ExchangeDeclareBodyImpl ext public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException { - return ((MethodDispatcher_8_0)dispatcher).dispatchExchangeDeclare(this, channelId); + return dispatcher.dispatchExchangeDeclare(this, channelId); } public String toString() Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeclareOkBodyImpl.java (from r1628068, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/ExchangeDeclareOkBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeclareOkBodyImpl.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeclareOkBodyImpl.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/ExchangeDeclareOkBodyImpl.java&r1=1628068&r2=1628074&rev=1628074&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/ExchangeDeclareOkBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeclareOkBodyImpl.java Sun Sep 28 15:22:03 2014 @@ -25,16 +25,15 @@ * 8-0 */ -package org.apache.qpid.framing.amqp_8_0; +package org.apache.qpid.framing; -import org.apache.qpid.codec.MarkableDataInput; import java.io.DataOutput; import java.io.IOException; -import org.apache.qpid.framing.*; import org.apache.qpid.AMQException; +import org.apache.qpid.codec.MarkableDataInput; -public class ExchangeDeclareOkBodyImpl extends AMQMethodBody_8_0 implements ExchangeDeclareOkBody +public class ExchangeDeclareOkBodyImpl extends AMQMethodBodyImpl implements ExchangeDeclareOkBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { @@ -87,7 +86,7 @@ public class ExchangeDeclareOkBodyImpl e public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException { - return ((MethodDispatcher_8_0)dispatcher).dispatchExchangeDeclareOk(this, channelId); + return dispatcher.dispatchExchangeDeclareOk(this, channelId); } public String toString() Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeleteBodyImpl.java (from r1628068, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/ExchangeDeleteBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeleteBodyImpl.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeleteBodyImpl.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/ExchangeDeleteBodyImpl.java&r1=1628068&r2=1628074&rev=1628074&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/ExchangeDeleteBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeleteBodyImpl.java Sun Sep 28 15:22:03 2014 @@ -25,16 +25,15 @@ * 8-0 */ -package org.apache.qpid.framing.amqp_8_0; +package org.apache.qpid.framing; -import org.apache.qpid.codec.MarkableDataInput; import java.io.DataOutput; import java.io.IOException; -import org.apache.qpid.framing.*; import org.apache.qpid.AMQException; +import org.apache.qpid.codec.MarkableDataInput; -public class ExchangeDeleteBodyImpl extends AMQMethodBody_8_0 implements ExchangeDeleteBody +public class ExchangeDeleteBodyImpl extends AMQMethodBodyImpl implements ExchangeDeleteBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { @@ -130,7 +129,7 @@ public class ExchangeDeleteBodyImpl exte public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException { - return ((MethodDispatcher_8_0)dispatcher).dispatchExchangeDelete(this, channelId); + return dispatcher.dispatchExchangeDelete(this, channelId); } public String toString() Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeleteOkBodyImpl.java (from r1628068, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/ExchangeDeleteOkBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeleteOkBodyImpl.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeleteOkBodyImpl.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/ExchangeDeleteOkBodyImpl.java&r1=1628068&r2=1628074&rev=1628074&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/ExchangeDeleteOkBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/ExchangeDeleteOkBodyImpl.java Sun Sep 28 15:22:03 2014 @@ -25,16 +25,15 @@ * 8-0 */ -package org.apache.qpid.framing.amqp_8_0; +package org.apache.qpid.framing; -import org.apache.qpid.codec.MarkableDataInput; import java.io.DataOutput; import java.io.IOException; -import org.apache.qpid.framing.*; import org.apache.qpid.AMQException; +import org.apache.qpid.codec.MarkableDataInput; -public class ExchangeDeleteOkBodyImpl extends AMQMethodBody_8_0 implements ExchangeDeleteOkBody +public class ExchangeDeleteOkBodyImpl extends AMQMethodBodyImpl implements ExchangeDeleteOkBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { @@ -87,7 +86,7 @@ public class ExchangeDeleteOkBodyImpl ex public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException { - return ((MethodDispatcher_8_0)dispatcher).dispatchExchangeDeleteOk(this, channelId); + return dispatcher.dispatchExchangeDeleteOk(this, channelId); } public String toString() Added: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/MethodRegistrySource.java URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/MethodRegistrySource.java?rev=1628074&view=auto ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/MethodRegistrySource.java (added) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/MethodRegistrySource.java Sun Sep 28 15:22:03 2014 @@ -0,0 +1,26 @@ +/* + * + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + * + */ +package org.apache.qpid.framing; + +public interface MethodRegistrySource +{ + public MethodRegistry getMethodRegistry(); +} Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueBindBodyImpl.java (from r1628068, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/QueueBindBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueBindBodyImpl.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueBindBodyImpl.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/QueueBindBodyImpl.java&r1=1628068&r2=1628074&rev=1628074&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/QueueBindBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueBindBodyImpl.java Sun Sep 28 15:22:03 2014 @@ -25,16 +25,15 @@ * 8-0 */ -package org.apache.qpid.framing.amqp_8_0; +package org.apache.qpid.framing; -import org.apache.qpid.codec.MarkableDataInput; import java.io.DataOutput; import java.io.IOException; -import org.apache.qpid.framing.*; import org.apache.qpid.AMQException; +import org.apache.qpid.codec.MarkableDataInput; -public class QueueBindBodyImpl extends AMQMethodBody_8_0 implements QueueBindBody +public class QueueBindBodyImpl extends AMQMethodBodyImpl implements QueueBindBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { @@ -151,7 +150,7 @@ public class QueueBindBodyImpl extends A public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException { - return ((MethodDispatcher_8_0)dispatcher).dispatchQueueBind(this, channelId); + return dispatcher.dispatchQueueBind(this, channelId); } public String toString() Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueBindOkBodyImpl.java (from r1628068, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/QueueBindOkBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueBindOkBodyImpl.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueBindOkBodyImpl.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/QueueBindOkBodyImpl.java&r1=1628068&r2=1628074&rev=1628074&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/QueueBindOkBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueBindOkBodyImpl.java Sun Sep 28 15:22:03 2014 @@ -25,16 +25,15 @@ * 8-0 */ -package org.apache.qpid.framing.amqp_8_0; +package org.apache.qpid.framing; -import org.apache.qpid.codec.MarkableDataInput; import java.io.DataOutput; import java.io.IOException; -import org.apache.qpid.framing.*; import org.apache.qpid.AMQException; +import org.apache.qpid.codec.MarkableDataInput; -public class QueueBindOkBodyImpl extends AMQMethodBody_8_0 implements QueueBindOkBody +public class QueueBindOkBodyImpl extends AMQMethodBodyImpl implements QueueBindOkBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { @@ -87,7 +86,7 @@ public class QueueBindOkBodyImpl extends public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException { - return ((MethodDispatcher_8_0)dispatcher).dispatchQueueBindOk(this, channelId); + return dispatcher.dispatchQueueBindOk(this, channelId); } public String toString() Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareBodyImpl.java (from r1628068, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/QueueDeclareBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareBodyImpl.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareBodyImpl.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/QueueDeclareBodyImpl.java&r1=1628068&r2=1628074&rev=1628074&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/QueueDeclareBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareBodyImpl.java Sun Sep 28 15:22:03 2014 @@ -25,16 +25,15 @@ * 8-0 */ -package org.apache.qpid.framing.amqp_8_0; +package org.apache.qpid.framing; -import org.apache.qpid.codec.MarkableDataInput; import java.io.DataOutput; import java.io.IOException; -import org.apache.qpid.framing.*; import org.apache.qpid.AMQException; +import org.apache.qpid.codec.MarkableDataInput; -public class QueueDeclareBodyImpl extends AMQMethodBody_8_0 implements QueueDeclareBody +public class QueueDeclareBodyImpl extends AMQMethodBodyImpl implements QueueDeclareBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { @@ -171,7 +170,7 @@ public class QueueDeclareBodyImpl extend public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException { - return ((MethodDispatcher_8_0)dispatcher).dispatchQueueDeclare(this, channelId); + return dispatcher.dispatchQueueDeclare(this, channelId); } public String toString() Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareOkBodyImpl.java (from r1628068, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/QueueDeclareOkBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareOkBodyImpl.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareOkBodyImpl.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/QueueDeclareOkBodyImpl.java&r1=1628068&r2=1628074&rev=1628074&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/QueueDeclareOkBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeclareOkBodyImpl.java Sun Sep 28 15:22:03 2014 @@ -25,16 +25,15 @@ * 8-0 */ -package org.apache.qpid.framing.amqp_8_0; +package org.apache.qpid.framing; -import org.apache.qpid.codec.MarkableDataInput; import java.io.DataOutput; import java.io.IOException; -import org.apache.qpid.framing.*; import org.apache.qpid.AMQException; +import org.apache.qpid.codec.MarkableDataInput; -public class QueueDeclareOkBodyImpl extends AMQMethodBody_8_0 implements QueueDeclareOkBody +public class QueueDeclareOkBodyImpl extends AMQMethodBodyImpl implements QueueDeclareOkBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { @@ -115,7 +114,7 @@ public class QueueDeclareOkBodyImpl exte public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException { - return ((MethodDispatcher_8_0)dispatcher).dispatchQueueDeclareOk(this, channelId); + return dispatcher.dispatchQueueDeclareOk(this, channelId); } public String toString() Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteBodyImpl.java (from r1628068, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/QueueDeleteBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteBodyImpl.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteBodyImpl.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/QueueDeleteBodyImpl.java&r1=1628068&r2=1628074&rev=1628074&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/QueueDeleteBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteBodyImpl.java Sun Sep 28 15:22:03 2014 @@ -25,16 +25,15 @@ * 8-0 */ -package org.apache.qpid.framing.amqp_8_0; +package org.apache.qpid.framing; -import org.apache.qpid.codec.MarkableDataInput; import java.io.DataOutput; import java.io.IOException; -import org.apache.qpid.framing.*; import org.apache.qpid.AMQException; +import org.apache.qpid.codec.MarkableDataInput; -public class QueueDeleteBodyImpl extends AMQMethodBody_8_0 implements QueueDeleteBody +public class QueueDeleteBodyImpl extends AMQMethodBodyImpl implements QueueDeleteBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { @@ -140,7 +139,7 @@ public class QueueDeleteBodyImpl extends public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException { - return ((MethodDispatcher_8_0)dispatcher).dispatchQueueDelete(this, channelId); + return dispatcher.dispatchQueueDelete(this, channelId); } public String toString() Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteOkBodyImpl.java (from r1628068, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/QueueDeleteOkBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteOkBodyImpl.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteOkBodyImpl.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/QueueDeleteOkBodyImpl.java&r1=1628068&r2=1628074&rev=1628074&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/QueueDeleteOkBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueueDeleteOkBodyImpl.java Sun Sep 28 15:22:03 2014 @@ -25,16 +25,15 @@ * 8-0 */ -package org.apache.qpid.framing.amqp_8_0; +package org.apache.qpid.framing; -import org.apache.qpid.codec.MarkableDataInput; import java.io.DataOutput; import java.io.IOException; -import org.apache.qpid.framing.*; import org.apache.qpid.AMQException; +import org.apache.qpid.codec.MarkableDataInput; -public class QueueDeleteOkBodyImpl extends AMQMethodBody_8_0 implements QueueDeleteOkBody +public class QueueDeleteOkBodyImpl extends AMQMethodBodyImpl implements QueueDeleteOkBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { @@ -96,7 +95,7 @@ public class QueueDeleteOkBodyImpl exten public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException { - return ((MethodDispatcher_8_0)dispatcher).dispatchQueueDeleteOk(this, channelId); + return dispatcher.dispatchQueueDeleteOk(this, channelId); } public String toString() Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueuePurgeBodyImpl.java (from r1628068, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/QueuePurgeBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueuePurgeBodyImpl.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueuePurgeBodyImpl.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/QueuePurgeBodyImpl.java&r1=1628068&r2=1628074&rev=1628074&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/QueuePurgeBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueuePurgeBodyImpl.java Sun Sep 28 15:22:03 2014 @@ -25,16 +25,15 @@ * 8-0 */ -package org.apache.qpid.framing.amqp_8_0; +package org.apache.qpid.framing; -import org.apache.qpid.codec.MarkableDataInput; import java.io.DataOutput; import java.io.IOException; -import org.apache.qpid.framing.*; import org.apache.qpid.AMQException; +import org.apache.qpid.codec.MarkableDataInput; -public class QueuePurgeBodyImpl extends AMQMethodBody_8_0 implements QueuePurgeBody +public class QueuePurgeBodyImpl extends AMQMethodBodyImpl implements QueuePurgeBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { @@ -120,7 +119,7 @@ public class QueuePurgeBodyImpl extends public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException { - return ((MethodDispatcher_8_0)dispatcher).dispatchQueuePurge(this, channelId); + return dispatcher.dispatchQueuePurge(this, channelId); } public String toString() Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueuePurgeOkBodyImpl.java (from r1628068, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/QueuePurgeOkBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueuePurgeOkBodyImpl.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueuePurgeOkBodyImpl.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/QueuePurgeOkBodyImpl.java&r1=1628068&r2=1628074&rev=1628074&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/QueuePurgeOkBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/QueuePurgeOkBodyImpl.java Sun Sep 28 15:22:03 2014 @@ -25,16 +25,15 @@ * 8-0 */ -package org.apache.qpid.framing.amqp_8_0; +package org.apache.qpid.framing; -import org.apache.qpid.codec.MarkableDataInput; import java.io.DataOutput; import java.io.IOException; -import org.apache.qpid.framing.*; import org.apache.qpid.AMQException; +import org.apache.qpid.codec.MarkableDataInput; -public class QueuePurgeOkBodyImpl extends AMQMethodBody_8_0 implements QueuePurgeOkBody +public class QueuePurgeOkBodyImpl extends AMQMethodBodyImpl implements QueuePurgeOkBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { @@ -96,7 +95,7 @@ public class QueuePurgeOkBodyImpl extend public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException { - return ((MethodDispatcher_8_0)dispatcher).dispatchQueuePurgeOk(this, channelId); + return dispatcher.dispatchQueuePurgeOk(this, channelId); } public String toString() Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxCommitBodyImpl.java (from r1628068, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxCommitBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxCommitBodyImpl.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxCommitBodyImpl.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxCommitBodyImpl.java&r1=1628068&r2=1628074&rev=1628074&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxCommitBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxCommitBodyImpl.java Sun Sep 28 15:22:03 2014 @@ -25,16 +25,15 @@ * 8-0 */ -package org.apache.qpid.framing.amqp_8_0; +package org.apache.qpid.framing; -import org.apache.qpid.codec.MarkableDataInput; import java.io.DataOutput; import java.io.IOException; -import org.apache.qpid.framing.*; import org.apache.qpid.AMQException; +import org.apache.qpid.codec.MarkableDataInput; -public class TxCommitBodyImpl extends AMQMethodBody_8_0 implements TxCommitBody +public class TxCommitBodyImpl extends AMQMethodBodyImpl implements TxCommitBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { @@ -87,7 +86,7 @@ public class TxCommitBodyImpl extends AM public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException { - return ((MethodDispatcher_8_0)dispatcher).dispatchTxCommit(this, channelId); + return dispatcher.dispatchTxCommit(this, channelId); } public String toString() Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxCommitOkBodyImpl.java (from r1628068, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxCommitOkBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxCommitOkBodyImpl.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxCommitOkBodyImpl.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxCommitOkBodyImpl.java&r1=1628068&r2=1628074&rev=1628074&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxCommitOkBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxCommitOkBodyImpl.java Sun Sep 28 15:22:03 2014 @@ -25,16 +25,15 @@ * 8-0 */ -package org.apache.qpid.framing.amqp_8_0; +package org.apache.qpid.framing; -import org.apache.qpid.codec.MarkableDataInput; import java.io.DataOutput; import java.io.IOException; -import org.apache.qpid.framing.*; import org.apache.qpid.AMQException; +import org.apache.qpid.codec.MarkableDataInput; -public class TxCommitOkBodyImpl extends AMQMethodBody_8_0 implements TxCommitOkBody +public class TxCommitOkBodyImpl extends AMQMethodBodyImpl implements TxCommitOkBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { @@ -87,7 +86,7 @@ public class TxCommitOkBodyImpl extends public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException { - return ((MethodDispatcher_8_0)dispatcher).dispatchTxCommitOk(this, channelId); + return dispatcher.dispatchTxCommitOk(this, channelId); } public String toString() Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxRollbackBodyImpl.java (from r1628068, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxRollbackBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxRollbackBodyImpl.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxRollbackBodyImpl.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxRollbackBodyImpl.java&r1=1628068&r2=1628074&rev=1628074&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxRollbackBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxRollbackBodyImpl.java Sun Sep 28 15:22:03 2014 @@ -25,16 +25,15 @@ * 8-0 */ -package org.apache.qpid.framing.amqp_8_0; +package org.apache.qpid.framing; -import org.apache.qpid.codec.MarkableDataInput; import java.io.DataOutput; import java.io.IOException; -import org.apache.qpid.framing.*; import org.apache.qpid.AMQException; +import org.apache.qpid.codec.MarkableDataInput; -public class TxRollbackBodyImpl extends AMQMethodBody_8_0 implements TxRollbackBody +public class TxRollbackBodyImpl extends AMQMethodBodyImpl implements TxRollbackBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { @@ -87,7 +86,7 @@ public class TxRollbackBodyImpl extends public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException { - return ((MethodDispatcher_8_0)dispatcher).dispatchTxRollback(this, channelId); + return dispatcher.dispatchTxRollback(this, channelId); } public String toString() Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxRollbackOkBodyImpl.java (from r1628068, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxRollbackOkBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxRollbackOkBodyImpl.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxRollbackOkBodyImpl.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxRollbackOkBodyImpl.java&r1=1628068&r2=1628074&rev=1628074&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxRollbackOkBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxRollbackOkBodyImpl.java Sun Sep 28 15:22:03 2014 @@ -25,16 +25,15 @@ * 8-0 */ -package org.apache.qpid.framing.amqp_8_0; +package org.apache.qpid.framing; -import org.apache.qpid.codec.MarkableDataInput; import java.io.DataOutput; import java.io.IOException; -import org.apache.qpid.framing.*; import org.apache.qpid.AMQException; +import org.apache.qpid.codec.MarkableDataInput; -public class TxRollbackOkBodyImpl extends AMQMethodBody_8_0 implements TxRollbackOkBody +public class TxRollbackOkBodyImpl extends AMQMethodBodyImpl implements TxRollbackOkBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { @@ -87,7 +86,7 @@ public class TxRollbackOkBodyImpl extend public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException { - return ((MethodDispatcher_8_0)dispatcher).dispatchTxRollbackOk(this, channelId); + return dispatcher.dispatchTxRollbackOk(this, channelId); } public String toString() Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxSelectBodyImpl.java (from r1628068, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxSelectBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxSelectBodyImpl.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxSelectBodyImpl.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxSelectBodyImpl.java&r1=1628068&r2=1628074&rev=1628074&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxSelectBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxSelectBodyImpl.java Sun Sep 28 15:22:03 2014 @@ -25,16 +25,15 @@ * 8-0 */ -package org.apache.qpid.framing.amqp_8_0; +package org.apache.qpid.framing; -import org.apache.qpid.codec.MarkableDataInput; import java.io.DataOutput; import java.io.IOException; -import org.apache.qpid.framing.*; import org.apache.qpid.AMQException; +import org.apache.qpid.codec.MarkableDataInput; -public class TxSelectBodyImpl extends AMQMethodBody_8_0 implements TxSelectBody +public class TxSelectBodyImpl extends AMQMethodBodyImpl implements TxSelectBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { @@ -87,7 +86,7 @@ public class TxSelectBodyImpl extends AM public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException { - return ((MethodDispatcher_8_0)dispatcher).dispatchTxSelect(this, channelId); + return dispatcher.dispatchTxSelect(this, channelId); } public String toString() Copied: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxSelectOkBodyImpl.java (from r1628068, qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxSelectOkBodyImpl.java) URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxSelectOkBodyImpl.java?p2=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxSelectOkBodyImpl.java&p1=qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxSelectOkBodyImpl.java&r1=1628068&r2=1628074&rev=1628074&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_8_0/TxSelectOkBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/TxSelectOkBodyImpl.java Sun Sep 28 15:22:03 2014 @@ -25,16 +25,15 @@ * 8-0 */ -package org.apache.qpid.framing.amqp_8_0; +package org.apache.qpid.framing; -import org.apache.qpid.codec.MarkableDataInput; import java.io.DataOutput; import java.io.IOException; -import org.apache.qpid.framing.*; import org.apache.qpid.AMQException; +import org.apache.qpid.codec.MarkableDataInput; -public class TxSelectOkBodyImpl extends AMQMethodBody_8_0 implements TxSelectOkBody +public class TxSelectOkBodyImpl extends AMQMethodBodyImpl implements TxSelectOkBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { @@ -87,7 +86,7 @@ public class TxSelectOkBodyImpl extends public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException { - return ((MethodDispatcher_8_0)dispatcher).dispatchTxSelectOk(this, channelId); + return dispatcher.dispatchTxSelectOk(this, channelId); } public String toString() Modified: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/AccessRequestBodyImpl.java URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/AccessRequestBodyImpl.java?rev=1628074&r1=1628073&r2=1628074&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/AccessRequestBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/AccessRequestBodyImpl.java Sun Sep 28 15:22:03 2014 @@ -27,14 +27,20 @@ package org.apache.qpid.framing.amqp_0_9; -import org.apache.qpid.codec.MarkableDataInput; import java.io.DataOutput; import java.io.IOException; -import org.apache.qpid.framing.*; import org.apache.qpid.AMQException; +import org.apache.qpid.codec.MarkableDataInput; +import org.apache.qpid.framing.AMQFrameDecodingException; +import org.apache.qpid.framing.AMQMethodBody; +import org.apache.qpid.framing.AMQMethodBodyImpl; +import org.apache.qpid.framing.AMQMethodBodyInstanceFactory; +import org.apache.qpid.framing.AMQShortString; +import org.apache.qpid.framing.AccessRequestBody; +import org.apache.qpid.framing.MethodDispatcher; -public class AccessRequestBodyImpl extends AMQMethodBody_0_9 implements AccessRequestBody +public class AccessRequestBodyImpl extends AMQMethodBodyImpl implements AccessRequestBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { Modified: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/AccessRequestOkBodyImpl.java URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/AccessRequestOkBodyImpl.java?rev=1628074&r1=1628073&r2=1628074&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/AccessRequestOkBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/AccessRequestOkBodyImpl.java Sun Sep 28 15:22:03 2014 @@ -34,7 +34,7 @@ import java.io.IOException; import org.apache.qpid.framing.*; import org.apache.qpid.AMQException; -public class AccessRequestOkBodyImpl extends AMQMethodBody_0_9 implements AccessRequestOkBody +public class AccessRequestOkBodyImpl extends AMQMethodBodyImpl implements AccessRequestOkBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { Modified: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/BasicRecoverSyncBodyImpl.java URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/BasicRecoverSyncBodyImpl.java?rev=1628074&r1=1628073&r2=1628074&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/BasicRecoverSyncBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/BasicRecoverSyncBodyImpl.java Sun Sep 28 15:22:03 2014 @@ -34,7 +34,7 @@ import java.io.IOException; import org.apache.qpid.framing.*; import org.apache.qpid.AMQException; -public class BasicRecoverSyncBodyImpl extends AMQMethodBody_0_9 implements BasicRecoverSyncBody +public class BasicRecoverSyncBodyImpl extends AMQMethodBodyImpl implements BasicRecoverSyncBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { Modified: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/BasicRecoverSyncOkBodyImpl.java URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/BasicRecoverSyncOkBodyImpl.java?rev=1628074&r1=1628073&r2=1628074&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/BasicRecoverSyncOkBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/BasicRecoverSyncOkBodyImpl.java Sun Sep 28 15:22:03 2014 @@ -34,7 +34,7 @@ import java.io.IOException; import org.apache.qpid.framing.*; import org.apache.qpid.AMQException; -public class BasicRecoverSyncOkBodyImpl extends AMQMethodBody_0_9 implements BasicRecoverSyncOkBody +public class BasicRecoverSyncOkBodyImpl extends AMQMethodBodyImpl implements BasicRecoverSyncOkBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { Modified: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/ChannelOpenOkBodyImpl.java URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/ChannelOpenOkBodyImpl.java?rev=1628074&r1=1628073&r2=1628074&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/ChannelOpenOkBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/ChannelOpenOkBodyImpl.java Sun Sep 28 15:22:03 2014 @@ -34,7 +34,7 @@ import java.io.IOException; import org.apache.qpid.framing.*; import org.apache.qpid.AMQException; -public class ChannelOpenOkBodyImpl extends AMQMethodBody_0_9 implements ChannelOpenOkBody +public class ChannelOpenOkBodyImpl extends AMQMethodBodyImpl implements ChannelOpenOkBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { Modified: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/ClientMethodDispatcher_0_9.java URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/ClientMethodDispatcher_0_9.java?rev=1628074&r1=1628073&r2=1628074&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/ClientMethodDispatcher_0_9.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/ClientMethodDispatcher_0_9.java Sun Sep 28 15:22:03 2014 @@ -34,64 +34,8 @@ public interface ClientMethodDispatcher_ { public boolean dispatchAccessRequestOk(AccessRequestOkBody body, int channelId) throws AMQException; - public boolean dispatchBasicCancelOk(BasicCancelOkBody body, int channelId) throws AMQException; - public boolean dispatchBasicConsumeOk(BasicConsumeOkBody body, int channelId) throws AMQException; - public boolean dispatchBasicDeliver(BasicDeliverBody body, int channelId) throws AMQException; - public boolean dispatchBasicGetEmpty(BasicGetEmptyBody body, int channelId) throws AMQException; - public boolean dispatchBasicGetOk(BasicGetOkBody body, int channelId) throws AMQException; - public boolean dispatchBasicQosOk(BasicQosOkBody body, int channelId) throws AMQException; public boolean dispatchBasicRecoverSyncOk(BasicRecoverSyncOkBody body, int channelId) throws AMQException; - public boolean dispatchBasicReturn(BasicReturnBody body, int channelId) throws AMQException; - public boolean dispatchChannelClose(ChannelCloseBody body, int channelId) throws AMQException; - public boolean dispatchChannelCloseOk(ChannelCloseOkBody body, int channelId) throws AMQException; - public boolean dispatchChannelFlow(ChannelFlowBody body, int channelId) throws AMQException; - public boolean dispatchChannelFlowOk(ChannelFlowOkBody body, int channelId) throws AMQException; - public boolean dispatchChannelOk(ChannelOkBody body, int channelId) throws AMQException; - public boolean dispatchChannelOpenOk(ChannelOpenOkBody body, int channelId) throws AMQException; - public boolean dispatchChannelPing(ChannelPingBody body, int channelId) throws AMQException; - public boolean dispatchChannelPong(ChannelPongBody body, int channelId) throws AMQException; - public boolean dispatchConnectionClose(ConnectionCloseBody body, int channelId) throws AMQException; - public boolean dispatchConnectionCloseOk(ConnectionCloseOkBody body, int channelId) throws AMQException; - public boolean dispatchConnectionOpenOk(ConnectionOpenOkBody body, int channelId) throws AMQException; public boolean dispatchConnectionRedirect(ConnectionRedirectBody body, int channelId) throws AMQException; - public boolean dispatchConnectionSecure(ConnectionSecureBody body, int channelId) throws AMQException; - public boolean dispatchConnectionStart(ConnectionStartBody body, int channelId) throws AMQException; - public boolean dispatchConnectionTune(ConnectionTuneBody body, int channelId) throws AMQException; - public boolean dispatchDtxSelectOk(DtxSelectOkBody body, int channelId) throws AMQException; - public boolean dispatchDtxStartOk(DtxStartOkBody body, int channelId) throws AMQException; - public boolean dispatchExchangeBoundOk(ExchangeBoundOkBody body, int channelId) throws AMQException; - public boolean dispatchExchangeDeclareOk(ExchangeDeclareOkBody body, int channelId) throws AMQException; - public boolean dispatchExchangeDeleteOk(ExchangeDeleteOkBody body, int channelId) throws AMQException; - public boolean dispatchFileCancelOk(FileCancelOkBody body, int channelId) throws AMQException; - public boolean dispatchFileConsumeOk(FileConsumeOkBody body, int channelId) throws AMQException; - public boolean dispatchFileDeliver(FileDeliverBody body, int channelId) throws AMQException; - public boolean dispatchFileOpen(FileOpenBody body, int channelId) throws AMQException; - public boolean dispatchFileOpenOk(FileOpenOkBody body, int channelId) throws AMQException; - public boolean dispatchFileQosOk(FileQosOkBody body, int channelId) throws AMQException; - public boolean dispatchFileReturn(FileReturnBody body, int channelId) throws AMQException; - public boolean dispatchFileStage(FileStageBody body, int channelId) throws AMQException; - public boolean dispatchMessageAppend(MessageAppendBody body, int channelId) throws AMQException; - public boolean dispatchMessageCheckpoint(MessageCheckpointBody body, int channelId) throws AMQException; - public boolean dispatchMessageClose(MessageCloseBody body, int channelId) throws AMQException; - public boolean dispatchMessageEmpty(MessageEmptyBody body, int channelId) throws AMQException; - public boolean dispatchMessageOffset(MessageOffsetBody body, int channelId) throws AMQException; - public boolean dispatchMessageOk(MessageOkBody body, int channelId) throws AMQException; - public boolean dispatchMessageOpen(MessageOpenBody body, int channelId) throws AMQException; - public boolean dispatchMessageReject(MessageRejectBody body, int channelId) throws AMQException; - public boolean dispatchMessageResume(MessageResumeBody body, int channelId) throws AMQException; - public boolean dispatchMessageTransfer(MessageTransferBody body, int channelId) throws AMQException; - public boolean dispatchQueueBindOk(QueueBindOkBody body, int channelId) throws AMQException; - public boolean dispatchQueueDeclareOk(QueueDeclareOkBody body, int channelId) throws AMQException; - public boolean dispatchQueueDeleteOk(QueueDeleteOkBody body, int channelId) throws AMQException; - public boolean dispatchQueuePurgeOk(QueuePurgeOkBody body, int channelId) throws AMQException; public boolean dispatchQueueUnbindOk(QueueUnbindOkBody body, int channelId) throws AMQException; - public boolean dispatchStreamCancelOk(StreamCancelOkBody body, int channelId) throws AMQException; - public boolean dispatchStreamConsumeOk(StreamConsumeOkBody body, int channelId) throws AMQException; - public boolean dispatchStreamDeliver(StreamDeliverBody body, int channelId) throws AMQException; - public boolean dispatchStreamQosOk(StreamQosOkBody body, int channelId) throws AMQException; - public boolean dispatchStreamReturn(StreamReturnBody body, int channelId) throws AMQException; - public boolean dispatchTxCommitOk(TxCommitOkBody body, int channelId) throws AMQException; - public boolean dispatchTxRollbackOk(TxRollbackOkBody body, int channelId) throws AMQException; - public boolean dispatchTxSelectOk(TxSelectOkBody body, int channelId) throws AMQException; -} \ No newline at end of file +} Modified: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/ConnectionCloseBodyImpl.java URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/ConnectionCloseBodyImpl.java?rev=1628074&r1=1628073&r2=1628074&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/ConnectionCloseBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/ConnectionCloseBodyImpl.java Sun Sep 28 15:22:03 2014 @@ -34,7 +34,7 @@ import java.io.IOException; import org.apache.qpid.framing.*; import org.apache.qpid.AMQException; -public class ConnectionCloseBodyImpl extends AMQMethodBody_0_9 implements ConnectionCloseBody +public class ConnectionCloseBodyImpl extends AMQMethodBodyImpl implements ConnectionCloseBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { Modified: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/ConnectionCloseOkBodyImpl.java URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/ConnectionCloseOkBodyImpl.java?rev=1628074&r1=1628073&r2=1628074&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/ConnectionCloseOkBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/ConnectionCloseOkBodyImpl.java Sun Sep 28 15:22:03 2014 @@ -34,7 +34,7 @@ import java.io.IOException; import org.apache.qpid.framing.*; import org.apache.qpid.AMQException; -public class ConnectionCloseOkBodyImpl extends AMQMethodBody_0_9 implements ConnectionCloseOkBody +public class ConnectionCloseOkBodyImpl extends AMQMethodBodyImpl implements ConnectionCloseOkBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { Modified: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/ConnectionRedirectBodyImpl.java URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/ConnectionRedirectBodyImpl.java?rev=1628074&r1=1628073&r2=1628074&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/ConnectionRedirectBodyImpl.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/ConnectionRedirectBodyImpl.java Sun Sep 28 15:22:03 2014 @@ -34,7 +34,7 @@ import java.io.IOException; import org.apache.qpid.framing.*; import org.apache.qpid.AMQException; -public class ConnectionRedirectBodyImpl extends AMQMethodBody_0_9 implements ConnectionRedirectBody +public class ConnectionRedirectBodyImpl extends AMQMethodBodyImpl implements ConnectionRedirectBody { private static final AMQMethodBodyInstanceFactory FACTORY_INSTANCE = new AMQMethodBodyInstanceFactory() { Modified: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/MethodConverter_0_9.java URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/MethodConverter_0_9.java?rev=1628074&r1=1628073&r2=1628074&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/MethodConverter_0_9.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/MethodConverter_0_9.java Sun Sep 28 15:22:03 2014 @@ -24,6 +24,7 @@ package org.apache.qpid.framing.amqp_0_9 import org.apache.qpid.framing.AMQMethodBody; import org.apache.qpid.framing.AMQShortString; import org.apache.qpid.framing.BasicPublishBody; +import org.apache.qpid.framing.BasicPublishBodyImpl; import org.apache.qpid.framing.abstraction.AbstractMethodConverter; import org.apache.qpid.framing.abstraction.MessagePublishInfo; import org.apache.qpid.framing.abstraction.MessagePublishInfoImpl; Modified: qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/MethodRegistry_0_9.java URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/MethodRegistry_0_9.java?rev=1628074&r1=1628073&r2=1628074&view=diff ============================================================================== --- qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/MethodRegistry_0_9.java (original) +++ qpid/branches/QPID-6125-ProtocolRefactoring/java/common/src/main/java/org/apache/qpid/framing/amqp_0_9/MethodRegistry_0_9.java Sun Sep 28 15:22:03 2014 @@ -27,17 +27,15 @@ package org.apache.qpid.framing.amqp_0_9; -import org.apache.qpid.framing.*; -import org.apache.qpid.protocol.AMQConstant; - +import java.io.IOException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import java.io.IOException; - -import org.apache.qpid.framing.abstraction.ProtocolVersionMethodConverter; import org.apache.qpid.codec.MarkableDataInput; +import org.apache.qpid.framing.*; +import org.apache.qpid.framing.abstraction.ProtocolVersionMethodConverter; +import org.apache.qpid.protocol.AMQConstant; public class MethodRegistry_0_9 extends MethodRegistry @@ -47,7 +45,7 @@ public class MethodRegistry_0_9 extends private ProtocolVersionMethodConverter _protocolVersionConverter = new MethodConverter_0_9(); - private final AMQMethodBodyInstanceFactory[][] _factories = new AMQMethodBodyInstanceFactory[121][]; + private final AMQMethodBodyInstanceFactory[][] _factories = new AMQMethodBodyInstanceFactory[91][]; public MethodRegistry_0_9() { @@ -88,10 +86,6 @@ public class MethodRegistry_0_9 extends _factories[20][21] = ChannelFlowOkBodyImpl.getFactory(); _factories[20][40] = ChannelCloseBodyImpl.getFactory(); _factories[20][41] = ChannelCloseOkBodyImpl.getFactory(); - _factories[20][50] = ChannelResumeBodyImpl.getFactory(); - _factories[20][60] = ChannelPingBodyImpl.getFactory(); - _factories[20][70] = ChannelPongBodyImpl.getFactory(); - _factories[20][80] = ChannelOkBodyImpl.getFactory(); @@ -158,43 +152,6 @@ public class MethodRegistry_0_9 extends - // Register method body instance factories for the File class. - - _factories[70] = new AMQMethodBodyInstanceFactory[101]; - - _factories[70][10] = FileQosBodyImpl.getFactory(); - _factories[70][11] = FileQosOkBodyImpl.getFactory(); - _factories[70][20] = FileConsumeBodyImpl.getFactory(); - _factories[70][21] = FileConsumeOkBodyImpl.getFactory(); - _factories[70][30] = FileCancelBodyImpl.getFactory(); - _factories[70][31] = FileCancelOkBodyImpl.getFactory(); - _factories[70][40] = FileOpenBodyImpl.getFactory(); - _factories[70][41] = FileOpenOkBodyImpl.getFactory(); - _factories[70][50] = FileStageBodyImpl.getFactory(); - _factories[70][60] = FilePublishBodyImpl.getFactory(); - _factories[70][70] = FileReturnBodyImpl.getFactory(); - _factories[70][80] = FileDeliverBodyImpl.getFactory(); - _factories[70][90] = FileAckBodyImpl.getFactory(); - _factories[70][100] = FileRejectBodyImpl.getFactory(); - - - - // Register method body instance factories for the Stream class. - - _factories[80] = new AMQMethodBodyInstanceFactory[61]; - - _factories[80][10] = StreamQosBodyImpl.getFactory(); - _factories[80][11] = StreamQosOkBodyImpl.getFactory(); - _factories[80][20] = StreamConsumeBodyImpl.getFactory(); - _factories[80][21] = StreamConsumeOkBodyImpl.getFactory(); - _factories[80][30] = StreamCancelBodyImpl.getFactory(); - _factories[80][31] = StreamCancelOkBodyImpl.getFactory(); - _factories[80][40] = StreamPublishBodyImpl.getFactory(); - _factories[80][50] = StreamReturnBodyImpl.getFactory(); - _factories[80][60] = StreamDeliverBodyImpl.getFactory(); - - - // Register method body instance factories for the Tx class. _factories[90] = new AMQMethodBodyInstanceFactory[32]; @@ -206,46 +163,6 @@ public class MethodRegistry_0_9 extends _factories[90][30] = TxRollbackBodyImpl.getFactory(); _factories[90][31] = TxRollbackOkBodyImpl.getFactory(); - - - // Register method body instance factories for the Dtx class. - - _factories[100] = new AMQMethodBodyInstanceFactory[22]; - - _factories[100][10] = DtxSelectBodyImpl.getFactory(); - _factories[100][11] = DtxSelectOkBodyImpl.getFactory(); - _factories[100][20] = DtxStartBodyImpl.getFactory(); - _factories[100][21] = DtxStartOkBodyImpl.getFactory(); - - - - // Register method body instance factories for the Tunnel class. - - _factories[110] = new AMQMethodBodyInstanceFactory[11]; - - _factories[110][10] = TunnelRequestBodyImpl.getFactory(); - - - - // Register method body instance factories for the Message class. - - _factories[120] = new AMQMethodBodyInstanceFactory[531]; - - _factories[120][10] = MessageTransferBodyImpl.getFactory(); - _factories[120][20] = MessageConsumeBodyImpl.getFactory(); - _factories[120][30] = MessageCancelBodyImpl.getFactory(); - _factories[120][40] = MessageGetBodyImpl.getFactory(); - _factories[120][50] = MessageRecoverBodyImpl.getFactory(); - _factories[120][60] = MessageOpenBodyImpl.getFactory(); - _factories[120][70] = MessageCloseBodyImpl.getFactory(); - _factories[120][80] = MessageAppendBodyImpl.getFactory(); - _factories[120][90] = MessageCheckpointBodyImpl.getFactory(); - _factories[120][100] = MessageResumeBodyImpl.getFactory(); - _factories[120][110] = MessageQosBodyImpl.getFactory(); - _factories[120][500] = MessageOkBodyImpl.getFactory(); - _factories[120][510] = MessageEmptyBodyImpl.getFactory(); - _factories[120][520] = MessageRejectBodyImpl.getFactory(); - _factories[120][530] = MessageOffsetBodyImpl.getFactory(); } public AMQMethodBody convertToBody(MarkableDataInput in, long size) @@ -497,38 +414,6 @@ public class MethodRegistry_0_9 extends ); } - public ChannelResumeBody createChannelResumeBody( - final byte[] channelId - ) - { - return new ChannelResumeBodyImpl( - channelId - ); - } - - public ChannelPingBody createChannelPingBody( - ) - { - return new ChannelPingBodyImpl( - ); - } - - public ChannelPongBody createChannelPongBody( - ) - { - return new ChannelPongBodyImpl( - ); - } - - public ChannelOkBody createChannelOkBody( - ) - { - return new ChannelOkBodyImpl( - ); - } - - - public AccessRequestBody createAccessRequestBody( final AMQShortString realm, @@ -986,308 +871,6 @@ public class MethodRegistry_0_9 extends ); } - - - - public FileQosBody createFileQosBody( - final long prefetchSize, - final int prefetchCount, - final boolean global - ) - { - return new FileQosBodyImpl( - prefetchSize, - prefetchCount, - global - ); - } - - public FileQosOkBody createFileQosOkBody( - ) - { - return new FileQosOkBodyImpl( - ); - } - - public FileConsumeBody createFileConsumeBody( - final int ticket, - final AMQShortString queue, - final AMQShortString consumerTag, - final boolean noLocal, - final boolean noAck, - final boolean exclusive, - final boolean nowait, - final FieldTable filter - ) - { - return new FileConsumeBodyImpl( - ticket, - queue, - consumerTag, - noLocal, - noAck, - exclusive, - nowait, - filter - ); - } - - public FileConsumeOkBody createFileConsumeOkBody( - final AMQShortString consumerTag - ) - { - return new FileConsumeOkBodyImpl( - consumerTag - ); - } - - public FileCancelBody createFileCancelBody( - final AMQShortString consumerTag, - final boolean nowait - ) - { - return new FileCancelBodyImpl( - consumerTag, - nowait - ); - } - - public FileCancelOkBody createFileCancelOkBody( - final AMQShortString consumerTag - ) - { - return new FileCancelOkBodyImpl( - consumerTag - ); - } - - public FileOpenBody createFileOpenBody( - final AMQShortString identifier, - final long contentSize - ) - { - return new FileOpenBodyImpl( - identifier, - contentSize - ); - } - - public FileOpenOkBody createFileOpenOkBody( - final long stagedSize - ) - { - return new FileOpenOkBodyImpl( - stagedSize - ); - } - - public FileStageBody createFileStageBody( - ) - { - return new FileStageBodyImpl( - ); - } - - public FilePublishBody createFilePublishBody( - final int ticket, - final AMQShortString exchange, - final AMQShortString routingKey, - final boolean mandatory, - final boolean immediate, - final AMQShortString identifier - ) - { - return new FilePublishBodyImpl( - ticket, - exchange, - routingKey, - mandatory, - immediate, - identifier - ); - } - - public FileReturnBody createFileReturnBody( - final int replyCode, - final AMQShortString replyText, - final AMQShortString exchange, - final AMQShortString routingKey - ) - { - return new FileReturnBodyImpl( - replyCode, - replyText, - exchange, - routingKey - ); - } - - public FileDeliverBody createFileDeliverBody( - final AMQShortString consumerTag, - final long deliveryTag, - final boolean redelivered, - final AMQShortString exchange, - final AMQShortString routingKey, - final AMQShortString identifier - ) - { - return new FileDeliverBodyImpl( - consumerTag, - deliveryTag, - redelivered, - exchange, - routingKey, - identifier - ); - } - - public FileAckBody createFileAckBody( - final long deliveryTag, - final boolean multiple - ) - { - return new FileAckBodyImpl( - deliveryTag, - multiple - ); - } - - public FileRejectBody createFileRejectBody( - final long deliveryTag, - final boolean requeue - ) - { - return new FileRejectBodyImpl( - deliveryTag, - requeue - ); - } - - - - - public StreamQosBody createStreamQosBody( - final long prefetchSize, - final int prefetchCount, - final long consumeRate, - final boolean global - ) - { - return new StreamQosBodyImpl( - prefetchSize, - prefetchCount, - consumeRate, - global - ); - } - - public StreamQosOkBody createStreamQosOkBody( - ) - { - return new StreamQosOkBodyImpl( - ); - } - - public StreamConsumeBody createStreamConsumeBody( - final int ticket, - final AMQShortString queue, - final AMQShortString consumerTag, - final boolean noLocal, - final boolean exclusive, - final boolean nowait, - final FieldTable filter - ) - { - return new StreamConsumeBodyImpl( - ticket, - queue, - consumerTag, - noLocal, - exclusive, - nowait, - filter - ); - } - - public StreamConsumeOkBody createStreamConsumeOkBody( - final AMQShortString consumerTag - ) - { - return new StreamConsumeOkBodyImpl( - consumerTag - ); - } - - public StreamCancelBody createStreamCancelBody( - final AMQShortString consumerTag, - final boolean nowait - ) - { - return new StreamCancelBodyImpl( - consumerTag, - nowait - ); - } - - public StreamCancelOkBody createStreamCancelOkBody( - final AMQShortString consumerTag - ) - { - return new StreamCancelOkBodyImpl( - consumerTag - ); - } - - public StreamPublishBody createStreamPublishBody( - final int ticket, - final AMQShortString exchange, - final AMQShortString routingKey, - final boolean mandatory, - final boolean immediate - ) - { - return new StreamPublishBodyImpl( - ticket, - exchange, - routingKey, - mandatory, - immediate - ); - } - - public StreamReturnBody createStreamReturnBody( - final int replyCode, - final AMQShortString replyText, - final AMQShortString exchange, - final AMQShortString routingKey - ) - { - return new StreamReturnBodyImpl( - replyCode, - replyText, - exchange, - routingKey - ); - } - - public StreamDeliverBody createStreamDeliverBody( - final AMQShortString consumerTag, - final long deliveryTag, - final AMQShortString exchange, - final AMQShortString queue - ) - { - return new StreamDeliverBodyImpl( - consumerTag, - deliveryTag, - exchange, - queue - ); - } - - - - public TxSelectBody createTxSelectBody( ) { @@ -1330,259 +913,6 @@ public class MethodRegistry_0_9 extends ); } - - - - public DtxSelectBody createDtxSelectBody( - ) - { - return new DtxSelectBodyImpl( - ); - } - - public DtxSelectOkBody createDtxSelectOkBody( - ) - { - return new DtxSelectOkBodyImpl( - ); - } - - public DtxStartBody createDtxStartBody( - final AMQShortString dtxIdentifier - ) - { - return new DtxStartBodyImpl( - dtxIdentifier - ); - } - - public DtxStartOkBody createDtxStartOkBody( - ) - { - return new DtxStartOkBodyImpl( - ); - } - - - - - public TunnelRequestBody createTunnelRequestBody( - final FieldTable metaData - ) - { - return new TunnelRequestBodyImpl( - metaData - ); - } - - - - - public MessageTransferBody createMessageTransferBody( - final int ticket, - final AMQShortString destination, - final boolean redelivered, - final boolean immediate, - final long ttl, - final short priority, - final long timestamp, - final short deliveryMode, - final long expiration, - final AMQShortString exchange, - final AMQShortString routingKey, - final AMQShortString messageId, - final AMQShortString correlationId, - final AMQShortString replyTo, - final AMQShortString contentType, - final AMQShortString contentEncoding, - final AMQShortString userId, - final AMQShortString appId, - final AMQShortString transactionId, - final byte[] securityToken, - final FieldTable applicationHeaders, - final Content body - ) - { - return new MessageTransferBodyImpl( - ticket, - destination, - redelivered, - immediate, - ttl, - priority, - timestamp, - deliveryMode, - expiration, - exchange, - routingKey, - messageId, - correlationId, - replyTo, - contentType, - contentEncoding, - userId, - appId, - transactionId, - securityToken, - applicationHeaders, - body - ); - } - - public MessageConsumeBody createMessageConsumeBody( - final int ticket, - final AMQShortString queue, - final AMQShortString destination, - final boolean noLocal, - final boolean noAck, - final boolean exclusive, - final FieldTable filter - ) - { - return new MessageConsumeBodyImpl( - ticket, - queue, - destination, - noLocal, - noAck, - exclusive, - filter - ); - } - - public MessageCancelBody createMessageCancelBody( - final AMQShortString destination - ) - { - return new MessageCancelBodyImpl( - destination - ); - } - - public MessageGetBody createMessageGetBody( - final int ticket, - final AMQShortString queue, - final AMQShortString destination, - final boolean noAck - ) - { - return new MessageGetBodyImpl( - ticket, - queue, - destination, - noAck - ); - } - - public MessageRecoverBody createMessageRecoverBody( - final boolean requeue - ) - { - return new MessageRecoverBodyImpl( - requeue - ); - } - - public MessageOpenBody createMessageOpenBody( - final byte[] reference - ) - { - return new MessageOpenBodyImpl( - reference - ); - } - - public MessageCloseBody createMessageCloseBody( - final byte[] reference - ) - { - return new MessageCloseBodyImpl( - reference - ); - } - - public MessageAppendBody createMessageAppendBody( - final byte[] reference, - final byte[] bytes - ) - { - return new MessageAppendBodyImpl( - reference, - bytes - ); - } - - public MessageCheckpointBody createMessageCheckpointBody( - final byte[] reference, - final AMQShortString identifier - ) - { - return new MessageCheckpointBodyImpl( - reference, - identifier - ); - } - - public MessageResumeBody createMessageResumeBody( - final byte[] reference, - final AMQShortString identifier - ) - { - return new MessageResumeBodyImpl( - reference, - identifier - ); - } - - public MessageQosBody createMessageQosBody( - final long prefetchSize, - final int prefetchCount, - final boolean global - ) - { - return new MessageQosBodyImpl( - prefetchSize, - prefetchCount, - global - ); - } - - public MessageOkBody createMessageOkBody( - ) - { - return new MessageOkBodyImpl( - ); - } - - public MessageEmptyBody createMessageEmptyBody( - ) - { - return new MessageEmptyBodyImpl( - ); - } - - public MessageRejectBody createMessageRejectBody( - final int code, - final AMQShortString text - ) - { - return new MessageRejectBodyImpl( - code, - text - ); - } - - public MessageOffsetBody createMessageOffsetBody( - final long value - ) - { - return new MessageOffsetBodyImpl( - value - ); - } - - - public ProtocolVersionMethodConverter getProtocolVersionMethodConverter() { return _protocolVersionConverter; --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
