Modified: qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/type/security/SaslOutcome.java URL: http://svn.apache.org/viewvc/qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/type/security/SaslOutcome.java?rev=1354543&r1=1354542&r2=1354543&view=diff ============================================================================== --- qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/type/security/SaslOutcome.java (original) +++ qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/type/security/SaslOutcome.java Wed Jun 27 14:40:27 2012 @@ -37,12 +37,12 @@ public class SaslOutcome { private static final Object[] DESCRIPTORS = { - UnsignedLong.valueOf(0x0000000000000044L), Symbol.valueOf("amqp:sasl-outcome:list"), + UnsignedLong.valueOf(0x0000000000000044L), Symbol.valueOf("amqp:sasl-outcome:list"), }; private static final UnsignedLong DESCRIPTOR = UnsignedLong.valueOf(0x0000000000000044L); private final SaslOutcomeWrapper _wrapper = new SaslOutcomeWrapper(); - + private UnsignedByte _code; private Binary _additionalData; @@ -70,7 +70,7 @@ public class SaslOutcome { _additionalData = additionalData; } - + public Object getDescriptor() { return DESCRIPTOR; @@ -80,7 +80,7 @@ public class SaslOutcome { return _wrapper; } - + public Object get(final int index) { @@ -89,7 +89,7 @@ public class SaslOutcome case 0: return _code; case 1: - return _additionalData; + return _additionalData; } throw new IllegalStateException("Unknown index " + index); @@ -98,12 +98,17 @@ public class SaslOutcome public int size() { - return _additionalData != null - ? 2 - : 1; + return _additionalData != null + ? 2 + : 1; } + public <E> void invoke(SaslFrameBodyHandler<E> handler, Binary payload, E context) + { + handler.handleOutcome(this, payload, context); + } + public final class SaslOutcomeWrapper extends AbstractList { @@ -163,4 +168,3 @@ public class SaslOutcome } } } - \ No newline at end of file
Modified: qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/type/security/SaslResponse.java URL: http://svn.apache.org/viewvc/qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/type/security/SaslResponse.java?rev=1354543&r1=1354542&r2=1354543&view=diff ============================================================================== --- qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/type/security/SaslResponse.java (original) +++ qpid/proton/trunk/proton-j/src/org/apache/qpid/proton/type/security/SaslResponse.java Wed Jun 27 14:40:27 2012 @@ -37,12 +37,12 @@ public class SaslResponse { private static final Object[] DESCRIPTORS = { - UnsignedLong.valueOf(0x0000000000000043L), Symbol.valueOf("amqp:sasl-response:list"), + UnsignedLong.valueOf(0x0000000000000043L), Symbol.valueOf("amqp:sasl-response:list"), }; private static final UnsignedLong DESCRIPTOR = UnsignedLong.valueOf(0x0000000000000043L); private final SaslResponseWrapper _wrapper = new SaslResponseWrapper(); - + private Binary _response; public Binary getResponse() @@ -59,7 +59,7 @@ public class SaslResponse _response = response; } - + public Object getDescriptor() { return DESCRIPTOR; @@ -69,14 +69,14 @@ public class SaslResponse { return _wrapper; } - + public Object get(final int index) { switch(index) { case 0: - return _response; + return _response; } throw new IllegalStateException("Unknown index " + index); @@ -85,10 +85,15 @@ public class SaslResponse public int size() { - return 1; + return 1; } + public <E> void invoke(SaslFrameBodyHandler<E> handler, Binary payload, E context) + { + handler.handleResponse(this, payload, context); + } + public final class SaslResponseWrapper extends AbstractList { @@ -146,4 +151,3 @@ public class SaslResponse } } } - \ No newline at end of file --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
