Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpRelinkMarshaller.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpRelinkMarshaller.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpRelinkMarshaller.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpRelinkMarshaller.java Wed Jul 7 03:50:42 2010 @@ -31,7 +31,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.types.AmqpType; import org.apache.activemq.amqp.protocol.types.AmqpUlong; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; //!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!// //!!!!!!!!THIS CLASS IS AUTOGENERATED DO NOT MODIFY DIRECTLY!!!!!!!!!!!!// Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpSaslChallengeMarshaller.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpSaslChallengeMarshaller.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpSaslChallengeMarshaller.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpSaslChallengeMarshaller.java Wed Jul 7 03:50:42 2010 @@ -30,7 +30,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.types.AmqpType; import org.apache.activemq.amqp.protocol.types.AmqpUlong; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; //!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!// //!!!!!!!!THIS CLASS IS AUTOGENERATED DO NOT MODIFY DIRECTLY!!!!!!!!!!!!// Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpSaslInitMarshaller.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpSaslInitMarshaller.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpSaslInitMarshaller.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpSaslInitMarshaller.java Wed Jul 7 03:50:42 2010 @@ -31,7 +31,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.types.AmqpType; import org.apache.activemq.amqp.protocol.types.AmqpUlong; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; //!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!// //!!!!!!!!THIS CLASS IS AUTOGENERATED DO NOT MODIFY DIRECTLY!!!!!!!!!!!!// Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpSaslMechanismsMarshaller.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpSaslMechanismsMarshaller.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpSaslMechanismsMarshaller.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpSaslMechanismsMarshaller.java Wed Jul 7 03:50:42 2010 @@ -30,7 +30,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.types.AmqpType; import org.apache.activemq.amqp.protocol.types.AmqpUlong; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; //!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!// //!!!!!!!!THIS CLASS IS AUTOGENERATED DO NOT MODIFY DIRECTLY!!!!!!!!!!!!// Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpSaslOutcomeMarshaller.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpSaslOutcomeMarshaller.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpSaslOutcomeMarshaller.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpSaslOutcomeMarshaller.java Wed Jul 7 03:50:42 2010 @@ -31,7 +31,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.types.AmqpUbyte; import org.apache.activemq.amqp.protocol.types.AmqpUlong; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; //!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!// //!!!!!!!!THIS CLASS IS AUTOGENERATED DO NOT MODIFY DIRECTLY!!!!!!!!!!!!// Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpSaslResponseMarshaller.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpSaslResponseMarshaller.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpSaslResponseMarshaller.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpSaslResponseMarshaller.java Wed Jul 7 03:50:42 2010 @@ -30,7 +30,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.types.AmqpType; import org.apache.activemq.amqp.protocol.types.AmqpUlong; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; //!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!// //!!!!!!!!THIS CLASS IS AUTOGENERATED DO NOT MODIFY DIRECTLY!!!!!!!!!!!!// Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpSessionErrorMarshaller.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpSessionErrorMarshaller.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpSessionErrorMarshaller.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpSessionErrorMarshaller.java Wed Jul 7 03:50:42 2010 @@ -33,7 +33,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.types.AmqpUlong; import org.apache.activemq.amqp.protocol.types.AmqpUshort; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; //!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!// //!!!!!!!!THIS CLASS IS AUTOGENERATED DO NOT MODIFY DIRECTLY!!!!!!!!!!!!// Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpShortMarshaller.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpShortMarshaller.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpShortMarshaller.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpShortMarshaller.java Wed Jul 7 03:50:42 2010 @@ -25,7 +25,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.v1_0_0.Encoder; import org.apache.activemq.amqp.protocol.marshaller.v1_0_0.Encoder.*; import org.apache.activemq.amqp.protocol.types.AmqpShort; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; //!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!// //!!!!!!!!THIS CLASS IS AUTOGENERATED DO NOT MODIFY DIRECTLY!!!!!!!!!!!!// Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpSourceMarshaller.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpSourceMarshaller.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpSourceMarshaller.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpSourceMarshaller.java Wed Jul 7 03:50:42 2010 @@ -35,7 +35,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.types.AmqpUint; import org.apache.activemq.amqp.protocol.types.AmqpUlong; import org.apache.activemq.amqp.protocol.types.IAmqpMap; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; //!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!// //!!!!!!!!THIS CLASS IS AUTOGENERATED DO NOT MODIFY DIRECTLY!!!!!!!!!!!!// Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpStringMarshaller.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpStringMarshaller.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpStringMarshaller.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpStringMarshaller.java Wed Jul 7 03:50:42 2010 @@ -28,7 +28,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.v1_0_0.Encoder; import org.apache.activemq.amqp.protocol.marshaller.v1_0_0.Encoder.*; import org.apache.activemq.amqp.protocol.types.AmqpString; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; //!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!// //!!!!!!!!THIS CLASS IS AUTOGENERATED DO NOT MODIFY DIRECTLY!!!!!!!!!!!!// Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpSymbolMarshaller.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpSymbolMarshaller.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpSymbolMarshaller.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpSymbolMarshaller.java Wed Jul 7 03:50:42 2010 @@ -28,7 +28,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.v1_0_0.Encoder; import org.apache.activemq.amqp.protocol.marshaller.v1_0_0.Encoder.*; import org.apache.activemq.amqp.protocol.types.AmqpSymbol; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; //!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!// //!!!!!!!!THIS CLASS IS AUTOGENERATED DO NOT MODIFY DIRECTLY!!!!!!!!!!!!// Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpTargetMarshaller.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpTargetMarshaller.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpTargetMarshaller.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpTargetMarshaller.java Wed Jul 7 03:50:42 2010 @@ -32,7 +32,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.types.AmqpUint; import org.apache.activemq.amqp.protocol.types.AmqpUlong; import org.apache.activemq.amqp.protocol.types.IAmqpMap; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; //!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!// //!!!!!!!!THIS CLASS IS AUTOGENERATED DO NOT MODIFY DIRECTLY!!!!!!!!!!!!// Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpTimestampMarshaller.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpTimestampMarshaller.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpTimestampMarshaller.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpTimestampMarshaller.java Wed Jul 7 03:50:42 2010 @@ -25,7 +25,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.v1_0_0.Encoder; import org.apache.activemq.amqp.protocol.marshaller.v1_0_0.Encoder.*; import org.apache.activemq.amqp.protocol.types.AmqpTimestamp; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; //!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!// //!!!!!!!!THIS CLASS IS AUTOGENERATED DO NOT MODIFY DIRECTLY!!!!!!!!!!!!// Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpTransferMarshaller.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpTransferMarshaller.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpTransferMarshaller.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpTransferMarshaller.java Wed Jul 7 03:50:42 2010 @@ -33,7 +33,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.types.AmqpType; import org.apache.activemq.amqp.protocol.types.AmqpUlong; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; //!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!// //!!!!!!!!THIS CLASS IS AUTOGENERATED DO NOT MODIFY DIRECTLY!!!!!!!!!!!!// Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpTxnMarshaller.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpTxnMarshaller.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpTxnMarshaller.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpTxnMarshaller.java Wed Jul 7 03:50:42 2010 @@ -30,7 +30,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.types.AmqpType; import org.apache.activemq.amqp.protocol.types.AmqpUlong; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; //!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!// //!!!!!!!!THIS CLASS IS AUTOGENERATED DO NOT MODIFY DIRECTLY!!!!!!!!!!!!// Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpUbyteMarshaller.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpUbyteMarshaller.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpUbyteMarshaller.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpUbyteMarshaller.java Wed Jul 7 03:50:42 2010 @@ -25,7 +25,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.v1_0_0.Encoder; import org.apache.activemq.amqp.protocol.marshaller.v1_0_0.Encoder.*; import org.apache.activemq.amqp.protocol.types.AmqpUbyte; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; //!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!// //!!!!!!!!THIS CLASS IS AUTOGENERATED DO NOT MODIFY DIRECTLY!!!!!!!!!!!!// Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpUintMarshaller.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpUintMarshaller.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpUintMarshaller.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpUintMarshaller.java Wed Jul 7 03:50:42 2010 @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.activemq.amqp.protocol.marshaller.v1_0_0; +package org.apache.activemq.amqp.protocol.marshaller.v1_0_0; import java.io.DataInput; import java.io.DataOutput; @@ -25,7 +25,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.v1_0_0.Encoder; import org.apache.activemq.amqp.protocol.marshaller.v1_0_0.Encoder.*; import org.apache.activemq.amqp.protocol.types.AmqpUint; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.buffer.Buffer; //!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!// //!!!!!!!!THIS CLASS IS AUTOGENERATED DO NOT MODIFY DIRECTLY!!!!!!!!!!!!// Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpUlongMarshaller.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpUlongMarshaller.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpUlongMarshaller.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpUlongMarshaller.java Wed Jul 7 03:50:42 2010 @@ -25,7 +25,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.v1_0_0.Encoder; import org.apache.activemq.amqp.protocol.marshaller.v1_0_0.Encoder.*; import org.apache.activemq.amqp.protocol.types.AmqpUlong; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; //!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!// //!!!!!!!!THIS CLASS IS AUTOGENERATED DO NOT MODIFY DIRECTLY!!!!!!!!!!!!// Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpUnlinkMarshaller.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpUnlinkMarshaller.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpUnlinkMarshaller.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpUnlinkMarshaller.java Wed Jul 7 03:50:42 2010 @@ -31,7 +31,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.types.AmqpUlong; import org.apache.activemq.amqp.protocol.types.AmqpUnlink; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; //!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!// //!!!!!!!!THIS CLASS IS AUTOGENERATED DO NOT MODIFY DIRECTLY!!!!!!!!!!!!// Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpUshortMarshaller.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpUshortMarshaller.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpUshortMarshaller.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpUshortMarshaller.java Wed Jul 7 03:50:42 2010 @@ -25,7 +25,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.v1_0_0.Encoder; import org.apache.activemq.amqp.protocol.marshaller.v1_0_0.Encoder.*; import org.apache.activemq.amqp.protocol.types.AmqpUshort; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; //!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!// //!!!!!!!!THIS CLASS IS AUTOGENERATED DO NOT MODIFY DIRECTLY!!!!!!!!!!!!// Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpUuidMarshaller.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpUuidMarshaller.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpUuidMarshaller.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpUuidMarshaller.java Wed Jul 7 03:50:42 2010 @@ -25,7 +25,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.v1_0_0.Encoder; import org.apache.activemq.amqp.protocol.marshaller.v1_0_0.Encoder.*; import org.apache.activemq.amqp.protocol.types.AmqpUuid; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; //!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!// //!!!!!!!!THIS CLASS IS AUTOGENERATED DO NOT MODIFY DIRECTLY!!!!!!!!!!!!// Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpXidMarshaller.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpXidMarshaller.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpXidMarshaller.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/AmqpXidMarshaller.java Wed Jul 7 03:50:42 2010 @@ -30,7 +30,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.types.AmqpUlong; import org.apache.activemq.amqp.protocol.types.AmqpXid; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; //!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!// //!!!!!!!!THIS CLASS IS AUTOGENERATED DO NOT MODIFY DIRECTLY!!!!!!!!!!!!// Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/BaseEncoder.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/BaseEncoder.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/BaseEncoder.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/BaseEncoder.java Wed Jul 7 03:50:42 2010 @@ -28,7 +28,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.v1_0_0.AmqpSymbolMarshaller.SYMBOL_ENCODING; import org.apache.activemq.amqp.protocol.BitUtils; import org.apache.activemq.amqp.protocol.marshaller.AmqpEncodingError; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; //!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!// //!!!!!!!!THIS CLASS IS AUTOGENERATED DO NOT MODIFY DIRECTLY!!!!!!!!!!!!// Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/Encoder.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/Encoder.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/Encoder.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/Encoder.java Wed Jul 7 03:50:42 2010 @@ -35,7 +35,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.types.AmqpType; import org.apache.activemq.amqp.protocol.types.IAmqpList; import org.apache.activemq.amqp.protocol.types.IAmqpMap; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.buffer.Buffer; //!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!// //!!!!!!!!THIS CLASS IS AUTOGENERATED DO NOT MODIFY DIRECTLY!!!!!!!!!!!!// Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/PrimitiveEncoder.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/PrimitiveEncoder.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/PrimitiveEncoder.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/PrimitiveEncoder.java Wed Jul 7 03:50:42 2010 @@ -23,7 +23,7 @@ import java.math.BigInteger; import java.util.Date; import java.util.UUID; import org.apache.activemq.amqp.protocol.marshaller.AmqpEncodingError; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; //!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!// Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpAddress.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpAddress.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpAddress.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpAddress.java Wed Jul 7 03:50:42 2010 @@ -24,7 +24,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.Encoded; import org.apache.activemq.amqp.protocol.types.AmqpAddress; import org.apache.activemq.amqp.protocol.types.AmqpBinary; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a name of the source or target for a Message @@ -163,4 +163,4 @@ public interface AmqpAddress extends Amq return create(marshaller.decodeAmqpBinary(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpAttach.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpAttach.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpAttach.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpAttach.java Wed Jul 7 03:50:42 2010 @@ -28,7 +28,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a attach to the named Session @@ -704,4 +704,4 @@ public interface AmqpAttach extends Amqp return create(marshaller.decodeAmqpAttach(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpBar.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpBar.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpBar.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpBar.java Wed Jul 7 03:50:42 2010 @@ -26,7 +26,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a establish a barrier for Message acknowledgments on a Link @@ -420,4 +420,4 @@ public interface AmqpBar extends AmqpLis return create(marshaller.decodeAmqpBar(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpBinary.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpBinary.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpBinary.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpBinary.java Wed Jul 7 03:50:42 2010 @@ -22,7 +22,7 @@ import java.io.IOException; import org.apache.activemq.amqp.protocol.marshaller.AmqpEncodingError; import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a a sequence of octets @@ -166,4 +166,4 @@ public interface AmqpBinary extends Amqp return create(marshaller.decodeAmqpBinary(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpBoolean.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpBoolean.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpBoolean.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpBoolean.java Wed Jul 7 03:50:42 2010 @@ -14,7 +14,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.activemq.amqp.protocol.types; +package org.apache.activemq.amqp.protocol.types; import java.io.DataInput; import java.io.DataOutput; @@ -23,7 +23,7 @@ import java.lang.Boolean; import org.apache.activemq.amqp.protocol.marshaller.AmqpEncodingError; import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.buffer.Buffer; /** * Represents a represents a true or false value Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpByte.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpByte.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpByte.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpByte.java Wed Jul 7 03:50:42 2010 @@ -23,7 +23,7 @@ import java.lang.Byte; import org.apache.activemq.amqp.protocol.marshaller.AmqpEncodingError; import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a integer in the range -(2^7) to 2^7 - 1 @@ -167,4 +167,4 @@ public interface AmqpByte extends AmqpTy return create(marshaller.decodeAmqpByte(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpChar.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpChar.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpChar.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpChar.java Wed Jul 7 03:50:42 2010 @@ -23,7 +23,7 @@ import java.lang.Integer; import org.apache.activemq.amqp.protocol.marshaller.AmqpEncodingError; import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a a single unicode character @@ -167,4 +167,4 @@ public interface AmqpChar extends AmqpTy return create(marshaller.decodeAmqpChar(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpClose.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpClose.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpClose.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpClose.java Wed Jul 7 03:50:42 2010 @@ -26,7 +26,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a signal a Connection close @@ -305,4 +305,4 @@ public interface AmqpClose extends AmqpL return create(marshaller.decodeAmqpClose(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpCompleted.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpCompleted.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpCompleted.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpCompleted.java Wed Jul 7 03:50:42 2010 @@ -27,7 +27,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; import org.apache.activemq.amqp.protocol.types.IAmqpMap; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a the completed disposition @@ -278,4 +278,4 @@ public interface AmqpCompleted extends A return create(marshaller.decodeAmqpCompleted(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpConnectionError.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpConnectionError.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpConnectionError.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpConnectionError.java Wed Jul 7 03:50:42 2010 @@ -25,7 +25,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a details of a Connection error @@ -360,4 +360,4 @@ public interface AmqpConnectionError ext return create(marshaller.decodeAmqpConnectionError(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpDeliveryTag.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpDeliveryTag.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpDeliveryTag.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpDeliveryTag.java Wed Jul 7 03:50:42 2010 @@ -24,7 +24,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.Encoded; import org.apache.activemq.amqp.protocol.types.AmqpBinary; import org.apache.activemq.amqp.protocol.types.AmqpDeliveryTag; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; //!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!// //!!!!!!!!THIS CLASS IS AUTOGENERATED DO NOT MODIFY DIRECTLY!!!!!!!!!!!!// @@ -155,4 +155,4 @@ public interface AmqpDeliveryTag extends return create(marshaller.decodeAmqpBinary(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpDetach.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpDetach.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpDetach.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpDetach.java Wed Jul 7 03:50:42 2010 @@ -27,7 +27,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a detach from the named Session @@ -464,4 +464,4 @@ public interface AmqpDetach extends Amqp return create(marshaller.decodeAmqpDetach(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpDisposition.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpDisposition.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpDisposition.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpDisposition.java Wed Jul 7 03:50:42 2010 @@ -26,7 +26,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a alter disposition of transfers on a Link @@ -491,4 +491,4 @@ public interface AmqpDisposition extends return create(marshaller.decodeAmqpDisposition(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpDouble.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpDouble.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpDouble.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpDouble.java Wed Jul 7 03:50:42 2010 @@ -23,7 +23,7 @@ import java.lang.Double; import org.apache.activemq.amqp.protocol.marshaller.AmqpEncodingError; import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a 64-bit floating point number (IEEE 754-2008 binary64) @@ -167,4 +167,4 @@ public interface AmqpDouble extends Amqp return create(marshaller.decodeAmqpDouble(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpDrain.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpDrain.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpDrain.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpDrain.java Wed Jul 7 03:50:42 2010 @@ -26,7 +26,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a drain the Link of immediately available transfers and stop it @@ -364,4 +364,4 @@ public interface AmqpDrain extends AmqpL return create(marshaller.decodeAmqpDrain(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpEnlist.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpEnlist.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpEnlist.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpEnlist.java Wed Jul 7 03:50:42 2010 @@ -27,7 +27,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a associate the current transactional work with a distributed transaction @@ -481,4 +481,4 @@ public interface AmqpEnlist extends Amqp return create(marshaller.decodeAmqpEnlist(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFilter.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFilter.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFilter.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFilter.java Wed Jul 7 03:50:42 2010 @@ -25,7 +25,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a the predicate to filter the Messages admitted onto the Link @@ -312,4 +312,4 @@ public interface AmqpFilter extends Amqp return create(marshaller.decodeAmqpFilter(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFilterSet.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFilterSet.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFilterSet.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFilterSet.java Wed Jul 7 03:50:42 2010 @@ -28,7 +28,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.types.AmqpFilterSet; import org.apache.activemq.amqp.protocol.types.AmqpMap; import org.apache.activemq.amqp.protocol.types.IAmqpMap; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** *

@@ -195,4 +195,4 @@ public interface AmqpFilterSet extends A return create(marshaller.decodeAmqpMap(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFloat.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFloat.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFloat.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFloat.java Wed Jul 7 03:50:42 2010 @@ -23,7 +23,7 @@ import java.lang.Float; import org.apache.activemq.amqp.protocol.marshaller.AmqpEncodingError; import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a 32-bit floating point number (IEEE 754-2008 binary32) @@ -167,4 +167,4 @@ public interface AmqpFloat extends AmqpT return create(marshaller.decodeAmqpFloat(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFlow.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFlow.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFlow.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFlow.java Wed Jul 7 03:50:42 2010 @@ -26,7 +26,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a update the transfer-limit for a Link @@ -471,4 +471,4 @@ public interface AmqpFlow extends AmqpLi return create(marshaller.decodeAmqpFlow(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFooter.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFooter.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFooter.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFooter.java Wed Jul 7 03:50:42 2010 @@ -24,7 +24,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a transport footers for a Message @@ -298,4 +298,4 @@ public interface AmqpFooter extends Amqp return create(marshaller.decodeAmqpFooter(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFragment.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFragment.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFragment.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFragment.java Wed Jul 7 03:50:42 2010 @@ -27,7 +27,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a a Message fragment @@ -583,4 +583,4 @@ public interface AmqpFragment extends Am return create(marshaller.decodeAmqpFragment(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpHandle.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpHandle.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpHandle.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpHandle.java Wed Jul 7 03:50:42 2010 @@ -25,7 +25,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.Encoded; import org.apache.activemq.amqp.protocol.types.AmqpHandle; import org.apache.activemq.amqp.protocol.types.AmqpUint; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a the handle of a Link @@ -165,4 +165,4 @@ public interface AmqpHandle extends Amqp return create(marshaller.decodeAmqpUint(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpHeader.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpHeader.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpHeader.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpHeader.java Wed Jul 7 03:50:42 2010 @@ -29,7 +29,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a transport headers for a Message @@ -1079,4 +1079,4 @@ public interface AmqpHeader extends Amqp return create(marshaller.decodeAmqpHeader(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpInt.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpInt.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpInt.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpInt.java Wed Jul 7 03:50:42 2010 @@ -23,7 +23,7 @@ import java.lang.Integer; import org.apache.activemq.amqp.protocol.marshaller.AmqpEncodingError; import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a integer in the range -(2^31) to 2^31 - 1 @@ -167,4 +167,4 @@ public interface AmqpInt extends AmqpTyp return create(marshaller.decodeAmqpInt(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpLink.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpLink.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpLink.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpLink.java Wed Jul 7 03:50:42 2010 @@ -28,7 +28,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a carries the local state and desired remote state of a Link @@ -900,4 +900,4 @@ public interface AmqpLink extends AmqpLi return create(marshaller.decodeAmqpLink(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpLinkError.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpLinkError.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpLinkError.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpLinkError.java Wed Jul 7 03:50:42 2010 @@ -25,7 +25,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a details of a Link error @@ -363,4 +363,4 @@ public interface AmqpLinkError extends A return create(marshaller.decodeAmqpLinkError(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpList.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpList.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpList.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpList.java Wed Jul 7 03:50:42 2010 @@ -25,7 +25,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a a sequence of polymorphic values @@ -205,4 +205,4 @@ public interface AmqpList extends AmqpTy return create(marshaller.decodeAmqpList(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpLong.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpLong.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpLong.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpLong.java Wed Jul 7 03:50:42 2010 @@ -23,7 +23,7 @@ import java.lang.Long; import org.apache.activemq.amqp.protocol.marshaller.AmqpEncodingError; import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a integer in the range -(2^63) to 2^63 - 1 @@ -167,4 +167,4 @@ public interface AmqpLong extends AmqpTy return create(marshaller.decodeAmqpLong(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpMap.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpMap.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpMap.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpMap.java Wed Jul 7 03:50:42 2010 @@ -26,7 +26,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; import org.apache.activemq.amqp.protocol.types.IAmqpMap; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a a polymorphic mapping from distinct keys to values @@ -203,4 +203,4 @@ public interface AmqpMap extends AmqpTyp return create(marshaller.decodeAmqpMap(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpMessageAttributes.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpMessageAttributes.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpMessageAttributes.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpMessageAttributes.java Wed Jul 7 03:50:42 2010 @@ -28,7 +28,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.types.AmqpMap; import org.apache.activemq.amqp.protocol.types.AmqpMessageAttributes; import org.apache.activemq.amqp.protocol.types.IAmqpMap; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** *

@@ -197,4 +197,4 @@ public interface AmqpMessageAttributes e return create(marshaller.decodeAmqpMap(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpNoop.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpNoop.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpNoop.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpNoop.java Wed Jul 7 03:50:42 2010 @@ -26,7 +26,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a a command that does nothing @@ -253,4 +253,4 @@ public interface AmqpNoop extends AmqpLi return create(marshaller.decodeAmqpNoop(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpNull.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpNull.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpNull.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpNull.java Wed Jul 7 03:50:42 2010 @@ -23,7 +23,7 @@ import java.lang.Object; import org.apache.activemq.amqp.protocol.marshaller.AmqpEncodingError; import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a indicates an empty value @@ -167,4 +167,4 @@ public interface AmqpNull extends AmqpTy return create(marshaller.decodeAmqpNull(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpOpen.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpOpen.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpOpen.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpOpen.java Wed Jul 7 03:50:42 2010 @@ -29,7 +29,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a negotiate Connection parameters @@ -966,4 +966,4 @@ public interface AmqpOpen extends AmqpLi return create(marshaller.decodeAmqpOpen(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpOptions.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpOptions.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpOptions.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpOptions.java Wed Jul 7 03:50:42 2010 @@ -28,7 +28,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.types.AmqpMap; import org.apache.activemq.amqp.protocol.types.AmqpOptions; import org.apache.activemq.amqp.protocol.types.IAmqpMap; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a options map @@ -196,4 +196,4 @@ public interface AmqpOptions extends Amq return create(marshaller.decodeAmqpMap(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpProperties.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpProperties.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpProperties.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpProperties.java Wed Jul 7 03:50:42 2010 @@ -26,7 +26,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a immutable properties of the Message @@ -703,4 +703,4 @@ public interface AmqpProperties extends return create(marshaller.decodeAmqpProperties(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpRejected.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpRejected.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpRejected.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpRejected.java Wed Jul 7 03:50:42 2010 @@ -27,7 +27,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; import org.apache.activemq.amqp.protocol.types.IAmqpMap; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a the rejected disposition @@ -325,4 +325,4 @@ public interface AmqpRejected extends Am return create(marshaller.decodeAmqpRejected(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpReleased.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpReleased.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpReleased.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpReleased.java Wed Jul 7 03:50:42 2010 @@ -27,7 +27,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; import org.apache.activemq.amqp.protocol.types.IAmqpMap; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a the released disposition @@ -554,4 +554,4 @@ public interface AmqpReleased extends Am return create(marshaller.decodeAmqpReleased(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpRelink.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpRelink.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpRelink.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpRelink.java Wed Jul 7 03:50:42 2010 @@ -26,7 +26,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a re-establish Link parameters @@ -437,4 +437,4 @@ public interface AmqpRelink extends Amqp return create(marshaller.decodeAmqpRelink(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpSaslChallenge.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpSaslChallenge.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpSaslChallenge.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpSaslChallenge.java Wed Jul 7 03:50:42 2010 @@ -24,7 +24,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a security mechanism challenge @@ -311,4 +311,4 @@ public interface AmqpSaslChallenge exten return create(marshaller.decodeAmqpSaslChallenge(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpSaslInit.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpSaslInit.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpSaslInit.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpSaslInit.java Wed Jul 7 03:50:42 2010 @@ -25,7 +25,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a initiate sasl exchange @@ -386,4 +386,4 @@ public interface AmqpSaslInit extends Am return create(marshaller.decodeAmqpSaslInit(buffer, offset)); } } -} \ No newline at end of file +} Modified: activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpSaslMechanisms.java URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpSaslMechanisms.java?rev=961087&r1=961086&r2=961087&view=diff ============================================================================== --- activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpSaslMechanisms.java (original) +++ activemq/sandbox/activemq-apollo-actor/sandbox/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpSaslMechanisms.java Wed Jul 7 03:50:42 2010 @@ -24,7 +24,7 @@ import org.apache.activemq.amqp.protocol import org.apache.activemq.amqp.protocol.marshaller.AmqpMarshaller; import org.apache.activemq.amqp.protocol.marshaller.Encoded; import org.apache.activemq.amqp.protocol.types.IAmqpList; -import org.apache.activemq.util.buffer.Buffer; +import org.fusesource.hawtbuf.Buffer; /** * Represents a advertise available sasl mechanisms @@ -295,4 +295,4 @@ public interface AmqpSaslMechanisms exte return create(marshaller.decodeAmqpSaslMechanisms(buffer, offset)); } } -} \ No newline at end of file +}