activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cmacn...@apache.org
Subject svn commit: r909704 [6/10] - in /activemq/sandbox/activemq-apollo-actor/activemq-amqp/src: main/java/org/apache/activemq/amqp/protocol/marshaller/ main/java/org/apache/activemq/amqp/protocol/marshaller/v1_0_0/ main/java/org/apache/activemq/amqp/protoco...
Date Sat, 13 Feb 2010 03:20:18 GMT
Modified: activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpConnectionError.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpConnectionError.java?rev=909704&r1=909703&r2=909704&view=diff
==============================================================================
--- activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpConnectionError.java (original)
+++ activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpConnectionError.java Sat Feb 13 03:20:16 2010
@@ -98,178 +98,178 @@
         AmqpConnectionErrorBean() {
         }
 
-        AmqpConnectionErrorBean(IAmqpList value) {
+        AmqpConnectionErrorBean(IAmqpList<AmqpType<?, ?>> value) {
 
-        for(int i = 0; i < value.getListCount(); i++) {
-            set(i, value.get(i));
+            for(int i = 0; i < value.getListCount(); i++) {
+                set(i, value.get(i));
+            }
         }
-    }
-
-    AmqpConnectionErrorBean(AmqpConnectionError.AmqpConnectionErrorBean other) {
-        this.bean = other;
-    }
-
-    public final AmqpConnectionErrorBean copy() {
-        return new AmqpConnectionError.AmqpConnectionErrorBean(bean);
-    }
 
-    public final AmqpConnectionError.AmqpConnectionErrorBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
-        if(buffer == null) {
-            buffer = new AmqpConnectionErrorBuffer(marshaller.encode(this));
+        AmqpConnectionErrorBean(AmqpConnectionError.AmqpConnectionErrorBean other) {
+            this.bean = other;
         }
-        return buffer;
-    }
-
-    public final void marshal(DataOutput out, AmqpMarshaller marshaller) throws IOException, AmqpEncodingError{
-        getBuffer(marshaller).marshal(out, marshaller);
-    }
 
+        public final AmqpConnectionErrorBean copy() {
+            return new AmqpConnectionError.AmqpConnectionErrorBean(bean);
+        }
 
-    public final void setErrorCode(AmqpConnectionErrorCode errorCode) {
-        copyCheck();
-        bean.errorCode = errorCode;
-    }
-
-    public final AmqpConnectionErrorCode getErrorCode() {
-        return bean.errorCode;
-    }
+        public final AmqpConnectionError.AmqpConnectionErrorBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
+            if(buffer == null) {
+                buffer = new AmqpConnectionErrorBuffer(marshaller.encode(this));
+            }
+            return buffer;
+        }
 
-    public void setDescription(String description) {
-        setDescription(TypeFactory.createAmqpString(description));
-    }
+        public final void marshal(DataOutput out, AmqpMarshaller marshaller) throws IOException, AmqpEncodingError{
+            getBuffer(marshaller).marshal(out, marshaller);
+        }
 
 
-    public final void setDescription(AmqpString description) {
-        copyCheck();
-        bean.description = description;
-    }
+        public final void setErrorCode(AmqpConnectionErrorCode errorCode) {
+            copyCheck();
+            bean.errorCode = errorCode;
+        }
 
-    public final String getDescription() {
-        return bean.description.getValue();
-    }
+        public final AmqpConnectionErrorCode getErrorCode() {
+            return bean.errorCode;
+        }
 
-    public final void setErrorInfo(AmqpMap errorInfo) {
-        copyCheck();
-        bean.errorInfo = errorInfo;
-    }
+        public void setDescription(String description) {
+            setDescription(TypeFactory.createAmqpString(description));
+        }
 
-    public final IAmqpMap<AmqpType<?, ?>, AmqpType<?, ?>> getErrorInfo() {
-        return bean.errorInfo.getValue();
-    }
 
-    public void set(int index, AmqpType<?, ?> value) {
-        switch(index) {
-        case 0: {
-            setErrorCode(AmqpConnectionErrorCode.get((AmqpUshort)value));
-            break;
-        }
-        case 1: {
-            setDescription((AmqpString) value);
-            break;
-        }
-        case 2: {
-            setErrorInfo((AmqpMap) value);
-            break;
-        }
-        default : {
-            throw new IndexOutOfBoundsException(String.valueOf(index));
-        }
+        public final void setDescription(AmqpString description) {
+            copyCheck();
+            bean.description = description;
         }
-    }
 
-    public AmqpType<?, ?> get(int index) {
-        switch(index) {
-        case 0: {
-            if(errorCode == null) {
-                return null;
-            }
-            return errorCode.getValue();
+        public final String getDescription() {
+            return bean.description.getValue();
         }
-        case 1: {
-            return bean.description;
+
+        public final void setErrorInfo(AmqpMap errorInfo) {
+            copyCheck();
+            bean.errorInfo = errorInfo;
         }
-        case 2: {
+
+        public final IAmqpMap<AmqpType<?, ?>, AmqpType<?, ?>> getErrorInfo() {
             return bean.errorInfo;
         }
-        default : {
-            throw new IndexOutOfBoundsException(String.valueOf(index));
+
+        public void set(int index, AmqpType<?, ?> value) {
+            switch(index) {
+            case 0: {
+                setErrorCode(AmqpConnectionErrorCode.get((AmqpUshort)value));
+                break;
+            }
+            case 1: {
+                setDescription((AmqpString) value);
+                break;
+            }
+            case 2: {
+                setErrorInfo((AmqpMap) value);
+                break;
+            }
+            default : {
+                throw new IndexOutOfBoundsException(String.valueOf(index));
+            }
+            }
         }
+
+        public AmqpType<?, ?> get(int index) {
+            switch(index) {
+            case 0: {
+                if(errorCode == null) {
+                    return null;
+                }
+                return errorCode.getValue();
+            }
+            case 1: {
+                return bean.description;
+            }
+            case 2: {
+                return bean.errorInfo;
+            }
+            default : {
+                throw new IndexOutOfBoundsException(String.valueOf(index));
+            }
+            }
         }
-    }
 
-    public int getListCount() {
-        return 3;
-    }
+        public int getListCount() {
+            return 3;
+        }
 
-    public IAmqpList getValue() {
-        return bean;
-    }
+        public IAmqpList<AmqpType<?, ?>> getValue() {
+            return bean;
+        }
 
-    public Iterator<AmqpType<?, ?>> iterator() {
-        return new AmqpListIterator(bean);
-    }
+        public Iterator<AmqpType<?, ?>> iterator() {
+            return new AmqpListIterator<AmqpType<?, ?>>(bean);
+        }
 
 
-    private final void copyCheck() {
-        if(buffer != null) {;
-            throw new IllegalStateException("unwriteable");
+        private final void copyCheck() {
+            if(buffer != null) {;
+                throw new IllegalStateException("unwriteable");
+            }
+            if(bean != this) {;
+                copy(bean);
+            }
         }
-        if(bean != this) {;
-            copy(bean);
+
+        private final void copy(AmqpConnectionError.AmqpConnectionErrorBean other) {
+            bean = this;
         }
-    }
 
-    private final void copy(AmqpConnectionError.AmqpConnectionErrorBean other) {
-        bean = this;
-    }
+        public boolean equals(Object o){
+            if(this == o) {
+                return true;
+            }
 
-    public boolean equals(Object o){
-        if(this == o) {
-            return true;
-        }
+            if(o == null || !(o instanceof AmqpConnectionError)) {
+                return false;
+            }
 
-        if(o == null || !(o instanceof AmqpConnectionError)) {
-            return false;
+            return equals((AmqpConnectionError) o);
         }
 
-        return equals((AmqpConnectionError) o);
-    }
+        public boolean equals(AmqpConnectionError b) {
 
-    public boolean equals(AmqpConnectionError b) {
+            if(b.getErrorCode() == null ^ getErrorCode() == null) {
+                return false;
+            }
+            if(b.getErrorCode() != null && !b.getErrorCode().equals(getErrorCode())){ 
+                return false;
+            }
 
-        if(b.getErrorCode() == null ^ getErrorCode() == null) {
-            return false;
-        }
-        if(b.getErrorCode() != null && !b.getErrorCode().equals(getErrorCode())){ 
-            return false;
-        }
+            if(b.getDescription() == null ^ getDescription() == null) {
+                return false;
+            }
+            if(b.getDescription() != null && !b.getDescription().equals(getDescription())){ 
+                return false;
+            }
 
-        if(b.getDescription() == null ^ getDescription() == null) {
-            return false;
-        }
-        if(b.getDescription() != null && !b.getDescription().equals(getDescription())){ 
-            return false;
+            if(b.getErrorInfo() == null ^ getErrorInfo() == null) {
+                return false;
+            }
+            if(b.getErrorInfo() != null && !b.getErrorInfo().equals(getErrorInfo())){ 
+                return false;
+            }
+            return true;
         }
 
-        if(b.getErrorInfo() == null ^ getErrorInfo() == null) {
-            return false;
-        }
-        if(b.getErrorInfo() != null && !b.getErrorInfo().equals(getErrorInfo())){ 
-            return false;
+        public int hashCode() {
+            return AbstractAmqpList.hashCodeFor(this);
         }
-        return true;
-    }
-
-    public int hashCode() {
-        return AbstractAmqpList.hashCodeFor(this);
     }
-}
 
     public static class AmqpConnectionErrorBuffer extends AmqpList.AmqpListBuffer implements AmqpConnectionError{
 
         private AmqpConnectionErrorBean bean;
 
-        protected AmqpConnectionErrorBuffer(Encoded<IAmqpList> encoded) {
+        protected AmqpConnectionErrorBuffer(Encoded<IAmqpList<AmqpType<?, ?>>> encoded) {
             super(encoded);
         }
 
@@ -317,10 +317,6 @@
             return bean().iterator();
         }
 
-        public IAmqpList getValue() {
-            return bean().getValue();
-        }
-
         public AmqpConnectionError.AmqpConnectionErrorBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
             return this;
         }
@@ -345,7 +341,7 @@
             return bean().hashCode();
         }
 
-        public static AmqpConnectionError.AmqpConnectionErrorBuffer create(Encoded<IAmqpList> encoded) {
+        public static AmqpConnectionError.AmqpConnectionErrorBuffer create(Encoded<IAmqpList<AmqpType<?, ?>>> encoded) {
             if(encoded.isNull()) {
                 return null;
             }

Modified: activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpDetach.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpDetach.java?rev=909704&r1=909703&r2=909704&view=diff
==============================================================================
--- activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpDetach.java (original)
+++ activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpDetach.java Sat Feb 13 03:20:16 2010
@@ -147,212 +147,212 @@
         AmqpDetachBean() {
         }
 
-        AmqpDetachBean(IAmqpList value) {
+        AmqpDetachBean(IAmqpList<AmqpType<?, ?>> value) {
 
-        for(int i = 0; i < value.getListCount(); i++) {
-            set(i, value.get(i));
+            for(int i = 0; i < value.getListCount(); i++) {
+                set(i, value.get(i));
+            }
         }
-    }
-
-    AmqpDetachBean(AmqpDetach.AmqpDetachBean other) {
-        this.bean = other;
-    }
-
-    public final AmqpDetachBean copy() {
-        return new AmqpDetach.AmqpDetachBean(bean);
-    }
-
-    public final void handle(AmqpCommandHandler handler) throws Exception {
-        handler.handleDetach(this);
-    }
 
-    public final AmqpDetach.AmqpDetachBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
-        if(buffer == null) {
-            buffer = new AmqpDetachBuffer(marshaller.encode(this));
+        AmqpDetachBean(AmqpDetach.AmqpDetachBean other) {
+            this.bean = other;
         }
-        return buffer;
-    }
-
-    public final void marshal(DataOutput out, AmqpMarshaller marshaller) throws IOException, AmqpEncodingError{
-        getBuffer(marshaller).marshal(out, marshaller);
-    }
 
+        public final AmqpDetachBean copy() {
+            return new AmqpDetach.AmqpDetachBean(bean);
+        }
 
-    public final void setOptions(AmqpOptions options) {
-        copyCheck();
-        bean.options = options;
-    }
+        public final void handle(AmqpCommandHandler handler) throws Exception {
+            handler.handleDetach(this);
+        }
 
-    public final AmqpOptions getOptions() {
-        return bean.options;
-    }
+        public final AmqpDetach.AmqpDetachBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
+            if(buffer == null) {
+                buffer = new AmqpDetachBuffer(marshaller.encode(this));
+            }
+            return buffer;
+        }
 
-    public void setName(Buffer name) {
-        setName(TypeFactory.createAmqpSessionName(name));
-    }
+        public final void marshal(DataOutput out, AmqpMarshaller marshaller) throws IOException, AmqpEncodingError{
+            getBuffer(marshaller).marshal(out, marshaller);
+        }
 
 
-    public final void setName(AmqpSessionName name) {
-        copyCheck();
-        bean.name = name;
-    }
+        public final void setOptions(AmqpOptions options) {
+            copyCheck();
+            bean.options = options;
+        }
 
-    public final AmqpSessionName getName() {
-        return bean.name;
-    }
+        public final AmqpOptions getOptions() {
+            return bean.options;
+        }
 
-    public void setClosing(Boolean closing) {
-        setClosing(TypeFactory.createAmqpBoolean(closing));
-    }
+        public void setName(Buffer name) {
+            setName(TypeFactory.createAmqpSessionName(name));
+        }
 
 
-    public void setClosing(boolean closing) {
-        setClosing(TypeFactory.createAmqpBoolean(closing));
-    }
+        public final void setName(AmqpSessionName name) {
+            copyCheck();
+            bean.name = name;
+        }
 
+        public final AmqpSessionName getName() {
+            return bean.name;
+        }
 
-    public final void setClosing(AmqpBoolean closing) {
-        copyCheck();
-        bean.closing = closing;
-    }
+        public void setClosing(Boolean closing) {
+            setClosing(TypeFactory.createAmqpBoolean(closing));
+        }
 
-    public final Boolean getClosing() {
-        return bean.closing.getValue();
-    }
 
-    public final void setException(AmqpSessionError exception) {
-        copyCheck();
-        bean.exception = exception;
-    }
+        public void setClosing(boolean closing) {
+            setClosing(TypeFactory.createAmqpBoolean(closing));
+        }
 
-    public final AmqpSessionError getException() {
-        return bean.exception;
-    }
 
-    public void set(int index, AmqpType<?, ?> value) {
-        switch(index) {
-        case 0: {
-            setOptions((AmqpOptions) value);
-            break;
-        }
-        case 1: {
-            setName((AmqpSessionName) value);
-            break;
-        }
-        case 2: {
-            setClosing((AmqpBoolean) value);
-            break;
-        }
-        case 3: {
-            setException((AmqpSessionError) value);
-            break;
-        }
-        default : {
-            throw new IndexOutOfBoundsException(String.valueOf(index));
-        }
+        public final void setClosing(AmqpBoolean closing) {
+            copyCheck();
+            bean.closing = closing;
         }
-    }
 
-    public AmqpType<?, ?> get(int index) {
-        switch(index) {
-        case 0: {
-            return bean.options;
-        }
-        case 1: {
-            return bean.name;
+        public final Boolean getClosing() {
+            return bean.closing.getValue();
         }
-        case 2: {
-            return bean.closing;
+
+        public final void setException(AmqpSessionError exception) {
+            copyCheck();
+            bean.exception = exception;
         }
-        case 3: {
+
+        public final AmqpSessionError getException() {
             return bean.exception;
         }
-        default : {
-            throw new IndexOutOfBoundsException(String.valueOf(index));
+
+        public void set(int index, AmqpType<?, ?> value) {
+            switch(index) {
+            case 0: {
+                setOptions((AmqpOptions) value);
+                break;
+            }
+            case 1: {
+                setName((AmqpSessionName) value);
+                break;
+            }
+            case 2: {
+                setClosing((AmqpBoolean) value);
+                break;
+            }
+            case 3: {
+                setException((AmqpSessionError) value);
+                break;
+            }
+            default : {
+                throw new IndexOutOfBoundsException(String.valueOf(index));
+            }
+            }
         }
+
+        public AmqpType<?, ?> get(int index) {
+            switch(index) {
+            case 0: {
+                return bean.options;
+            }
+            case 1: {
+                return bean.name;
+            }
+            case 2: {
+                return bean.closing;
+            }
+            case 3: {
+                return bean.exception;
+            }
+            default : {
+                throw new IndexOutOfBoundsException(String.valueOf(index));
+            }
+            }
         }
-    }
 
-    public int getListCount() {
-        return 4;
-    }
+        public int getListCount() {
+            return 4;
+        }
 
-    public IAmqpList getValue() {
-        return bean;
-    }
+        public IAmqpList<AmqpType<?, ?>> getValue() {
+            return bean;
+        }
 
-    public Iterator<AmqpType<?, ?>> iterator() {
-        return new AmqpListIterator(bean);
-    }
+        public Iterator<AmqpType<?, ?>> iterator() {
+            return new AmqpListIterator<AmqpType<?, ?>>(bean);
+        }
 
 
-    private final void copyCheck() {
-        if(buffer != null) {;
-            throw new IllegalStateException("unwriteable");
+        private final void copyCheck() {
+            if(buffer != null) {;
+                throw new IllegalStateException("unwriteable");
+            }
+            if(bean != this) {;
+                copy(bean);
+            }
         }
-        if(bean != this) {;
-            copy(bean);
+
+        private final void copy(AmqpDetach.AmqpDetachBean other) {
+            bean = this;
         }
-    }
 
-    private final void copy(AmqpDetach.AmqpDetachBean other) {
-        bean = this;
-    }
+        public boolean equals(Object o){
+            if(this == o) {
+                return true;
+            }
 
-    public boolean equals(Object o){
-        if(this == o) {
-            return true;
-        }
+            if(o == null || !(o instanceof AmqpDetach)) {
+                return false;
+            }
 
-        if(o == null || !(o instanceof AmqpDetach)) {
-            return false;
+            return equals((AmqpDetach) o);
         }
 
-        return equals((AmqpDetach) o);
-    }
+        public boolean equals(AmqpDetach b) {
 
-    public boolean equals(AmqpDetach b) {
+            if(b.getOptions() == null ^ getOptions() == null) {
+                return false;
+            }
+            if(b.getOptions() != null && !b.getOptions().equals(getOptions())){ 
+                return false;
+            }
 
-        if(b.getOptions() == null ^ getOptions() == null) {
-            return false;
-        }
-        if(b.getOptions() != null && !b.getOptions().equals(getOptions())){ 
-            return false;
-        }
+            if(b.getName() == null ^ getName() == null) {
+                return false;
+            }
+            if(b.getName() != null && !b.getName().equals(getName())){ 
+                return false;
+            }
 
-        if(b.getName() == null ^ getName() == null) {
-            return false;
-        }
-        if(b.getName() != null && !b.getName().equals(getName())){ 
-            return false;
-        }
+            if(b.getClosing() == null ^ getClosing() == null) {
+                return false;
+            }
+            if(b.getClosing() != null && !b.getClosing().equals(getClosing())){ 
+                return false;
+            }
 
-        if(b.getClosing() == null ^ getClosing() == null) {
-            return false;
-        }
-        if(b.getClosing() != null && !b.getClosing().equals(getClosing())){ 
-            return false;
+            if(b.getException() == null ^ getException() == null) {
+                return false;
+            }
+            if(b.getException() != null && !b.getException().equals(getException())){ 
+                return false;
+            }
+            return true;
         }
 
-        if(b.getException() == null ^ getException() == null) {
-            return false;
-        }
-        if(b.getException() != null && !b.getException().equals(getException())){ 
-            return false;
+        public int hashCode() {
+            return AbstractAmqpList.hashCodeFor(this);
         }
-        return true;
     }
 
-    public int hashCode() {
-        return AbstractAmqpList.hashCodeFor(this);
-    }
-}
-
     public static class AmqpDetachBuffer extends AmqpList.AmqpListBuffer implements AmqpDetach{
 
         private AmqpDetachBean bean;
 
-        protected AmqpDetachBuffer(Encoded<IAmqpList> encoded) {
+        protected AmqpDetachBuffer(Encoded<IAmqpList<AmqpType<?, ?>>> encoded) {
             super(encoded);
         }
 
@@ -417,10 +417,6 @@
             return bean().iterator();
         }
 
-        public IAmqpList getValue() {
-            return bean().getValue();
-        }
-
         public AmqpDetach.AmqpDetachBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
             return this;
         }
@@ -449,7 +445,7 @@
             return bean().hashCode();
         }
 
-        public static AmqpDetach.AmqpDetachBuffer create(Encoded<IAmqpList> encoded) {
+        public static AmqpDetach.AmqpDetachBuffer create(Encoded<IAmqpList<AmqpType<?, ?>>> encoded) {
             if(encoded.isNull()) {
                 return null;
             }

Modified: activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpDisposition.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpDisposition.java?rev=909704&r1=909703&r2=909704&view=diff
==============================================================================
--- activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpDisposition.java (original)
+++ activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpDisposition.java Sat Feb 13 03:20:16 2010
@@ -134,240 +134,240 @@
         AmqpDispositionBean() {
         }
 
-        AmqpDispositionBean(IAmqpList value) {
+        AmqpDispositionBean(IAmqpList<AmqpType<?, ?>> value) {
 
-        for(int i = 0; i < value.getListCount(); i++) {
-            set(i, value.get(i));
+            for(int i = 0; i < value.getListCount(); i++) {
+                set(i, value.get(i));
+            }
         }
-    }
 
-    AmqpDispositionBean(AmqpDisposition.AmqpDispositionBean other) {
-        this.bean = other;
-    }
-
-    public final AmqpDispositionBean copy() {
-        return new AmqpDisposition.AmqpDispositionBean(bean);
-    }
-
-    public final void handle(AmqpCommandHandler handler) throws Exception {
-        handler.handleDisposition(this);
-    }
+        AmqpDispositionBean(AmqpDisposition.AmqpDispositionBean other) {
+            this.bean = other;
+        }
 
-    public final AmqpDisposition.AmqpDispositionBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
-        if(buffer == null) {
-            buffer = new AmqpDispositionBuffer(marshaller.encode(this));
+        public final AmqpDispositionBean copy() {
+            return new AmqpDisposition.AmqpDispositionBean(bean);
         }
-        return buffer;
-    }
 
-    public final void marshal(DataOutput out, AmqpMarshaller marshaller) throws IOException, AmqpEncodingError{
-        getBuffer(marshaller).marshal(out, marshaller);
-    }
+        public final void handle(AmqpCommandHandler handler) throws Exception {
+            handler.handleDisposition(this);
+        }
 
+        public final AmqpDisposition.AmqpDispositionBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
+            if(buffer == null) {
+                buffer = new AmqpDispositionBuffer(marshaller.encode(this));
+            }
+            return buffer;
+        }
 
-    public final void setOptions(AmqpOptions options) {
-        copyCheck();
-        bean.options = options;
-    }
+        public final void marshal(DataOutput out, AmqpMarshaller marshaller) throws IOException, AmqpEncodingError{
+            getBuffer(marshaller).marshal(out, marshaller);
+        }
 
-    public final AmqpOptions getOptions() {
-        return bean.options;
-    }
 
-    public void setHandle(Long handle) {
-        setHandle(TypeFactory.createAmqpHandle(handle));
-    }
+        public final void setOptions(AmqpOptions options) {
+            copyCheck();
+            bean.options = options;
+        }
 
+        public final AmqpOptions getOptions() {
+            return bean.options;
+        }
 
-    public void setHandle(long handle) {
-        setHandle(TypeFactory.createAmqpHandle(handle));
-    }
+        public void setHandle(Long handle) {
+            setHandle(TypeFactory.createAmqpHandle(handle));
+        }
 
 
-    public final void setHandle(AmqpHandle handle) {
-        copyCheck();
-        bean.handle = handle;
-    }
+        public void setHandle(long handle) {
+            setHandle(TypeFactory.createAmqpHandle(handle));
+        }
 
-    public final AmqpHandle getHandle() {
-        return bean.handle;
-    }
 
-    public final void setDisposition(AmqpMap disposition) {
-        copyCheck();
-        bean.disposition = disposition;
-    }
+        public final void setHandle(AmqpHandle handle) {
+            copyCheck();
+            bean.handle = handle;
+        }
 
-    public final IAmqpMap<AmqpType<?, ?>, AmqpType<?, ?>> getDisposition() {
-        return bean.disposition.getValue();
-    }
+        public final AmqpHandle getHandle() {
+            return bean.handle;
+        }
 
-    public void setFirst(Buffer first) {
-        setFirst(TypeFactory.createAmqpDeliveryTag(first));
-    }
+        public final void setDisposition(AmqpMap disposition) {
+            copyCheck();
+            bean.disposition = disposition;
+        }
 
+        public final IAmqpMap<AmqpType<?, ?>, AmqpType<?, ?>> getDisposition() {
+            return bean.disposition;
+        }
 
-    public final void setFirst(AmqpDeliveryTag first) {
-        copyCheck();
-        bean.first = first;
-    }
+        public void setFirst(Buffer first) {
+            setFirst(TypeFactory.createAmqpDeliveryTag(first));
+        }
 
-    public final AmqpDeliveryTag getFirst() {
-        return bean.first;
-    }
 
-    public void setLast(Buffer last) {
-        setLast(TypeFactory.createAmqpDeliveryTag(last));
-    }
+        public final void setFirst(AmqpDeliveryTag first) {
+            copyCheck();
+            bean.first = first;
+        }
 
+        public final AmqpDeliveryTag getFirst() {
+            return bean.first;
+        }
 
-    public final void setLast(AmqpDeliveryTag last) {
-        copyCheck();
-        bean.last = last;
-    }
+        public void setLast(Buffer last) {
+            setLast(TypeFactory.createAmqpDeliveryTag(last));
+        }
 
-    public final AmqpDeliveryTag getLast() {
-        return bean.last;
-    }
 
-    public void set(int index, AmqpType<?, ?> value) {
-        switch(index) {
-        case 0: {
-            setOptions((AmqpOptions) value);
-            break;
-        }
-        case 1: {
-            setHandle((AmqpHandle) value);
-            break;
-        }
-        case 2: {
-            setDisposition((AmqpMap) value);
-            break;
-        }
-        case 3: {
-            setFirst((AmqpDeliveryTag) value);
-            break;
-        }
-        case 4: {
-            setLast((AmqpDeliveryTag) value);
-            break;
-        }
-        default : {
-            throw new IndexOutOfBoundsException(String.valueOf(index));
-        }
+        public final void setLast(AmqpDeliveryTag last) {
+            copyCheck();
+            bean.last = last;
         }
-    }
 
-    public AmqpType<?, ?> get(int index) {
-        switch(index) {
-        case 0: {
-            return bean.options;
-        }
-        case 1: {
-            return bean.handle;
-        }
-        case 2: {
-            return bean.disposition;
-        }
-        case 3: {
-            return bean.first;
-        }
-        case 4: {
+        public final AmqpDeliveryTag getLast() {
             return bean.last;
         }
-        default : {
-            throw new IndexOutOfBoundsException(String.valueOf(index));
+
+        public void set(int index, AmqpType<?, ?> value) {
+            switch(index) {
+            case 0: {
+                setOptions((AmqpOptions) value);
+                break;
+            }
+            case 1: {
+                setHandle((AmqpHandle) value);
+                break;
+            }
+            case 2: {
+                setDisposition((AmqpMap) value);
+                break;
+            }
+            case 3: {
+                setFirst((AmqpDeliveryTag) value);
+                break;
+            }
+            case 4: {
+                setLast((AmqpDeliveryTag) value);
+                break;
+            }
+            default : {
+                throw new IndexOutOfBoundsException(String.valueOf(index));
+            }
+            }
         }
+
+        public AmqpType<?, ?> get(int index) {
+            switch(index) {
+            case 0: {
+                return bean.options;
+            }
+            case 1: {
+                return bean.handle;
+            }
+            case 2: {
+                return bean.disposition;
+            }
+            case 3: {
+                return bean.first;
+            }
+            case 4: {
+                return bean.last;
+            }
+            default : {
+                throw new IndexOutOfBoundsException(String.valueOf(index));
+            }
+            }
         }
-    }
 
-    public int getListCount() {
-        return 5;
-    }
+        public int getListCount() {
+            return 5;
+        }
 
-    public IAmqpList getValue() {
-        return bean;
-    }
+        public IAmqpList<AmqpType<?, ?>> getValue() {
+            return bean;
+        }
 
-    public Iterator<AmqpType<?, ?>> iterator() {
-        return new AmqpListIterator(bean);
-    }
+        public Iterator<AmqpType<?, ?>> iterator() {
+            return new AmqpListIterator<AmqpType<?, ?>>(bean);
+        }
 
 
-    private final void copyCheck() {
-        if(buffer != null) {;
-            throw new IllegalStateException("unwriteable");
+        private final void copyCheck() {
+            if(buffer != null) {;
+                throw new IllegalStateException("unwriteable");
+            }
+            if(bean != this) {;
+                copy(bean);
+            }
         }
-        if(bean != this) {;
-            copy(bean);
+
+        private final void copy(AmqpDisposition.AmqpDispositionBean other) {
+            bean = this;
         }
-    }
 
-    private final void copy(AmqpDisposition.AmqpDispositionBean other) {
-        bean = this;
-    }
+        public boolean equals(Object o){
+            if(this == o) {
+                return true;
+            }
 
-    public boolean equals(Object o){
-        if(this == o) {
-            return true;
-        }
+            if(o == null || !(o instanceof AmqpDisposition)) {
+                return false;
+            }
 
-        if(o == null || !(o instanceof AmqpDisposition)) {
-            return false;
+            return equals((AmqpDisposition) o);
         }
 
-        return equals((AmqpDisposition) o);
-    }
+        public boolean equals(AmqpDisposition b) {
 
-    public boolean equals(AmqpDisposition b) {
+            if(b.getOptions() == null ^ getOptions() == null) {
+                return false;
+            }
+            if(b.getOptions() != null && !b.getOptions().equals(getOptions())){ 
+                return false;
+            }
 
-        if(b.getOptions() == null ^ getOptions() == null) {
-            return false;
-        }
-        if(b.getOptions() != null && !b.getOptions().equals(getOptions())){ 
-            return false;
-        }
+            if(b.getHandle() == null ^ getHandle() == null) {
+                return false;
+            }
+            if(b.getHandle() != null && !b.getHandle().equals(getHandle())){ 
+                return false;
+            }
 
-        if(b.getHandle() == null ^ getHandle() == null) {
-            return false;
-        }
-        if(b.getHandle() != null && !b.getHandle().equals(getHandle())){ 
-            return false;
-        }
+            if(b.getDisposition() == null ^ getDisposition() == null) {
+                return false;
+            }
+            if(b.getDisposition() != null && !b.getDisposition().equals(getDisposition())){ 
+                return false;
+            }
 
-        if(b.getDisposition() == null ^ getDisposition() == null) {
-            return false;
-        }
-        if(b.getDisposition() != null && !b.getDisposition().equals(getDisposition())){ 
-            return false;
-        }
+            if(b.getFirst() == null ^ getFirst() == null) {
+                return false;
+            }
+            if(b.getFirst() != null && !b.getFirst().equals(getFirst())){ 
+                return false;
+            }
 
-        if(b.getFirst() == null ^ getFirst() == null) {
-            return false;
-        }
-        if(b.getFirst() != null && !b.getFirst().equals(getFirst())){ 
-            return false;
+            if(b.getLast() == null ^ getLast() == null) {
+                return false;
+            }
+            if(b.getLast() != null && !b.getLast().equals(getLast())){ 
+                return false;
+            }
+            return true;
         }
 
-        if(b.getLast() == null ^ getLast() == null) {
-            return false;
-        }
-        if(b.getLast() != null && !b.getLast().equals(getLast())){ 
-            return false;
+        public int hashCode() {
+            return AbstractAmqpList.hashCodeFor(this);
         }
-        return true;
     }
 
-    public int hashCode() {
-        return AbstractAmqpList.hashCodeFor(this);
-    }
-}
-
     public static class AmqpDispositionBuffer extends AmqpList.AmqpListBuffer implements AmqpDisposition{
 
         private AmqpDispositionBean bean;
 
-        protected AmqpDispositionBuffer(Encoded<IAmqpList> encoded) {
+        protected AmqpDispositionBuffer(Encoded<IAmqpList<AmqpType<?, ?>>> encoded) {
             super(encoded);
         }
 
@@ -444,10 +444,6 @@
             return bean().iterator();
         }
 
-        public IAmqpList getValue() {
-            return bean().getValue();
-        }
-
         public AmqpDisposition.AmqpDispositionBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
             return this;
         }
@@ -476,7 +472,7 @@
             return bean().hashCode();
         }
 
-        public static AmqpDisposition.AmqpDispositionBuffer create(Encoded<IAmqpList> encoded) {
+        public static AmqpDisposition.AmqpDispositionBuffer create(Encoded<IAmqpList<AmqpType<?, ?>>> encoded) {
             if(encoded.isNull()) {
                 return null;
             }

Modified: activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpDrain.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpDrain.java?rev=909704&r1=909703&r2=909704&view=diff
==============================================================================
--- activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpDrain.java (original)
+++ activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpDrain.java Sat Feb 13 03:20:16 2010
@@ -118,161 +118,161 @@
         AmqpDrainBean() {
         }
 
-        AmqpDrainBean(IAmqpList value) {
+        AmqpDrainBean(IAmqpList<AmqpType<?, ?>> value) {
 
-        for(int i = 0; i < value.getListCount(); i++) {
-            set(i, value.get(i));
+            for(int i = 0; i < value.getListCount(); i++) {
+                set(i, value.get(i));
+            }
         }
-    }
-
-    AmqpDrainBean(AmqpDrain.AmqpDrainBean other) {
-        this.bean = other;
-    }
-
-    public final AmqpDrainBean copy() {
-        return new AmqpDrain.AmqpDrainBean(bean);
-    }
 
-    public final void handle(AmqpCommandHandler handler) throws Exception {
-        handler.handleDrain(this);
-    }
+        AmqpDrainBean(AmqpDrain.AmqpDrainBean other) {
+            this.bean = other;
+        }
 
-    public final AmqpDrain.AmqpDrainBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
-        if(buffer == null) {
-            buffer = new AmqpDrainBuffer(marshaller.encode(this));
+        public final AmqpDrainBean copy() {
+            return new AmqpDrain.AmqpDrainBean(bean);
         }
-        return buffer;
-    }
 
-    public final void marshal(DataOutput out, AmqpMarshaller marshaller) throws IOException, AmqpEncodingError{
-        getBuffer(marshaller).marshal(out, marshaller);
-    }
+        public final void handle(AmqpCommandHandler handler) throws Exception {
+            handler.handleDrain(this);
+        }
 
+        public final AmqpDrain.AmqpDrainBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
+            if(buffer == null) {
+                buffer = new AmqpDrainBuffer(marshaller.encode(this));
+            }
+            return buffer;
+        }
 
-    public final void setOptions(AmqpOptions options) {
-        copyCheck();
-        bean.options = options;
-    }
+        public final void marshal(DataOutput out, AmqpMarshaller marshaller) throws IOException, AmqpEncodingError{
+            getBuffer(marshaller).marshal(out, marshaller);
+        }
 
-    public final AmqpOptions getOptions() {
-        return bean.options;
-    }
 
-    public void setHandle(Long handle) {
-        setHandle(TypeFactory.createAmqpHandle(handle));
-    }
+        public final void setOptions(AmqpOptions options) {
+            copyCheck();
+            bean.options = options;
+        }
 
+        public final AmqpOptions getOptions() {
+            return bean.options;
+        }
 
-    public void setHandle(long handle) {
-        setHandle(TypeFactory.createAmqpHandle(handle));
-    }
+        public void setHandle(Long handle) {
+            setHandle(TypeFactory.createAmqpHandle(handle));
+        }
 
 
-    public final void setHandle(AmqpHandle handle) {
-        copyCheck();
-        bean.handle = handle;
-    }
+        public void setHandle(long handle) {
+            setHandle(TypeFactory.createAmqpHandle(handle));
+        }
 
-    public final AmqpHandle getHandle() {
-        return bean.handle;
-    }
 
-    public void set(int index, AmqpType<?, ?> value) {
-        switch(index) {
-        case 0: {
-            setOptions((AmqpOptions) value);
-            break;
-        }
-        case 1: {
-            setHandle((AmqpHandle) value);
-            break;
-        }
-        default : {
-            throw new IndexOutOfBoundsException(String.valueOf(index));
-        }
+        public final void setHandle(AmqpHandle handle) {
+            copyCheck();
+            bean.handle = handle;
         }
-    }
 
-    public AmqpType<?, ?> get(int index) {
-        switch(index) {
-        case 0: {
-            return bean.options;
-        }
-        case 1: {
+        public final AmqpHandle getHandle() {
             return bean.handle;
         }
-        default : {
-            throw new IndexOutOfBoundsException(String.valueOf(index));
+
+        public void set(int index, AmqpType<?, ?> value) {
+            switch(index) {
+            case 0: {
+                setOptions((AmqpOptions) value);
+                break;
+            }
+            case 1: {
+                setHandle((AmqpHandle) value);
+                break;
+            }
+            default : {
+                throw new IndexOutOfBoundsException(String.valueOf(index));
+            }
+            }
         }
+
+        public AmqpType<?, ?> get(int index) {
+            switch(index) {
+            case 0: {
+                return bean.options;
+            }
+            case 1: {
+                return bean.handle;
+            }
+            default : {
+                throw new IndexOutOfBoundsException(String.valueOf(index));
+            }
+            }
         }
-    }
 
-    public int getListCount() {
-        return 2;
-    }
+        public int getListCount() {
+            return 2;
+        }
 
-    public IAmqpList getValue() {
-        return bean;
-    }
+        public IAmqpList<AmqpType<?, ?>> getValue() {
+            return bean;
+        }
 
-    public Iterator<AmqpType<?, ?>> iterator() {
-        return new AmqpListIterator(bean);
-    }
+        public Iterator<AmqpType<?, ?>> iterator() {
+            return new AmqpListIterator<AmqpType<?, ?>>(bean);
+        }
 
 
-    private final void copyCheck() {
-        if(buffer != null) {;
-            throw new IllegalStateException("unwriteable");
+        private final void copyCheck() {
+            if(buffer != null) {;
+                throw new IllegalStateException("unwriteable");
+            }
+            if(bean != this) {;
+                copy(bean);
+            }
         }
-        if(bean != this) {;
-            copy(bean);
+
+        private final void copy(AmqpDrain.AmqpDrainBean other) {
+            bean = this;
         }
-    }
 
-    private final void copy(AmqpDrain.AmqpDrainBean other) {
-        bean = this;
-    }
+        public boolean equals(Object o){
+            if(this == o) {
+                return true;
+            }
 
-    public boolean equals(Object o){
-        if(this == o) {
-            return true;
-        }
+            if(o == null || !(o instanceof AmqpDrain)) {
+                return false;
+            }
 
-        if(o == null || !(o instanceof AmqpDrain)) {
-            return false;
+            return equals((AmqpDrain) o);
         }
 
-        return equals((AmqpDrain) o);
-    }
+        public boolean equals(AmqpDrain b) {
 
-    public boolean equals(AmqpDrain b) {
+            if(b.getOptions() == null ^ getOptions() == null) {
+                return false;
+            }
+            if(b.getOptions() != null && !b.getOptions().equals(getOptions())){ 
+                return false;
+            }
 
-        if(b.getOptions() == null ^ getOptions() == null) {
-            return false;
-        }
-        if(b.getOptions() != null && !b.getOptions().equals(getOptions())){ 
-            return false;
+            if(b.getHandle() == null ^ getHandle() == null) {
+                return false;
+            }
+            if(b.getHandle() != null && !b.getHandle().equals(getHandle())){ 
+                return false;
+            }
+            return true;
         }
 
-        if(b.getHandle() == null ^ getHandle() == null) {
-            return false;
-        }
-        if(b.getHandle() != null && !b.getHandle().equals(getHandle())){ 
-            return false;
+        public int hashCode() {
+            return AbstractAmqpList.hashCodeFor(this);
         }
-        return true;
-    }
-
-    public int hashCode() {
-        return AbstractAmqpList.hashCodeFor(this);
     }
-}
 
     public static class AmqpDrainBuffer extends AmqpList.AmqpListBuffer implements AmqpDrain{
 
         private AmqpDrainBean bean;
 
-        protected AmqpDrainBuffer(Encoded<IAmqpList> encoded) {
+        protected AmqpDrainBuffer(Encoded<IAmqpList<AmqpType<?, ?>>> encoded) {
             super(encoded);
         }
 
@@ -317,10 +317,6 @@
             return bean().iterator();
         }
 
-        public IAmqpList getValue() {
-            return bean().getValue();
-        }
-
         public AmqpDrain.AmqpDrainBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
             return this;
         }
@@ -349,7 +345,7 @@
             return bean().hashCode();
         }
 
-        public static AmqpDrain.AmqpDrainBuffer create(Encoded<IAmqpList> encoded) {
+        public static AmqpDrain.AmqpDrainBuffer create(Encoded<IAmqpList<AmqpType<?, ?>>> encoded) {
             if(encoded.isNull()) {
                 return null;
             }

Modified: activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpEnlist.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpEnlist.java?rev=909704&r1=909703&r2=909704&view=diff
==============================================================================
--- activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpEnlist.java (original)
+++ activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpEnlist.java Sat Feb 13 03:20:16 2010
@@ -154,217 +154,217 @@
         AmqpEnlistBean() {
         }
 
-        AmqpEnlistBean(IAmqpList value) {
+        AmqpEnlistBean(IAmqpList<AmqpType<?, ?>> value) {
 
-        for(int i = 0; i < value.getListCount(); i++) {
-            set(i, value.get(i));
+            for(int i = 0; i < value.getListCount(); i++) {
+                set(i, value.get(i));
+            }
         }
-    }
-
-    AmqpEnlistBean(AmqpEnlist.AmqpEnlistBean other) {
-        this.bean = other;
-    }
 
-    public final AmqpEnlistBean copy() {
-        return new AmqpEnlist.AmqpEnlistBean(bean);
-    }
-
-    public final void handle(AmqpCommandHandler handler) throws Exception {
-        handler.handleEnlist(this);
-    }
+        AmqpEnlistBean(AmqpEnlist.AmqpEnlistBean other) {
+            this.bean = other;
+        }
 
-    public final AmqpEnlist.AmqpEnlistBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
-        if(buffer == null) {
-            buffer = new AmqpEnlistBuffer(marshaller.encode(this));
+        public final AmqpEnlistBean copy() {
+            return new AmqpEnlist.AmqpEnlistBean(bean);
         }
-        return buffer;
-    }
 
-    public final void marshal(DataOutput out, AmqpMarshaller marshaller) throws IOException, AmqpEncodingError{
-        getBuffer(marshaller).marshal(out, marshaller);
-    }
+        public final void handle(AmqpCommandHandler handler) throws Exception {
+            handler.handleEnlist(this);
+        }
 
+        public final AmqpEnlist.AmqpEnlistBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
+            if(buffer == null) {
+                buffer = new AmqpEnlistBuffer(marshaller.encode(this));
+            }
+            return buffer;
+        }
 
-    public final void setOptions(AmqpOptions options) {
-        copyCheck();
-        bean.options = options;
-    }
+        public final void marshal(DataOutput out, AmqpMarshaller marshaller) throws IOException, AmqpEncodingError{
+            getBuffer(marshaller).marshal(out, marshaller);
+        }
 
-    public final AmqpOptions getOptions() {
-        return bean.options;
-    }
 
-    public final void setXid(AmqpXid xid) {
-        copyCheck();
-        bean.xid = xid;
-    }
+        public final void setOptions(AmqpOptions options) {
+            copyCheck();
+            bean.options = options;
+        }
 
-    public final AmqpXid getXid() {
-        return bean.xid;
-    }
+        public final AmqpOptions getOptions() {
+            return bean.options;
+        }
 
-    public void setJoin(Boolean join) {
-        setJoin(TypeFactory.createAmqpBoolean(join));
-    }
+        public final void setXid(AmqpXid xid) {
+            copyCheck();
+            bean.xid = xid;
+        }
 
+        public final AmqpXid getXid() {
+            return bean.xid;
+        }
 
-    public void setJoin(boolean join) {
-        setJoin(TypeFactory.createAmqpBoolean(join));
-    }
+        public void setJoin(Boolean join) {
+            setJoin(TypeFactory.createAmqpBoolean(join));
+        }
 
 
-    public final void setJoin(AmqpBoolean join) {
-        copyCheck();
-        bean.join = join;
-    }
+        public void setJoin(boolean join) {
+            setJoin(TypeFactory.createAmqpBoolean(join));
+        }
 
-    public final Boolean getJoin() {
-        return bean.join.getValue();
-    }
 
-    public void setResume(Boolean resume) {
-        setResume(TypeFactory.createAmqpBoolean(resume));
-    }
+        public final void setJoin(AmqpBoolean join) {
+            copyCheck();
+            bean.join = join;
+        }
 
+        public final Boolean getJoin() {
+            return bean.join.getValue();
+        }
 
-    public void setResume(boolean resume) {
-        setResume(TypeFactory.createAmqpBoolean(resume));
-    }
+        public void setResume(Boolean resume) {
+            setResume(TypeFactory.createAmqpBoolean(resume));
+        }
 
 
-    public final void setResume(AmqpBoolean resume) {
-        copyCheck();
-        bean.resume = resume;
-    }
+        public void setResume(boolean resume) {
+            setResume(TypeFactory.createAmqpBoolean(resume));
+        }
 
-    public final Boolean getResume() {
-        return bean.resume.getValue();
-    }
 
-    public void set(int index, AmqpType<?, ?> value) {
-        switch(index) {
-        case 0: {
-            setOptions((AmqpOptions) value);
-            break;
-        }
-        case 1: {
-            setXid((AmqpXid) value);
-            break;
-        }
-        case 2: {
-            setJoin((AmqpBoolean) value);
-            break;
-        }
-        case 3: {
-            setResume((AmqpBoolean) value);
-            break;
-        }
-        default : {
-            throw new IndexOutOfBoundsException(String.valueOf(index));
-        }
+        public final void setResume(AmqpBoolean resume) {
+            copyCheck();
+            bean.resume = resume;
         }
-    }
 
-    public AmqpType<?, ?> get(int index) {
-        switch(index) {
-        case 0: {
-            return bean.options;
-        }
-        case 1: {
-            return bean.xid;
-        }
-        case 2: {
-            return bean.join;
-        }
-        case 3: {
-            return bean.resume;
+        public final Boolean getResume() {
+            return bean.resume.getValue();
         }
-        default : {
-            throw new IndexOutOfBoundsException(String.valueOf(index));
+
+        public void set(int index, AmqpType<?, ?> value) {
+            switch(index) {
+            case 0: {
+                setOptions((AmqpOptions) value);
+                break;
+            }
+            case 1: {
+                setXid((AmqpXid) value);
+                break;
+            }
+            case 2: {
+                setJoin((AmqpBoolean) value);
+                break;
+            }
+            case 3: {
+                setResume((AmqpBoolean) value);
+                break;
+            }
+            default : {
+                throw new IndexOutOfBoundsException(String.valueOf(index));
+            }
+            }
         }
+
+        public AmqpType<?, ?> get(int index) {
+            switch(index) {
+            case 0: {
+                return bean.options;
+            }
+            case 1: {
+                return bean.xid;
+            }
+            case 2: {
+                return bean.join;
+            }
+            case 3: {
+                return bean.resume;
+            }
+            default : {
+                throw new IndexOutOfBoundsException(String.valueOf(index));
+            }
+            }
         }
-    }
 
-    public int getListCount() {
-        return 4;
-    }
+        public int getListCount() {
+            return 4;
+        }
 
-    public IAmqpList getValue() {
-        return bean;
-    }
+        public IAmqpList<AmqpType<?, ?>> getValue() {
+            return bean;
+        }
 
-    public Iterator<AmqpType<?, ?>> iterator() {
-        return new AmqpListIterator(bean);
-    }
+        public Iterator<AmqpType<?, ?>> iterator() {
+            return new AmqpListIterator<AmqpType<?, ?>>(bean);
+        }
 
 
-    private final void copyCheck() {
-        if(buffer != null) {;
-            throw new IllegalStateException("unwriteable");
+        private final void copyCheck() {
+            if(buffer != null) {;
+                throw new IllegalStateException("unwriteable");
+            }
+            if(bean != this) {;
+                copy(bean);
+            }
         }
-        if(bean != this) {;
-            copy(bean);
+
+        private final void copy(AmqpEnlist.AmqpEnlistBean other) {
+            bean = this;
         }
-    }
 
-    private final void copy(AmqpEnlist.AmqpEnlistBean other) {
-        bean = this;
-    }
+        public boolean equals(Object o){
+            if(this == o) {
+                return true;
+            }
 
-    public boolean equals(Object o){
-        if(this == o) {
-            return true;
-        }
+            if(o == null || !(o instanceof AmqpEnlist)) {
+                return false;
+            }
 
-        if(o == null || !(o instanceof AmqpEnlist)) {
-            return false;
+            return equals((AmqpEnlist) o);
         }
 
-        return equals((AmqpEnlist) o);
-    }
+        public boolean equals(AmqpEnlist b) {
 
-    public boolean equals(AmqpEnlist b) {
+            if(b.getOptions() == null ^ getOptions() == null) {
+                return false;
+            }
+            if(b.getOptions() != null && !b.getOptions().equals(getOptions())){ 
+                return false;
+            }
 
-        if(b.getOptions() == null ^ getOptions() == null) {
-            return false;
-        }
-        if(b.getOptions() != null && !b.getOptions().equals(getOptions())){ 
-            return false;
-        }
+            if(b.getXid() == null ^ getXid() == null) {
+                return false;
+            }
+            if(b.getXid() != null && !b.getXid().equals(getXid())){ 
+                return false;
+            }
 
-        if(b.getXid() == null ^ getXid() == null) {
-            return false;
-        }
-        if(b.getXid() != null && !b.getXid().equals(getXid())){ 
-            return false;
-        }
+            if(b.getJoin() == null ^ getJoin() == null) {
+                return false;
+            }
+            if(b.getJoin() != null && !b.getJoin().equals(getJoin())){ 
+                return false;
+            }
 
-        if(b.getJoin() == null ^ getJoin() == null) {
-            return false;
-        }
-        if(b.getJoin() != null && !b.getJoin().equals(getJoin())){ 
-            return false;
+            if(b.getResume() == null ^ getResume() == null) {
+                return false;
+            }
+            if(b.getResume() != null && !b.getResume().equals(getResume())){ 
+                return false;
+            }
+            return true;
         }
 
-        if(b.getResume() == null ^ getResume() == null) {
-            return false;
-        }
-        if(b.getResume() != null && !b.getResume().equals(getResume())){ 
-            return false;
+        public int hashCode() {
+            return AbstractAmqpList.hashCodeFor(this);
         }
-        return true;
     }
 
-    public int hashCode() {
-        return AbstractAmqpList.hashCodeFor(this);
-    }
-}
-
     public static class AmqpEnlistBuffer extends AmqpList.AmqpListBuffer implements AmqpEnlist{
 
         private AmqpEnlistBean bean;
 
-        protected AmqpEnlistBuffer(Encoded<IAmqpList> encoded) {
+        protected AmqpEnlistBuffer(Encoded<IAmqpList<AmqpType<?, ?>>> encoded) {
             super(encoded);
         }
 
@@ -434,10 +434,6 @@
             return bean().iterator();
         }
 
-        public IAmqpList getValue() {
-            return bean().getValue();
-        }
-
         public AmqpEnlist.AmqpEnlistBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
             return this;
         }
@@ -466,7 +462,7 @@
             return bean().hashCode();
         }
 
-        public static AmqpEnlist.AmqpEnlistBuffer create(Encoded<IAmqpList> encoded) {
+        public static AmqpEnlist.AmqpEnlistBuffer create(Encoded<IAmqpList<AmqpType<?, ?>>> encoded) {
             if(encoded.isNull()) {
                 return null;
             }

Modified: activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFilter.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFilter.java?rev=909704&r1=909703&r2=909704&view=diff
==============================================================================
--- activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFilter.java (original)
+++ activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFilter.java Sat Feb 13 03:20:16 2010
@@ -84,152 +84,152 @@
         AmqpFilterBean() {
         }
 
-        AmqpFilterBean(IAmqpList value) {
+        AmqpFilterBean(IAmqpList<AmqpType<?, ?>> value) {
 
-        for(int i = 0; i < value.getListCount(); i++) {
-            set(i, value.get(i));
+            for(int i = 0; i < value.getListCount(); i++) {
+                set(i, value.get(i));
+            }
         }
-    }
-
-    AmqpFilterBean(AmqpFilter.AmqpFilterBean other) {
-        this.bean = other;
-    }
-
-    public final AmqpFilterBean copy() {
-        return new AmqpFilter.AmqpFilterBean(bean);
-    }
 
-    public final AmqpFilter.AmqpFilterBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
-        if(buffer == null) {
-            buffer = new AmqpFilterBuffer(marshaller.encode(this));
+        AmqpFilterBean(AmqpFilter.AmqpFilterBean other) {
+            this.bean = other;
         }
-        return buffer;
-    }
-
-    public final void marshal(DataOutput out, AmqpMarshaller marshaller) throws IOException, AmqpEncodingError{
-        getBuffer(marshaller).marshal(out, marshaller);
-    }
-
 
-    public void setFilterType(String filterType) {
-        setFilterType(TypeFactory.createAmqpSymbol(filterType));
-    }
+        public final AmqpFilterBean copy() {
+            return new AmqpFilter.AmqpFilterBean(bean);
+        }
 
+        public final AmqpFilter.AmqpFilterBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
+            if(buffer == null) {
+                buffer = new AmqpFilterBuffer(marshaller.encode(this));
+            }
+            return buffer;
+        }
 
-    public final void setFilterType(AmqpSymbol filterType) {
-        copyCheck();
-        bean.filterType = filterType;
-    }
+        public final void marshal(DataOutput out, AmqpMarshaller marshaller) throws IOException, AmqpEncodingError{
+            getBuffer(marshaller).marshal(out, marshaller);
+        }
 
-    public final String getFilterType() {
-        return bean.filterType.getValue();
-    }
 
-    public final void setFilter(AmqpType<?, ?> filter) {
-        copyCheck();
-        bean.filter = filter;
-    }
+        public void setFilterType(String filterType) {
+            setFilterType(TypeFactory.createAmqpSymbol(filterType));
+        }
 
-    public final AmqpType<?, ?> getFilter() {
-        return bean.filter;
-    }
 
-    public void set(int index, AmqpType<?, ?> value) {
-        switch(index) {
-        case 0: {
-            setFilterType((AmqpSymbol) value);
-            break;
-        }
-        case 1: {
-            setFilter((AmqpType<?, ?>) value);
-            break;
-        }
-        default : {
-            throw new IndexOutOfBoundsException(String.valueOf(index));
+        public final void setFilterType(AmqpSymbol filterType) {
+            copyCheck();
+            bean.filterType = filterType;
         }
+
+        public final String getFilterType() {
+            return bean.filterType.getValue();
         }
-    }
 
-    public AmqpType<?, ?> get(int index) {
-        switch(index) {
-        case 0: {
-            return bean.filterType;
+        public final void setFilter(AmqpType<?, ?> filter) {
+            copyCheck();
+            bean.filter = filter;
         }
-        case 1: {
+
+        public final AmqpType<?, ?> getFilter() {
             return bean.filter;
         }
-        default : {
-            throw new IndexOutOfBoundsException(String.valueOf(index));
+
+        public void set(int index, AmqpType<?, ?> value) {
+            switch(index) {
+            case 0: {
+                setFilterType((AmqpSymbol) value);
+                break;
+            }
+            case 1: {
+                setFilter((AmqpType<?, ?>) value);
+                break;
+            }
+            default : {
+                throw new IndexOutOfBoundsException(String.valueOf(index));
+            }
+            }
         }
+
+        public AmqpType<?, ?> get(int index) {
+            switch(index) {
+            case 0: {
+                return bean.filterType;
+            }
+            case 1: {
+                return bean.filter;
+            }
+            default : {
+                throw new IndexOutOfBoundsException(String.valueOf(index));
+            }
+            }
         }
-    }
 
-    public int getListCount() {
-        return 2;
-    }
+        public int getListCount() {
+            return 2;
+        }
 
-    public IAmqpList getValue() {
-        return bean;
-    }
+        public IAmqpList<AmqpType<?, ?>> getValue() {
+            return bean;
+        }
 
-    public Iterator<AmqpType<?, ?>> iterator() {
-        return new AmqpListIterator(bean);
-    }
+        public Iterator<AmqpType<?, ?>> iterator() {
+            return new AmqpListIterator<AmqpType<?, ?>>(bean);
+        }
 
 
-    private final void copyCheck() {
-        if(buffer != null) {;
-            throw new IllegalStateException("unwriteable");
+        private final void copyCheck() {
+            if(buffer != null) {;
+                throw new IllegalStateException("unwriteable");
+            }
+            if(bean != this) {;
+                copy(bean);
+            }
         }
-        if(bean != this) {;
-            copy(bean);
+
+        private final void copy(AmqpFilter.AmqpFilterBean other) {
+            bean = this;
         }
-    }
 
-    private final void copy(AmqpFilter.AmqpFilterBean other) {
-        bean = this;
-    }
+        public boolean equals(Object o){
+            if(this == o) {
+                return true;
+            }
 
-    public boolean equals(Object o){
-        if(this == o) {
-            return true;
-        }
+            if(o == null || !(o instanceof AmqpFilter)) {
+                return false;
+            }
 
-        if(o == null || !(o instanceof AmqpFilter)) {
-            return false;
+            return equals((AmqpFilter) o);
         }
 
-        return equals((AmqpFilter) o);
-    }
+        public boolean equals(AmqpFilter b) {
 
-    public boolean equals(AmqpFilter b) {
+            if(b.getFilterType() == null ^ getFilterType() == null) {
+                return false;
+            }
+            if(b.getFilterType() != null && !b.getFilterType().equals(getFilterType())){ 
+                return false;
+            }
 
-        if(b.getFilterType() == null ^ getFilterType() == null) {
-            return false;
-        }
-        if(b.getFilterType() != null && !b.getFilterType().equals(getFilterType())){ 
-            return false;
+            if(b.getFilter() == null ^ getFilter() == null) {
+                return false;
+            }
+            if(b.getFilter() != null && !b.getFilter().equals(getFilter())){ 
+                return false;
+            }
+            return true;
         }
 
-        if(b.getFilter() == null ^ getFilter() == null) {
-            return false;
-        }
-        if(b.getFilter() != null && !b.getFilter().equals(getFilter())){ 
-            return false;
+        public int hashCode() {
+            return AbstractAmqpList.hashCodeFor(this);
         }
-        return true;
     }
 
-    public int hashCode() {
-        return AbstractAmqpList.hashCodeFor(this);
-    }
-}
-
     public static class AmqpFilterBuffer extends AmqpList.AmqpListBuffer implements AmqpFilter{
 
         private AmqpFilterBean bean;
 
-        protected AmqpFilterBuffer(Encoded<IAmqpList> encoded) {
+        protected AmqpFilterBuffer(Encoded<IAmqpList<AmqpType<?, ?>>> encoded) {
             super(encoded);
         }
 
@@ -269,10 +269,6 @@
             return bean().iterator();
         }
 
-        public IAmqpList getValue() {
-            return bean().getValue();
-        }
-
         public AmqpFilter.AmqpFilterBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
             return this;
         }
@@ -297,7 +293,7 @@
             return bean().hashCode();
         }
 
-        public static AmqpFilter.AmqpFilterBuffer create(Encoded<IAmqpList> encoded) {
+        public static AmqpFilter.AmqpFilterBuffer create(Encoded<IAmqpList<AmqpType<?, ?>>> encoded) {
             if(encoded.isNull()) {
                 return null;
             }

Modified: activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFilterSet.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFilterSet.java?rev=909704&r1=909703&r2=909704&view=diff
==============================================================================
--- activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFilterSet.java (original)
+++ activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFilterSet.java Sat Feb 13 03:20:16 2010
@@ -46,7 +46,7 @@
         private IAmqpMap<AmqpType<?, ?>, AmqpType<?, ?>> value;
 
         AmqpFilterSetBean() {
-            this.value = new IAmqpMap.AmqpWrapperMap<AmqpType<?,?>, AmqpType<?,?>>(new HashMap<AmqpType<?,?>, AmqpType<?,?>>());
+            this.value = new IAmqpMap.AmqpWrapperMap<AmqpType<?,?>,AmqpType<?,?>>(new HashMap<AmqpType<?,?>,AmqpType<?,?>>());
         }
 
         AmqpFilterSetBean(IAmqpMap<AmqpType<?, ?>, AmqpType<?, ?>> value) {
@@ -72,12 +72,12 @@
             getBuffer(marshaller).marshal(out, marshaller);
         }
 
-        public void put(AmqpType<?, ?> key, AmqpType<?, ?> value) {
+        public void put(AmqpType<?,?> key, AmqpType<?,?> value) {
             copyCheck();
             bean.value.put(key, value);
         }
 
-        public AmqpType<?, ?> get(Object key) {
+        public AmqpType<?,?> get(Object key) {
             return bean.value.get(key);
         }
 
@@ -85,14 +85,10 @@
             return bean.value.getEntryCount();
         }
 
-        public Iterator<Map.Entry<AmqpType<?, ?>, AmqpType<?, ?>>> iterator() {
+        public Iterator<Map.Entry<AmqpType<?,?>, AmqpType<?,?>>> iterator() {
             return bean.value.iterator();
         }
 
-        public IAmqpMap<AmqpType<?, ?>, AmqpType<?, ?>> getValue() {
-            return bean.value;
-        }
-
 
         private final void copyCheck() {
             if(buffer != null) {;
@@ -140,11 +136,11 @@
         protected AmqpFilterSetBuffer(Encoded<IAmqpMap<AmqpType<?, ?>, AmqpType<?, ?>>> encoded) {
             super(encoded);
         }
-        public void put(AmqpType<?, ?> key, AmqpType<?, ?> value) {
+        public void put(AmqpType<?,?> key, AmqpType<?,?> value) {
             bean().put(key, value);
         }
 
-        public AmqpType<?, ?> get(Object key) {
+        public AmqpType<?,?> get(Object key) {
             return bean().get(key);
         }
 
@@ -152,14 +148,10 @@
             return bean().getEntryCount();
         }
 
-        public Iterator<Map.Entry<AmqpType<?, ?>, AmqpType<?, ?>>> iterator() {
+        public Iterator<Map.Entry<AmqpType<?,?>, AmqpType<?,?>>> iterator() {
             return bean().iterator();
         }
 
-        public IAmqpMap<AmqpType<?, ?>, AmqpType<?, ?>> getValue() {
-            return bean().getValue();
-        }
-
         public AmqpFilterSet.AmqpFilterSetBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
             return this;
         }

Modified: activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFlow.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFlow.java?rev=909704&r1=909703&r2=909704&view=diff
==============================================================================
--- activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFlow.java (original)
+++ activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpFlow.java Sat Feb 13 03:20:16 2010
@@ -175,194 +175,194 @@
         AmqpFlowBean() {
         }
 
-        AmqpFlowBean(IAmqpList value) {
+        AmqpFlowBean(IAmqpList<AmqpType<?, ?>> value) {
 
-        for(int i = 0; i < value.getListCount(); i++) {
-            set(i, value.get(i));
+            for(int i = 0; i < value.getListCount(); i++) {
+                set(i, value.get(i));
+            }
         }
-    }
-
-    AmqpFlowBean(AmqpFlow.AmqpFlowBean other) {
-        this.bean = other;
-    }
 
-    public final AmqpFlowBean copy() {
-        return new AmqpFlow.AmqpFlowBean(bean);
-    }
-
-    public final void handle(AmqpCommandHandler handler) throws Exception {
-        handler.handleFlow(this);
-    }
+        AmqpFlowBean(AmqpFlow.AmqpFlowBean other) {
+            this.bean = other;
+        }
 
-    public final AmqpFlow.AmqpFlowBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
-        if(buffer == null) {
-            buffer = new AmqpFlowBuffer(marshaller.encode(this));
+        public final AmqpFlowBean copy() {
+            return new AmqpFlow.AmqpFlowBean(bean);
         }
-        return buffer;
-    }
 
-    public final void marshal(DataOutput out, AmqpMarshaller marshaller) throws IOException, AmqpEncodingError{
-        getBuffer(marshaller).marshal(out, marshaller);
-    }
+        public final void handle(AmqpCommandHandler handler) throws Exception {
+            handler.handleFlow(this);
+        }
 
+        public final AmqpFlow.AmqpFlowBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
+            if(buffer == null) {
+                buffer = new AmqpFlowBuffer(marshaller.encode(this));
+            }
+            return buffer;
+        }
 
-    public final void setOptions(AmqpOptions options) {
-        copyCheck();
-        bean.options = options;
-    }
+        public final void marshal(DataOutput out, AmqpMarshaller marshaller) throws IOException, AmqpEncodingError{
+            getBuffer(marshaller).marshal(out, marshaller);
+        }
 
-    public final AmqpOptions getOptions() {
-        return bean.options;
-    }
 
-    public void setHandle(Long handle) {
-        setHandle(TypeFactory.createAmqpHandle(handle));
-    }
+        public final void setOptions(AmqpOptions options) {
+            copyCheck();
+            bean.options = options;
+        }
 
+        public final AmqpOptions getOptions() {
+            return bean.options;
+        }
 
-    public void setHandle(long handle) {
-        setHandle(TypeFactory.createAmqpHandle(handle));
-    }
+        public void setHandle(Long handle) {
+            setHandle(TypeFactory.createAmqpHandle(handle));
+        }
 
 
-    public final void setHandle(AmqpHandle handle) {
-        copyCheck();
-        bean.handle = handle;
-    }
+        public void setHandle(long handle) {
+            setHandle(TypeFactory.createAmqpHandle(handle));
+        }
 
-    public final AmqpHandle getHandle() {
-        return bean.handle;
-    }
 
-    public void setLimit(Long limit) {
-        setLimit(TypeFactory.createAmqpSequenceNo(limit));
-    }
+        public final void setHandle(AmqpHandle handle) {
+            copyCheck();
+            bean.handle = handle;
+        }
 
+        public final AmqpHandle getHandle() {
+            return bean.handle;
+        }
 
-    public void setLimit(long limit) {
-        setLimit(TypeFactory.createAmqpSequenceNo(limit));
-    }
+        public void setLimit(Long limit) {
+            setLimit(TypeFactory.createAmqpSequenceNo(limit));
+        }
 
 
-    public final void setLimit(AmqpSequenceNo limit) {
-        copyCheck();
-        bean.limit = limit;
-    }
+        public void setLimit(long limit) {
+            setLimit(TypeFactory.createAmqpSequenceNo(limit));
+        }
 
-    public final AmqpSequenceNo getLimit() {
-        return bean.limit;
-    }
 
-    public void set(int index, AmqpType<?, ?> value) {
-        switch(index) {
-        case 0: {
-            setOptions((AmqpOptions) value);
-            break;
-        }
-        case 1: {
-            setHandle((AmqpHandle) value);
-            break;
-        }
-        case 2: {
-            setLimit((AmqpSequenceNo) value);
-            break;
-        }
-        default : {
-            throw new IndexOutOfBoundsException(String.valueOf(index));
-        }
+        public final void setLimit(AmqpSequenceNo limit) {
+            copyCheck();
+            bean.limit = limit;
         }
-    }
 
-    public AmqpType<?, ?> get(int index) {
-        switch(index) {
-        case 0: {
-            return bean.options;
-        }
-        case 1: {
-            return bean.handle;
-        }
-        case 2: {
+        public final AmqpSequenceNo getLimit() {
             return bean.limit;
         }
-        default : {
-            throw new IndexOutOfBoundsException(String.valueOf(index));
+
+        public void set(int index, AmqpType<?, ?> value) {
+            switch(index) {
+            case 0: {
+                setOptions((AmqpOptions) value);
+                break;
+            }
+            case 1: {
+                setHandle((AmqpHandle) value);
+                break;
+            }
+            case 2: {
+                setLimit((AmqpSequenceNo) value);
+                break;
+            }
+            default : {
+                throw new IndexOutOfBoundsException(String.valueOf(index));
+            }
+            }
         }
+
+        public AmqpType<?, ?> get(int index) {
+            switch(index) {
+            case 0: {
+                return bean.options;
+            }
+            case 1: {
+                return bean.handle;
+            }
+            case 2: {
+                return bean.limit;
+            }
+            default : {
+                throw new IndexOutOfBoundsException(String.valueOf(index));
+            }
+            }
         }
-    }
 
-    public int getListCount() {
-        return 3;
-    }
+        public int getListCount() {
+            return 3;
+        }
 
-    public IAmqpList getValue() {
-        return bean;
-    }
+        public IAmqpList<AmqpType<?, ?>> getValue() {
+            return bean;
+        }
 
-    public Iterator<AmqpType<?, ?>> iterator() {
-        return new AmqpListIterator(bean);
-    }
+        public Iterator<AmqpType<?, ?>> iterator() {
+            return new AmqpListIterator<AmqpType<?, ?>>(bean);
+        }
 
 
-    private final void copyCheck() {
-        if(buffer != null) {;
-            throw new IllegalStateException("unwriteable");
+        private final void copyCheck() {
+            if(buffer != null) {;
+                throw new IllegalStateException("unwriteable");
+            }
+            if(bean != this) {;
+                copy(bean);
+            }
         }
-        if(bean != this) {;
-            copy(bean);
+
+        private final void copy(AmqpFlow.AmqpFlowBean other) {
+            bean = this;
         }
-    }
 
-    private final void copy(AmqpFlow.AmqpFlowBean other) {
-        bean = this;
-    }
+        public boolean equals(Object o){
+            if(this == o) {
+                return true;
+            }
 
-    public boolean equals(Object o){
-        if(this == o) {
-            return true;
-        }
+            if(o == null || !(o instanceof AmqpFlow)) {
+                return false;
+            }
 
-        if(o == null || !(o instanceof AmqpFlow)) {
-            return false;
+            return equals((AmqpFlow) o);
         }
 
-        return equals((AmqpFlow) o);
-    }
+        public boolean equals(AmqpFlow b) {
 
-    public boolean equals(AmqpFlow b) {
+            if(b.getOptions() == null ^ getOptions() == null) {
+                return false;
+            }
+            if(b.getOptions() != null && !b.getOptions().equals(getOptions())){ 
+                return false;
+            }
 
-        if(b.getOptions() == null ^ getOptions() == null) {
-            return false;
-        }
-        if(b.getOptions() != null && !b.getOptions().equals(getOptions())){ 
-            return false;
-        }
+            if(b.getHandle() == null ^ getHandle() == null) {
+                return false;
+            }
+            if(b.getHandle() != null && !b.getHandle().equals(getHandle())){ 
+                return false;
+            }
 
-        if(b.getHandle() == null ^ getHandle() == null) {
-            return false;
-        }
-        if(b.getHandle() != null && !b.getHandle().equals(getHandle())){ 
-            return false;
+            if(b.getLimit() == null ^ getLimit() == null) {
+                return false;
+            }
+            if(b.getLimit() != null && !b.getLimit().equals(getLimit())){ 
+                return false;
+            }
+            return true;
         }
 
-        if(b.getLimit() == null ^ getLimit() == null) {
-            return false;
-        }
-        if(b.getLimit() != null && !b.getLimit().equals(getLimit())){ 
-            return false;
+        public int hashCode() {
+            return AbstractAmqpList.hashCodeFor(this);
         }
-        return true;
-    }
-
-    public int hashCode() {
-        return AbstractAmqpList.hashCodeFor(this);
     }
-}
 
     public static class AmqpFlowBuffer extends AmqpList.AmqpListBuffer implements AmqpFlow{
 
         private AmqpFlowBean bean;
 
-        protected AmqpFlowBuffer(Encoded<IAmqpList> encoded) {
+        protected AmqpFlowBuffer(Encoded<IAmqpList<AmqpType<?, ?>>> encoded) {
             super(encoded);
         }
 
@@ -424,10 +424,6 @@
             return bean().iterator();
         }
 
-        public IAmqpList getValue() {
-            return bean().getValue();
-        }
-
         public AmqpFlow.AmqpFlowBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
             return this;
         }
@@ -456,7 +452,7 @@
             return bean().hashCode();
         }
 
-        public static AmqpFlow.AmqpFlowBuffer create(Encoded<IAmqpList> encoded) {
+        public static AmqpFlow.AmqpFlowBuffer create(Encoded<IAmqpList<AmqpType<?, ?>>> encoded) {
             if(encoded.isNull()) {
                 return null;
             }



Mime
View raw message