activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cmacn...@apache.org
Subject svn commit: r909704 [9/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/AmqpSaslInit.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpSaslInit.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/AmqpSaslInit.java (original)
+++ activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpSaslInit.java Sat Feb 13 03:20:16 2010
@@ -118,180 +118,180 @@
         AmqpSaslInitBean() {
         }
 
-        AmqpSaslInitBean(IAmqpList value) {
+        AmqpSaslInitBean(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));
+            }
         }
-    }
-
-    AmqpSaslInitBean(AmqpSaslInit.AmqpSaslInitBean other) {
-        this.bean = other;
-    }
-
-    public final AmqpSaslInitBean copy() {
-        return new AmqpSaslInit.AmqpSaslInitBean(bean);
-    }
 
-    public final AmqpSaslInit.AmqpSaslInitBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
-        if(buffer == null) {
-            buffer = new AmqpSaslInitBuffer(marshaller.encode(this));
+        AmqpSaslInitBean(AmqpSaslInit.AmqpSaslInitBean other) {
+            this.bean = other;
         }
-        return buffer;
-    }
 
-    public final void marshal(DataOutput out, AmqpMarshaller marshaller) throws IOException, AmqpEncodingError{
-        getBuffer(marshaller).marshal(out, marshaller);
-    }
+        public final AmqpSaslInitBean copy() {
+            return new AmqpSaslInit.AmqpSaslInitBean(bean);
+        }
 
+        public final AmqpSaslInit.AmqpSaslInitBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
+            if(buffer == null) {
+                buffer = new AmqpSaslInitBuffer(marshaller.encode(this));
+            }
+            return buffer;
+        }
 
-    public final void setOptions(AmqpMap options) {
-        copyCheck();
-        bean.options = options;
-    }
+        public final void marshal(DataOutput out, AmqpMarshaller marshaller) throws IOException, AmqpEncodingError{
+            getBuffer(marshaller).marshal(out, marshaller);
+        }
 
-    public final IAmqpMap<AmqpType<?, ?>, AmqpType<?, ?>> getOptions() {
-        return bean.options.getValue();
-    }
 
-    public void setMechanism(String mechanism) {
-        setMechanism(TypeFactory.createAmqpString(mechanism));
-    }
+        public final void setOptions(AmqpMap options) {
+            copyCheck();
+            bean.options = options;
+        }
 
+        public final IAmqpMap<AmqpType<?, ?>, AmqpType<?, ?>> getOptions() {
+            return bean.options;
+        }
 
-    public final void setMechanism(AmqpString mechanism) {
-        copyCheck();
-        bean.mechanism = mechanism;
-    }
+        public void setMechanism(String mechanism) {
+            setMechanism(TypeFactory.createAmqpString(mechanism));
+        }
 
-    public final String getMechanism() {
-        return bean.mechanism.getValue();
-    }
 
-    public void setInitialResponse(Buffer initialResponse) {
-        setInitialResponse(TypeFactory.createAmqpBinary(initialResponse));
-    }
+        public final void setMechanism(AmqpString mechanism) {
+            copyCheck();
+            bean.mechanism = mechanism;
+        }
 
+        public final String getMechanism() {
+            return bean.mechanism.getValue();
+        }
 
-    public final void setInitialResponse(AmqpBinary initialResponse) {
-        copyCheck();
-        bean.initialResponse = initialResponse;
-    }
+        public void setInitialResponse(Buffer initialResponse) {
+            setInitialResponse(TypeFactory.createAmqpBinary(initialResponse));
+        }
 
-    public final Buffer getInitialResponse() {
-        return bean.initialResponse.getValue();
-    }
 
-    public void set(int index, AmqpType<?, ?> value) {
-        switch(index) {
-        case 0: {
-            setOptions((AmqpMap) value);
-            break;
-        }
-        case 1: {
-            setMechanism((AmqpString) value);
-            break;
-        }
-        case 2: {
-            setInitialResponse((AmqpBinary) value);
-            break;
-        }
-        default : {
-            throw new IndexOutOfBoundsException(String.valueOf(index));
-        }
+        public final void setInitialResponse(AmqpBinary initialResponse) {
+            copyCheck();
+            bean.initialResponse = initialResponse;
         }
-    }
 
-    public AmqpType<?, ?> get(int index) {
-        switch(index) {
-        case 0: {
-            return bean.options;
-        }
-        case 1: {
-            return bean.mechanism;
-        }
-        case 2: {
-            return bean.initialResponse;
+        public final Buffer getInitialResponse() {
+            return bean.initialResponse.getValue();
         }
-        default : {
-            throw new IndexOutOfBoundsException(String.valueOf(index));
+
+        public void set(int index, AmqpType<?, ?> value) {
+            switch(index) {
+            case 0: {
+                setOptions((AmqpMap) value);
+                break;
+            }
+            case 1: {
+                setMechanism((AmqpString) value);
+                break;
+            }
+            case 2: {
+                setInitialResponse((AmqpBinary) 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.mechanism;
+            }
+            case 2: {
+                return bean.initialResponse;
+            }
+            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(AmqpSaslInit.AmqpSaslInitBean other) {
+            bean = this;
         }
-    }
 
-    private final void copy(AmqpSaslInit.AmqpSaslInitBean 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 AmqpSaslInit)) {
+                return false;
+            }
 
-        if(o == null || !(o instanceof AmqpSaslInit)) {
-            return false;
+            return equals((AmqpSaslInit) o);
         }
 
-        return equals((AmqpSaslInit) o);
-    }
+        public boolean equals(AmqpSaslInit b) {
 
-    public boolean equals(AmqpSaslInit 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.getMechanism() == null ^ getMechanism() == null) {
+                return false;
+            }
+            if(b.getMechanism() != null && !b.getMechanism().equals(getMechanism())){ 
+                return false;
+            }
 
-        if(b.getMechanism() == null ^ getMechanism() == null) {
-            return false;
-        }
-        if(b.getMechanism() != null && !b.getMechanism().equals(getMechanism())){ 
-            return false;
+            if(b.getInitialResponse() == null ^ getInitialResponse() == null) {
+                return false;
+            }
+            if(b.getInitialResponse() != null && !b.getInitialResponse().equals(getInitialResponse())){ 
+                return false;
+            }
+            return true;
         }
 
-        if(b.getInitialResponse() == null ^ getInitialResponse() == null) {
-            return false;
-        }
-        if(b.getInitialResponse() != null && !b.getInitialResponse().equals(getInitialResponse())){ 
-            return false;
+        public int hashCode() {
+            return AbstractAmqpList.hashCodeFor(this);
         }
-        return true;
-    }
-
-    public int hashCode() {
-        return AbstractAmqpList.hashCodeFor(this);
     }
-}
 
     public static class AmqpSaslInitBuffer extends AmqpList.AmqpListBuffer implements AmqpSaslInit{
 
         private AmqpSaslInitBean bean;
 
-        protected AmqpSaslInitBuffer(Encoded<IAmqpList> encoded) {
+        protected AmqpSaslInitBuffer(Encoded<IAmqpList<AmqpType<?, ?>>> encoded) {
             super(encoded);
         }
 
@@ -343,10 +343,6 @@
             return bean().iterator();
         }
 
-        public IAmqpList getValue() {
-            return bean().getValue();
-        }
-
         public AmqpSaslInit.AmqpSaslInitBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
             return this;
         }
@@ -371,7 +367,7 @@
             return bean().hashCode();
         }
 
-        public static AmqpSaslInit.AmqpSaslInitBuffer create(Encoded<IAmqpList> encoded) {
+        public static AmqpSaslInit.AmqpSaslInitBuffer 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/AmqpSaslMechanisms.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpSaslMechanisms.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/AmqpSaslMechanisms.java (original)
+++ activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpSaslMechanisms.java Sat Feb 13 03:20:16 2010
@@ -64,7 +64,7 @@
      * absent. The server mechanisms are ordered in decreasing level of preference.
      * </p>
      */
-    public IAmqpList getSaslServerMechanisms();
+    public IAmqpList<AmqpType<?, ?>> getSaslServerMechanisms();
 
     public static class AmqpSaslMechanismsBean implements AmqpSaslMechanisms{
 
@@ -76,147 +76,147 @@
         AmqpSaslMechanismsBean() {
         }
 
-        AmqpSaslMechanismsBean(IAmqpList value) {
+        AmqpSaslMechanismsBean(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));
+            }
         }
-    }
 
-    AmqpSaslMechanismsBean(AmqpSaslMechanisms.AmqpSaslMechanismsBean other) {
-        this.bean = other;
-    }
-
-    public final AmqpSaslMechanismsBean copy() {
-        return new AmqpSaslMechanisms.AmqpSaslMechanismsBean(bean);
-    }
-
-    public final AmqpSaslMechanisms.AmqpSaslMechanismsBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
-        if(buffer == null) {
-            buffer = new AmqpSaslMechanismsBuffer(marshaller.encode(this));
+        AmqpSaslMechanismsBean(AmqpSaslMechanisms.AmqpSaslMechanismsBean other) {
+            this.bean = other;
         }
-        return buffer;
-    }
-
-    public final void marshal(DataOutput out, AmqpMarshaller marshaller) throws IOException, AmqpEncodingError{
-        getBuffer(marshaller).marshal(out, marshaller);
-    }
 
+        public final AmqpSaslMechanismsBean copy() {
+            return new AmqpSaslMechanisms.AmqpSaslMechanismsBean(bean);
+        }
 
-    public final void setOptions(AmqpMap options) {
-        copyCheck();
-        bean.options = options;
-    }
-
-    public final IAmqpMap<AmqpType<?, ?>, AmqpType<?, ?>> getOptions() {
-        return bean.options.getValue();
-    }
+        public final AmqpSaslMechanisms.AmqpSaslMechanismsBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
+            if(buffer == null) {
+                buffer = new AmqpSaslMechanismsBuffer(marshaller.encode(this));
+            }
+            return buffer;
+        }
 
-    public final void setSaslServerMechanisms(AmqpList saslServerMechanisms) {
-        copyCheck();
-        bean.saslServerMechanisms = saslServerMechanisms;
-    }
+        public final void marshal(DataOutput out, AmqpMarshaller marshaller) throws IOException, AmqpEncodingError{
+            getBuffer(marshaller).marshal(out, marshaller);
+        }
 
-    public final IAmqpList getSaslServerMechanisms() {
-        return bean.saslServerMechanisms.getValue();
-    }
 
-    public void set(int index, AmqpType<?, ?> value) {
-        switch(index) {
-        case 0: {
-            setOptions((AmqpMap) value);
-            break;
-        }
-        case 1: {
-            setSaslServerMechanisms((AmqpList) value);
-            break;
-        }
-        default : {
-            throw new IndexOutOfBoundsException(String.valueOf(index));
-        }
+        public final void setOptions(AmqpMap options) {
+            copyCheck();
+            bean.options = options;
         }
-    }
 
-    public AmqpType<?, ?> get(int index) {
-        switch(index) {
-        case 0: {
+        public final IAmqpMap<AmqpType<?, ?>, AmqpType<?, ?>> getOptions() {
             return bean.options;
         }
-        case 1: {
+
+        public final void setSaslServerMechanisms(AmqpList saslServerMechanisms) {
+            copyCheck();
+            bean.saslServerMechanisms = saslServerMechanisms;
+        }
+
+        public final IAmqpList<AmqpType<?, ?>> getSaslServerMechanisms() {
             return bean.saslServerMechanisms;
         }
-        default : {
-            throw new IndexOutOfBoundsException(String.valueOf(index));
+
+        public void set(int index, AmqpType<?, ?> value) {
+            switch(index) {
+            case 0: {
+                setOptions((AmqpMap) value);
+                break;
+            }
+            case 1: {
+                setSaslServerMechanisms((AmqpList) 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.saslServerMechanisms;
+            }
+            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(AmqpSaslMechanisms.AmqpSaslMechanismsBean other) {
+            bean = this;
         }
-    }
 
-    private final void copy(AmqpSaslMechanisms.AmqpSaslMechanismsBean 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 AmqpSaslMechanisms)) {
+                return false;
+            }
 
-        if(o == null || !(o instanceof AmqpSaslMechanisms)) {
-            return false;
+            return equals((AmqpSaslMechanisms) o);
         }
 
-        return equals((AmqpSaslMechanisms) o);
-    }
+        public boolean equals(AmqpSaslMechanisms b) {
 
-    public boolean equals(AmqpSaslMechanisms 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.getSaslServerMechanisms() == null ^ getSaslServerMechanisms() == null) {
+                return false;
+            }
+            if(b.getSaslServerMechanisms() != null && !b.getSaslServerMechanisms().equals(getSaslServerMechanisms())){ 
+                return false;
+            }
+            return true;
         }
 
-        if(b.getSaslServerMechanisms() == null ^ getSaslServerMechanisms() == null) {
-            return false;
-        }
-        if(b.getSaslServerMechanisms() != null && !b.getSaslServerMechanisms().equals(getSaslServerMechanisms())){ 
-            return false;
+        public int hashCode() {
+            return AbstractAmqpList.hashCodeFor(this);
         }
-        return true;
     }
 
-    public int hashCode() {
-        return AbstractAmqpList.hashCodeFor(this);
-    }
-}
-
     public static class AmqpSaslMechanismsBuffer extends AmqpList.AmqpListBuffer implements AmqpSaslMechanisms{
 
         private AmqpSaslMechanismsBean bean;
 
-        protected AmqpSaslMechanismsBuffer(Encoded<IAmqpList> encoded) {
+        protected AmqpSaslMechanismsBuffer(Encoded<IAmqpList<AmqpType<?, ?>>> encoded) {
             super(encoded);
         }
 
@@ -232,7 +232,7 @@
             bean().setSaslServerMechanisms(saslServerMechanisms);
         }
 
-        public final IAmqpList getSaslServerMechanisms() {
+        public final IAmqpList<AmqpType<?, ?>> getSaslServerMechanisms() {
             return bean().getSaslServerMechanisms();
         }
 
@@ -252,10 +252,6 @@
             return bean().iterator();
         }
 
-        public IAmqpList getValue() {
-            return bean().getValue();
-        }
-
         public AmqpSaslMechanisms.AmqpSaslMechanismsBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
             return this;
         }
@@ -280,7 +276,7 @@
             return bean().hashCode();
         }
 
-        public static AmqpSaslMechanisms.AmqpSaslMechanismsBuffer create(Encoded<IAmqpList> encoded) {
+        public static AmqpSaslMechanisms.AmqpSaslMechanismsBuffer 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/AmqpSaslOutcome.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpSaslOutcome.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/AmqpSaslOutcome.java (original)
+++ activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpSaslOutcome.java Sat Feb 13 03:20:16 2010
@@ -105,178 +105,178 @@
         AmqpSaslOutcomeBean() {
         }
 
-        AmqpSaslOutcomeBean(IAmqpList value) {
+        AmqpSaslOutcomeBean(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));
+            }
         }
-    }
-
-    AmqpSaslOutcomeBean(AmqpSaslOutcome.AmqpSaslOutcomeBean other) {
-        this.bean = other;
-    }
-
-    public final AmqpSaslOutcomeBean copy() {
-        return new AmqpSaslOutcome.AmqpSaslOutcomeBean(bean);
-    }
 
-    public final AmqpSaslOutcome.AmqpSaslOutcomeBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
-        if(buffer == null) {
-            buffer = new AmqpSaslOutcomeBuffer(marshaller.encode(this));
+        AmqpSaslOutcomeBean(AmqpSaslOutcome.AmqpSaslOutcomeBean other) {
+            this.bean = other;
         }
-        return buffer;
-    }
 
-    public final void marshal(DataOutput out, AmqpMarshaller marshaller) throws IOException, AmqpEncodingError{
-        getBuffer(marshaller).marshal(out, marshaller);
-    }
+        public final AmqpSaslOutcomeBean copy() {
+            return new AmqpSaslOutcome.AmqpSaslOutcomeBean(bean);
+        }
 
+        public final AmqpSaslOutcome.AmqpSaslOutcomeBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
+            if(buffer == null) {
+                buffer = new AmqpSaslOutcomeBuffer(marshaller.encode(this));
+            }
+            return buffer;
+        }
 
-    public final void setOptions(AmqpMap options) {
-        copyCheck();
-        bean.options = options;
-    }
+        public final void marshal(DataOutput out, AmqpMarshaller marshaller) throws IOException, AmqpEncodingError{
+            getBuffer(marshaller).marshal(out, marshaller);
+        }
 
-    public final IAmqpMap<AmqpType<?, ?>, AmqpType<?, ?>> getOptions() {
-        return bean.options.getValue();
-    }
 
-    public final void setCode(AmqpSaslCode code) {
-        copyCheck();
-        bean.code = code;
-    }
+        public final void setOptions(AmqpMap options) {
+            copyCheck();
+            bean.options = options;
+        }
 
-    public final AmqpSaslCode getCode() {
-        return bean.code;
-    }
+        public final IAmqpMap<AmqpType<?, ?>, AmqpType<?, ?>> getOptions() {
+            return bean.options;
+        }
 
-    public void setAdditionalData(Buffer additionalData) {
-        setAdditionalData(TypeFactory.createAmqpBinary(additionalData));
-    }
+        public final void setCode(AmqpSaslCode code) {
+            copyCheck();
+            bean.code = code;
+        }
 
+        public final AmqpSaslCode getCode() {
+            return bean.code;
+        }
 
-    public final void setAdditionalData(AmqpBinary additionalData) {
-        copyCheck();
-        bean.additionalData = additionalData;
-    }
+        public void setAdditionalData(Buffer additionalData) {
+            setAdditionalData(TypeFactory.createAmqpBinary(additionalData));
+        }
 
-    public final Buffer getAdditionalData() {
-        return bean.additionalData.getValue();
-    }
 
-    public void set(int index, AmqpType<?, ?> value) {
-        switch(index) {
-        case 0: {
-            setOptions((AmqpMap) value);
-            break;
-        }
-        case 1: {
-            setCode(AmqpSaslCode.get((AmqpUbyte)value));
-            break;
-        }
-        case 2: {
-            setAdditionalData((AmqpBinary) value);
-            break;
-        }
-        default : {
-            throw new IndexOutOfBoundsException(String.valueOf(index));
-        }
+        public final void setAdditionalData(AmqpBinary additionalData) {
+            copyCheck();
+            bean.additionalData = additionalData;
         }
-    }
 
-    public AmqpType<?, ?> get(int index) {
-        switch(index) {
-        case 0: {
-            return bean.options;
+        public final Buffer getAdditionalData() {
+            return bean.additionalData.getValue();
         }
-        case 1: {
-            if(code == null) {
-                return null;
+
+        public void set(int index, AmqpType<?, ?> value) {
+            switch(index) {
+            case 0: {
+                setOptions((AmqpMap) value);
+                break;
+            }
+            case 1: {
+                setCode(AmqpSaslCode.get((AmqpUbyte)value));
+                break;
+            }
+            case 2: {
+                setAdditionalData((AmqpBinary) value);
+                break;
+            }
+            default : {
+                throw new IndexOutOfBoundsException(String.valueOf(index));
+            }
             }
-            return code.getValue();
-        }
-        case 2: {
-            return bean.additionalData;
-        }
-        default : {
-            throw new IndexOutOfBoundsException(String.valueOf(index));
         }
+
+        public AmqpType<?, ?> get(int index) {
+            switch(index) {
+            case 0: {
+                return bean.options;
+            }
+            case 1: {
+                if(code == null) {
+                    return null;
+                }
+                return code.getValue();
+            }
+            case 2: {
+                return bean.additionalData;
+            }
+            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(AmqpSaslOutcome.AmqpSaslOutcomeBean other) {
+            bean = this;
         }
-    }
 
-    private final void copy(AmqpSaslOutcome.AmqpSaslOutcomeBean 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 AmqpSaslOutcome)) {
+                return false;
+            }
 
-        if(o == null || !(o instanceof AmqpSaslOutcome)) {
-            return false;
+            return equals((AmqpSaslOutcome) o);
         }
 
-        return equals((AmqpSaslOutcome) o);
-    }
+        public boolean equals(AmqpSaslOutcome b) {
 
-    public boolean equals(AmqpSaslOutcome 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.getCode() == null ^ getCode() == null) {
+                return false;
+            }
+            if(b.getCode() != null && !b.getCode().equals(getCode())){ 
+                return false;
+            }
 
-        if(b.getCode() == null ^ getCode() == null) {
-            return false;
-        }
-        if(b.getCode() != null && !b.getCode().equals(getCode())){ 
-            return false;
+            if(b.getAdditionalData() == null ^ getAdditionalData() == null) {
+                return false;
+            }
+            if(b.getAdditionalData() != null && !b.getAdditionalData().equals(getAdditionalData())){ 
+                return false;
+            }
+            return true;
         }
 
-        if(b.getAdditionalData() == null ^ getAdditionalData() == null) {
-            return false;
-        }
-        if(b.getAdditionalData() != null && !b.getAdditionalData().equals(getAdditionalData())){ 
-            return false;
+        public int hashCode() {
+            return AbstractAmqpList.hashCodeFor(this);
         }
-        return true;
-    }
-
-    public int hashCode() {
-        return AbstractAmqpList.hashCodeFor(this);
     }
-}
 
     public static class AmqpSaslOutcomeBuffer extends AmqpList.AmqpListBuffer implements AmqpSaslOutcome{
 
         private AmqpSaslOutcomeBean bean;
 
-        protected AmqpSaslOutcomeBuffer(Encoded<IAmqpList> encoded) {
+        protected AmqpSaslOutcomeBuffer(Encoded<IAmqpList<AmqpType<?, ?>>> encoded) {
             super(encoded);
         }
 
@@ -324,10 +324,6 @@
             return bean().iterator();
         }
 
-        public IAmqpList getValue() {
-            return bean().getValue();
-        }
-
         public AmqpSaslOutcome.AmqpSaslOutcomeBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
             return this;
         }
@@ -352,7 +348,7 @@
             return bean().hashCode();
         }
 
-        public static AmqpSaslOutcome.AmqpSaslOutcomeBuffer create(Encoded<IAmqpList> encoded) {
+        public static AmqpSaslOutcome.AmqpSaslOutcomeBuffer 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/AmqpSaslResponse.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpSaslResponse.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/AmqpSaslResponse.java (original)
+++ activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpSaslResponse.java Sat Feb 13 03:20:16 2010
@@ -83,152 +83,152 @@
         AmqpSaslResponseBean() {
         }
 
-        AmqpSaslResponseBean(IAmqpList value) {
+        AmqpSaslResponseBean(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));
+            }
         }
-    }
-
-    AmqpSaslResponseBean(AmqpSaslResponse.AmqpSaslResponseBean other) {
-        this.bean = other;
-    }
-
-    public final AmqpSaslResponseBean copy() {
-        return new AmqpSaslResponse.AmqpSaslResponseBean(bean);
-    }
 
-    public final AmqpSaslResponse.AmqpSaslResponseBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
-        if(buffer == null) {
-            buffer = new AmqpSaslResponseBuffer(marshaller.encode(this));
+        AmqpSaslResponseBean(AmqpSaslResponse.AmqpSaslResponseBean other) {
+            this.bean = other;
         }
-        return buffer;
-    }
 
-    public final void marshal(DataOutput out, AmqpMarshaller marshaller) throws IOException, AmqpEncodingError{
-        getBuffer(marshaller).marshal(out, marshaller);
-    }
+        public final AmqpSaslResponseBean copy() {
+            return new AmqpSaslResponse.AmqpSaslResponseBean(bean);
+        }
 
+        public final AmqpSaslResponse.AmqpSaslResponseBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
+            if(buffer == null) {
+                buffer = new AmqpSaslResponseBuffer(marshaller.encode(this));
+            }
+            return buffer;
+        }
 
-    public final void setOptions(AmqpMap options) {
-        copyCheck();
-        bean.options = options;
-    }
+        public final void marshal(DataOutput out, AmqpMarshaller marshaller) throws IOException, AmqpEncodingError{
+            getBuffer(marshaller).marshal(out, marshaller);
+        }
 
-    public final IAmqpMap<AmqpType<?, ?>, AmqpType<?, ?>> getOptions() {
-        return bean.options.getValue();
-    }
 
-    public void setResponse(Buffer response) {
-        setResponse(TypeFactory.createAmqpBinary(response));
-    }
+        public final void setOptions(AmqpMap options) {
+            copyCheck();
+            bean.options = options;
+        }
 
+        public final IAmqpMap<AmqpType<?, ?>, AmqpType<?, ?>> getOptions() {
+            return bean.options;
+        }
 
-    public final void setResponse(AmqpBinary response) {
-        copyCheck();
-        bean.response = response;
-    }
+        public void setResponse(Buffer response) {
+            setResponse(TypeFactory.createAmqpBinary(response));
+        }
 
-    public final Buffer getResponse() {
-        return bean.response.getValue();
-    }
 
-    public void set(int index, AmqpType<?, ?> value) {
-        switch(index) {
-        case 0: {
-            setOptions((AmqpMap) value);
-            break;
-        }
-        case 1: {
-            setResponse((AmqpBinary) value);
-            break;
-        }
-        default : {
-            throw new IndexOutOfBoundsException(String.valueOf(index));
-        }
+        public final void setResponse(AmqpBinary response) {
+            copyCheck();
+            bean.response = response;
         }
-    }
 
-    public AmqpType<?, ?> get(int index) {
-        switch(index) {
-        case 0: {
-            return bean.options;
-        }
-        case 1: {
-            return bean.response;
+        public final Buffer getResponse() {
+            return bean.response.getValue();
         }
-        default : {
-            throw new IndexOutOfBoundsException(String.valueOf(index));
+
+        public void set(int index, AmqpType<?, ?> value) {
+            switch(index) {
+            case 0: {
+                setOptions((AmqpMap) value);
+                break;
+            }
+            case 1: {
+                setResponse((AmqpBinary) 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.response;
+            }
+            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(AmqpSaslResponse.AmqpSaslResponseBean other) {
+            bean = this;
         }
-    }
 
-    private final void copy(AmqpSaslResponse.AmqpSaslResponseBean 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 AmqpSaslResponse)) {
+                return false;
+            }
 
-        if(o == null || !(o instanceof AmqpSaslResponse)) {
-            return false;
+            return equals((AmqpSaslResponse) o);
         }
 
-        return equals((AmqpSaslResponse) o);
-    }
+        public boolean equals(AmqpSaslResponse b) {
 
-    public boolean equals(AmqpSaslResponse 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.getResponse() == null ^ getResponse() == null) {
+                return false;
+            }
+            if(b.getResponse() != null && !b.getResponse().equals(getResponse())){ 
+                return false;
+            }
+            return true;
         }
 
-        if(b.getResponse() == null ^ getResponse() == null) {
-            return false;
-        }
-        if(b.getResponse() != null && !b.getResponse().equals(getResponse())){ 
-            return false;
+        public int hashCode() {
+            return AbstractAmqpList.hashCodeFor(this);
         }
-        return true;
     }
 
-    public int hashCode() {
-        return AbstractAmqpList.hashCodeFor(this);
-    }
-}
-
     public static class AmqpSaslResponseBuffer extends AmqpList.AmqpListBuffer implements AmqpSaslResponse{
 
         private AmqpSaslResponseBean bean;
 
-        protected AmqpSaslResponseBuffer(Encoded<IAmqpList> encoded) {
+        protected AmqpSaslResponseBuffer(Encoded<IAmqpList<AmqpType<?, ?>>> encoded) {
             super(encoded);
         }
 
@@ -268,10 +268,6 @@
             return bean().iterator();
         }
 
-        public IAmqpList getValue() {
-            return bean().getValue();
-        }
-
         public AmqpSaslResponse.AmqpSaslResponseBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
             return this;
         }
@@ -296,7 +292,7 @@
             return bean().hashCode();
         }
 
-        public static AmqpSaslResponse.AmqpSaslResponseBuffer create(Encoded<IAmqpList> encoded) {
+        public static AmqpSaslResponse.AmqpSaslResponseBuffer 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/AmqpSessionError.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpSessionError.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/AmqpSessionError.java (original)
+++ activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpSessionError.java Sat Feb 13 03:20:16 2010
@@ -211,277 +211,277 @@
         AmqpSessionErrorBean() {
         }
 
-        AmqpSessionErrorBean(IAmqpList value) {
+        AmqpSessionErrorBean(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));
+            }
         }
-    }
-
-    AmqpSessionErrorBean(AmqpSessionError.AmqpSessionErrorBean other) {
-        this.bean = other;
-    }
-
-    public final AmqpSessionErrorBean copy() {
-        return new AmqpSessionError.AmqpSessionErrorBean(bean);
-    }
 
-    public final AmqpSessionError.AmqpSessionErrorBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
-        if(buffer == null) {
-            buffer = new AmqpSessionErrorBuffer(marshaller.encode(this));
+        AmqpSessionErrorBean(AmqpSessionError.AmqpSessionErrorBean other) {
+            this.bean = other;
         }
-        return buffer;
-    }
-
-    public final void marshal(DataOutput out, AmqpMarshaller marshaller) throws IOException, AmqpEncodingError{
-        getBuffer(marshaller).marshal(out, marshaller);
-    }
-
 
-    public final void setErrorCode(AmqpSessionErrorCode errorCode) {
-        copyCheck();
-        bean.errorCode = errorCode;
-    }
+        public final AmqpSessionErrorBean copy() {
+            return new AmqpSessionError.AmqpSessionErrorBean(bean);
+        }
 
-    public final AmqpSessionErrorCode getErrorCode() {
-        return bean.errorCode;
-    }
+        public final AmqpSessionError.AmqpSessionErrorBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
+            if(buffer == null) {
+                buffer = new AmqpSessionErrorBuffer(marshaller.encode(this));
+            }
+            return buffer;
+        }
 
-    public void setCommandId(Long commandId) {
-        setCommandId(TypeFactory.createAmqpSequenceNo(commandId));
-    }
+        public final void marshal(DataOutput out, AmqpMarshaller marshaller) throws IOException, AmqpEncodingError{
+            getBuffer(marshaller).marshal(out, marshaller);
+        }
 
 
-    public void setCommandId(long commandId) {
-        setCommandId(TypeFactory.createAmqpSequenceNo(commandId));
-    }
+        public final void setErrorCode(AmqpSessionErrorCode errorCode) {
+            copyCheck();
+            bean.errorCode = errorCode;
+        }
 
+        public final AmqpSessionErrorCode getErrorCode() {
+            return bean.errorCode;
+        }
 
-    public final void setCommandId(AmqpSequenceNo commandId) {
-        copyCheck();
-        bean.commandId = commandId;
-    }
+        public void setCommandId(Long commandId) {
+            setCommandId(TypeFactory.createAmqpSequenceNo(commandId));
+        }
 
-    public final AmqpSequenceNo getCommandId() {
-        return bean.commandId;
-    }
 
-    public void setCommandCode(Short commandCode) {
-        setCommandCode(TypeFactory.createAmqpUbyte(commandCode));
-    }
+        public void setCommandId(long commandId) {
+            setCommandId(TypeFactory.createAmqpSequenceNo(commandId));
+        }
 
 
-    public void setCommandCode(short commandCode) {
-        setCommandCode(TypeFactory.createAmqpUbyte(commandCode));
-    }
+        public final void setCommandId(AmqpSequenceNo commandId) {
+            copyCheck();
+            bean.commandId = commandId;
+        }
 
+        public final AmqpSequenceNo getCommandId() {
+            return bean.commandId;
+        }
 
-    public final void setCommandCode(AmqpUbyte commandCode) {
-        copyCheck();
-        bean.commandCode = commandCode;
-    }
+        public void setCommandCode(Short commandCode) {
+            setCommandCode(TypeFactory.createAmqpUbyte(commandCode));
+        }
 
-    public final Short getCommandCode() {
-        return bean.commandCode.getValue();
-    }
 
-    public void setFieldIndex(Short fieldIndex) {
-        setFieldIndex(TypeFactory.createAmqpUbyte(fieldIndex));
-    }
+        public void setCommandCode(short commandCode) {
+            setCommandCode(TypeFactory.createAmqpUbyte(commandCode));
+        }
 
 
-    public void setFieldIndex(short fieldIndex) {
-        setFieldIndex(TypeFactory.createAmqpUbyte(fieldIndex));
-    }
+        public final void setCommandCode(AmqpUbyte commandCode) {
+            copyCheck();
+            bean.commandCode = commandCode;
+        }
 
+        public final Short getCommandCode() {
+            return bean.commandCode.getValue();
+        }
 
-    public final void setFieldIndex(AmqpUbyte fieldIndex) {
-        copyCheck();
-        bean.fieldIndex = fieldIndex;
-    }
+        public void setFieldIndex(Short fieldIndex) {
+            setFieldIndex(TypeFactory.createAmqpUbyte(fieldIndex));
+        }
 
-    public final Short getFieldIndex() {
-        return bean.fieldIndex.getValue();
-    }
 
-    public void setDescription(String description) {
-        setDescription(TypeFactory.createAmqpString(description));
-    }
+        public void setFieldIndex(short fieldIndex) {
+            setFieldIndex(TypeFactory.createAmqpUbyte(fieldIndex));
+        }
 
 
-    public final void setDescription(AmqpString description) {
-        copyCheck();
-        bean.description = description;
-    }
+        public final void setFieldIndex(AmqpUbyte fieldIndex) {
+            copyCheck();
+            bean.fieldIndex = fieldIndex;
+        }
 
-    public final String getDescription() {
-        return bean.description.getValue();
-    }
+        public final Short getFieldIndex() {
+            return bean.fieldIndex.getValue();
+        }
 
-    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(AmqpSessionErrorCode.get((AmqpUshort)value));
-            break;
-        }
-        case 1: {
-            setCommandId((AmqpSequenceNo) value);
-            break;
-        }
-        case 2: {
-            setCommandCode((AmqpUbyte) value);
-            break;
-        }
-        case 3: {
-            setFieldIndex((AmqpUbyte) value);
-            break;
-        }
-        case 4: {
-            setDescription((AmqpString) value);
-            break;
-        }
-        case 5: {
-            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();
-        }
-        case 1: {
-            return bean.commandId;
-        }
-        case 2: {
-            return bean.commandCode;
-        }
-        case 3: {
-            return bean.fieldIndex;
+        public final String getDescription() {
+            return bean.description.getValue();
         }
-        case 4: {
-            return bean.description;
+
+        public final void setErrorInfo(AmqpMap errorInfo) {
+            copyCheck();
+            bean.errorInfo = errorInfo;
         }
-        case 5: {
+
+        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(AmqpSessionErrorCode.get((AmqpUshort)value));
+                break;
+            }
+            case 1: {
+                setCommandId((AmqpSequenceNo) value);
+                break;
+            }
+            case 2: {
+                setCommandCode((AmqpUbyte) value);
+                break;
+            }
+            case 3: {
+                setFieldIndex((AmqpUbyte) value);
+                break;
+            }
+            case 4: {
+                setDescription((AmqpString) value);
+                break;
+            }
+            case 5: {
+                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.commandId;
+            }
+            case 2: {
+                return bean.commandCode;
+            }
+            case 3: {
+                return bean.fieldIndex;
+            }
+            case 4: {
+                return bean.description;
+            }
+            case 5: {
+                return bean.errorInfo;
+            }
+            default : {
+                throw new IndexOutOfBoundsException(String.valueOf(index));
+            }
+            }
         }
-    }
 
-    public int getListCount() {
-        return 6;
-    }
+        public int getListCount() {
+            return 6;
+        }
 
-    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(AmqpSessionError.AmqpSessionErrorBean other) {
+            bean = this;
         }
-    }
 
-    private final void copy(AmqpSessionError.AmqpSessionErrorBean 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 AmqpSessionError)) {
+                return false;
+            }
 
-        if(o == null || !(o instanceof AmqpSessionError)) {
-            return false;
+            return equals((AmqpSessionError) o);
         }
 
-        return equals((AmqpSessionError) o);
-    }
+        public boolean equals(AmqpSessionError b) {
 
-    public boolean equals(AmqpSessionError 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.getCommandId() == null ^ getCommandId() == null) {
+                return false;
+            }
+            if(b.getCommandId() != null && !b.getCommandId().equals(getCommandId())){ 
+                return false;
+            }
 
-        if(b.getCommandId() == null ^ getCommandId() == null) {
-            return false;
-        }
-        if(b.getCommandId() != null && !b.getCommandId().equals(getCommandId())){ 
-            return false;
-        }
+            if(b.getCommandCode() == null ^ getCommandCode() == null) {
+                return false;
+            }
+            if(b.getCommandCode() != null && !b.getCommandCode().equals(getCommandCode())){ 
+                return false;
+            }
 
-        if(b.getCommandCode() == null ^ getCommandCode() == null) {
-            return false;
-        }
-        if(b.getCommandCode() != null && !b.getCommandCode().equals(getCommandCode())){ 
-            return false;
-        }
+            if(b.getFieldIndex() == null ^ getFieldIndex() == null) {
+                return false;
+            }
+            if(b.getFieldIndex() != null && !b.getFieldIndex().equals(getFieldIndex())){ 
+                return false;
+            }
 
-        if(b.getFieldIndex() == null ^ getFieldIndex() == null) {
-            return false;
-        }
-        if(b.getFieldIndex() != null && !b.getFieldIndex().equals(getFieldIndex())){ 
-            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 AmqpSessionErrorBuffer extends AmqpList.AmqpListBuffer implements AmqpSessionError{
 
         private AmqpSessionErrorBean bean;
 
-        protected AmqpSessionErrorBuffer(Encoded<IAmqpList> encoded) {
+        protected AmqpSessionErrorBuffer(Encoded<IAmqpList<AmqpType<?, ?>>> encoded) {
             super(encoded);
         }
 
@@ -580,10 +580,6 @@
             return bean().iterator();
         }
 
-        public IAmqpList getValue() {
-            return bean().getValue();
-        }
-
         public AmqpSessionError.AmqpSessionErrorBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
             return this;
         }
@@ -608,7 +604,7 @@
             return bean().hashCode();
         }
 
-        public static AmqpSessionError.AmqpSessionErrorBuffer create(Encoded<IAmqpList> encoded) {
+        public static AmqpSessionError.AmqpSessionErrorBuffer 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/AmqpSource.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpSource.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/AmqpSource.java (original)
+++ activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpSource.java Sat Feb 13 03:20:16 2010
@@ -266,7 +266,7 @@
      * state.
      * </p>
      */
-    public IAmqpList getMessageStates();
+    public IAmqpList<AmqpType<?, ?>> getMessageStates();
 
     /**
      * disposition for unacked Messages
@@ -298,7 +298,7 @@
         private IAmqpMap<AmqpType<?, ?>, AmqpType<?, ?>> value;
 
         AmqpSourceBean() {
-            this.value = new IAmqpMap.AmqpWrapperMap<AmqpType<?,?>, AmqpType<?,?>>(new HashMap<AmqpType<?,?>, AmqpType<?,?>>());
+            this.value = new IAmqpMap.AmqpWrapperMap<AmqpType<?,?>,AmqpType<?,?>>(new HashMap<AmqpType<?,?>,AmqpType<?,?>>());
         }
 
         AmqpSourceBean(IAmqpMap<AmqpType<?, ?>, AmqpType<?, ?>> value) {
@@ -400,8 +400,8 @@
             bean.messageStates = messageStates;
         }
 
-        public final IAmqpList getMessageStates() {
-            return bean.messageStates.getValue();
+        public final IAmqpList<AmqpType<?, ?>> getMessageStates() {
+            return bean.messageStates;
         }
 
         public final void setOrphanDisposition(AmqpMap orphanDisposition) {
@@ -410,14 +410,14 @@
         }
 
         public final IAmqpMap<AmqpType<?, ?>, AmqpType<?, ?>> getOrphanDisposition() {
-            return bean.orphanDisposition.getValue();
+            return bean.orphanDisposition;
         }
-        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);
         }
 
@@ -425,14 +425,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) {;
@@ -591,7 +587,7 @@
             bean().setMessageStates(messageStates);
         }
 
-        public final IAmqpList getMessageStates() {
+        public final IAmqpList<AmqpType<?, ?>> getMessageStates() {
             return bean().getMessageStates();
         }
 
@@ -602,11 +598,11 @@
         public final IAmqpMap<AmqpType<?, ?>, AmqpType<?, ?>> getOrphanDisposition() {
             return bean().getOrphanDisposition();
         }
-        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);
         }
 
@@ -614,14 +610,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 AmqpSource.AmqpSourceBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
             return this;
         }

Modified: activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpTarget.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpTarget.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/AmqpTarget.java (original)
+++ activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpTarget.java Sat Feb 13 03:20:16 2010
@@ -220,7 +220,7 @@
         private IAmqpMap<AmqpType<?, ?>, AmqpType<?, ?>> value;
 
         AmqpTargetBean() {
-            this.value = new IAmqpMap.AmqpWrapperMap<AmqpType<?,?>, AmqpType<?,?>>(new HashMap<AmqpType<?,?>, AmqpType<?,?>>());
+            this.value = new IAmqpMap.AmqpWrapperMap<AmqpType<?,?>,AmqpType<?,?>>(new HashMap<AmqpType<?,?>,AmqpType<?,?>>());
         }
 
         AmqpTargetBean(IAmqpMap<AmqpType<?, ?>, AmqpType<?, ?>> value) {
@@ -298,12 +298,12 @@
         public final Long getTimeout() {
             return bean.timeout.getValue();
         }
-        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);
         }
 
@@ -311,14 +311,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) {;
@@ -428,11 +424,11 @@
         public final Long getTimeout() {
             return bean().getTimeout();
         }
-        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);
         }
 
@@ -440,14 +436,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 AmqpTarget.AmqpTargetBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
             return this;
         }

Modified: activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpTransfer.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpTransfer.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/AmqpTransfer.java (original)
+++ activemq/sandbox/activemq-apollo-actor/activemq-amqp/src/main/java/org/apache/activemq/amqp/protocol/types/AmqpTransfer.java Sat Feb 13 03:20:16 2010
@@ -178,7 +178,7 @@
 
     public void setFragments(AmqpList fragments);
 
-    public IAmqpList getFragments();
+    public IAmqpList<AmqpType<?, ?>> getFragments();
 
     public static class AmqpTransferBean implements AmqpTransfer{
 
@@ -194,278 +194,278 @@
         AmqpTransferBean() {
         }
 
-        AmqpTransferBean(IAmqpList value) {
+        AmqpTransferBean(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));
+            }
         }
-    }
-
-    AmqpTransferBean(AmqpTransfer.AmqpTransferBean other) {
-        this.bean = other;
-    }
-
-    public final AmqpTransferBean copy() {
-        return new AmqpTransfer.AmqpTransferBean(bean);
-    }
-
-    public final void handle(AmqpCommandHandler handler) throws Exception {
-        handler.handleTransfer(this);
-    }
 
-    public final AmqpTransfer.AmqpTransferBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
-        if(buffer == null) {
-            buffer = new AmqpTransferBuffer(marshaller.encode(this));
+        AmqpTransferBean(AmqpTransfer.AmqpTransferBean other) {
+            this.bean = other;
         }
-        return buffer;
-    }
-
-    public final void marshal(DataOutput out, AmqpMarshaller marshaller) throws IOException, AmqpEncodingError{
-        getBuffer(marshaller).marshal(out, marshaller);
-    }
 
+        public final AmqpTransferBean copy() {
+            return new AmqpTransfer.AmqpTransferBean(bean);
+        }
 
-    public final void setOptions(AmqpOptions options) {
-        copyCheck();
-        bean.options = options;
-    }
+        public final void handle(AmqpCommandHandler handler) throws Exception {
+            handler.handleTransfer(this);
+        }
 
-    public final AmqpOptions getOptions() {
-        return bean.options;
-    }
+        public final AmqpTransfer.AmqpTransferBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
+            if(buffer == null) {
+                buffer = new AmqpTransferBuffer(marshaller.encode(this));
+            }
+            return buffer;
+        }
 
-    public void setHandle(Long handle) {
-        setHandle(TypeFactory.createAmqpHandle(handle));
-    }
+        public final void marshal(DataOutput out, AmqpMarshaller marshaller) throws IOException, AmqpEncodingError{
+            getBuffer(marshaller).marshal(out, marshaller);
+        }
 
 
-    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 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 setDeliveryTag(Buffer deliveryTag) {
-        setDeliveryTag(TypeFactory.createAmqpDeliveryTag(deliveryTag));
-    }
+        public void setHandle(long handle) {
+            setHandle(TypeFactory.createAmqpHandle(handle));
+        }
 
 
-    public final void setDeliveryTag(AmqpDeliveryTag deliveryTag) {
-        copyCheck();
-        bean.deliveryTag = deliveryTag;
-    }
+        public final void setHandle(AmqpHandle handle) {
+            copyCheck();
+            bean.handle = handle;
+        }
 
-    public final AmqpDeliveryTag getDeliveryTag() {
-        return bean.deliveryTag;
-    }
+        public final AmqpHandle getHandle() {
+            return bean.handle;
+        }
 
-    public void setMore(Boolean more) {
-        setMore(TypeFactory.createAmqpBoolean(more));
-    }
+        public void setDeliveryTag(Buffer deliveryTag) {
+            setDeliveryTag(TypeFactory.createAmqpDeliveryTag(deliveryTag));
+        }
 
 
-    public void setMore(boolean more) {
-        setMore(TypeFactory.createAmqpBoolean(more));
-    }
+        public final void setDeliveryTag(AmqpDeliveryTag deliveryTag) {
+            copyCheck();
+            bean.deliveryTag = deliveryTag;
+        }
 
+        public final AmqpDeliveryTag getDeliveryTag() {
+            return bean.deliveryTag;
+        }
 
-    public final void setMore(AmqpBoolean more) {
-        copyCheck();
-        bean.more = more;
-    }
+        public void setMore(Boolean more) {
+            setMore(TypeFactory.createAmqpBoolean(more));
+        }
 
-    public final Boolean getMore() {
-        return bean.more.getValue();
-    }
 
-    public void setAborted(Boolean aborted) {
-        setAborted(TypeFactory.createAmqpBoolean(aborted));
-    }
+        public void setMore(boolean more) {
+            setMore(TypeFactory.createAmqpBoolean(more));
+        }
 
 
-    public void setAborted(boolean aborted) {
-        setAborted(TypeFactory.createAmqpBoolean(aborted));
-    }
+        public final void setMore(AmqpBoolean more) {
+            copyCheck();
+            bean.more = more;
+        }
 
+        public final Boolean getMore() {
+            return bean.more.getValue();
+        }
 
-    public final void setAborted(AmqpBoolean aborted) {
-        copyCheck();
-        bean.aborted = aborted;
-    }
+        public void setAborted(Boolean aborted) {
+            setAborted(TypeFactory.createAmqpBoolean(aborted));
+        }
 
-    public final Boolean getAborted() {
-        return bean.aborted.getValue();
-    }
 
-    public final void setFragments(AmqpList fragments) {
-        copyCheck();
-        bean.fragments = fragments;
-    }
+        public void setAborted(boolean aborted) {
+            setAborted(TypeFactory.createAmqpBoolean(aborted));
+        }
 
-    public final IAmqpList getFragments() {
-        return bean.fragments.getValue();
-    }
 
-    public void set(int index, AmqpType<?, ?> value) {
-        switch(index) {
-        case 0: {
-            setOptions((AmqpOptions) value);
-            break;
-        }
-        case 1: {
-            setHandle((AmqpHandle) value);
-            break;
-        }
-        case 2: {
-            setDeliveryTag((AmqpDeliveryTag) value);
-            break;
-        }
-        case 3: {
-            setMore((AmqpBoolean) value);
-            break;
-        }
-        case 4: {
-            setAborted((AmqpBoolean) value);
-            break;
-        }
-        case 5: {
-            setFragments((AmqpList) value);
-            break;
-        }
-        default : {
-            throw new IndexOutOfBoundsException(String.valueOf(index));
-        }
+        public final void setAborted(AmqpBoolean aborted) {
+            copyCheck();
+            bean.aborted = aborted;
         }
-    }
 
-    public AmqpType<?, ?> get(int index) {
-        switch(index) {
-        case 0: {
-            return bean.options;
-        }
-        case 1: {
-            return bean.handle;
-        }
-        case 2: {
-            return bean.deliveryTag;
-        }
-        case 3: {
-            return bean.more;
+        public final Boolean getAborted() {
+            return bean.aborted.getValue();
         }
-        case 4: {
-            return bean.aborted;
+
+        public final void setFragments(AmqpList fragments) {
+            copyCheck();
+            bean.fragments = fragments;
         }
-        case 5: {
+
+        public final IAmqpList<AmqpType<?, ?>> getFragments() {
             return bean.fragments;
         }
-        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: {
+                setDeliveryTag((AmqpDeliveryTag) value);
+                break;
+            }
+            case 3: {
+                setMore((AmqpBoolean) value);
+                break;
+            }
+            case 4: {
+                setAborted((AmqpBoolean) value);
+                break;
+            }
+            case 5: {
+                setFragments((AmqpList) 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.deliveryTag;
+            }
+            case 3: {
+                return bean.more;
+            }
+            case 4: {
+                return bean.aborted;
+            }
+            case 5: {
+                return bean.fragments;
+            }
+            default : {
+                throw new IndexOutOfBoundsException(String.valueOf(index));
+            }
+            }
         }
-    }
 
-    public int getListCount() {
-        return 6;
-    }
+        public int getListCount() {
+            return 6;
+        }
 
-    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(AmqpTransfer.AmqpTransferBean other) {
+            bean = this;
         }
-    }
 
-    private final void copy(AmqpTransfer.AmqpTransferBean 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 AmqpTransfer)) {
+                return false;
+            }
 
-        if(o == null || !(o instanceof AmqpTransfer)) {
-            return false;
+            return equals((AmqpTransfer) o);
         }
 
-        return equals((AmqpTransfer) o);
-    }
+        public boolean equals(AmqpTransfer b) {
 
-    public boolean equals(AmqpTransfer 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.getDeliveryTag() == null ^ getDeliveryTag() == null) {
+                return false;
+            }
+            if(b.getDeliveryTag() != null && !b.getDeliveryTag().equals(getDeliveryTag())){ 
+                return false;
+            }
 
-        if(b.getDeliveryTag() == null ^ getDeliveryTag() == null) {
-            return false;
-        }
-        if(b.getDeliveryTag() != null && !b.getDeliveryTag().equals(getDeliveryTag())){ 
-            return false;
-        }
+            if(b.getMore() == null ^ getMore() == null) {
+                return false;
+            }
+            if(b.getMore() != null && !b.getMore().equals(getMore())){ 
+                return false;
+            }
 
-        if(b.getMore() == null ^ getMore() == null) {
-            return false;
-        }
-        if(b.getMore() != null && !b.getMore().equals(getMore())){ 
-            return false;
-        }
+            if(b.getAborted() == null ^ getAborted() == null) {
+                return false;
+            }
+            if(b.getAborted() != null && !b.getAborted().equals(getAborted())){ 
+                return false;
+            }
 
-        if(b.getAborted() == null ^ getAborted() == null) {
-            return false;
-        }
-        if(b.getAborted() != null && !b.getAborted().equals(getAborted())){ 
-            return false;
+            if(b.getFragments() == null ^ getFragments() == null) {
+                return false;
+            }
+            if(b.getFragments() != null && !b.getFragments().equals(getFragments())){ 
+                return false;
+            }
+            return true;
         }
 
-        if(b.getFragments() == null ^ getFragments() == null) {
-            return false;
-        }
-        if(b.getFragments() != null && !b.getFragments().equals(getFragments())){ 
-            return false;
+        public int hashCode() {
+            return AbstractAmqpList.hashCodeFor(this);
         }
-        return true;
     }
 
-    public int hashCode() {
-        return AbstractAmqpList.hashCodeFor(this);
-    }
-}
-
     public static class AmqpTransferBuffer extends AmqpList.AmqpListBuffer implements AmqpTransfer{
 
         private AmqpTransferBean bean;
 
-        protected AmqpTransferBuffer(Encoded<IAmqpList> encoded) {
+        protected AmqpTransferBuffer(Encoded<IAmqpList<AmqpType<?, ?>>> encoded) {
             super(encoded);
         }
 
@@ -544,7 +544,7 @@
             bean().setFragments(fragments);
         }
 
-        public final IAmqpList getFragments() {
+        public final IAmqpList<AmqpType<?, ?>> getFragments() {
             return bean().getFragments();
         }
 
@@ -564,10 +564,6 @@
             return bean().iterator();
         }
 
-        public IAmqpList getValue() {
-            return bean().getValue();
-        }
-
         public AmqpTransfer.AmqpTransferBuffer getBuffer(AmqpMarshaller marshaller) throws AmqpEncodingError{
             return this;
         }
@@ -596,7 +592,7 @@
             return bean().hashCode();
         }
 
-        public static AmqpTransfer.AmqpTransferBuffer create(Encoded<IAmqpList> encoded) {
+        public static AmqpTransfer.AmqpTransferBuffer create(Encoded<IAmqpList<AmqpType<?, ?>>> encoded) {
             if(encoded.isNull()) {
                 return null;
             }



Mime
View raw message