diff options
author | Robert Godfrey <rgodfrey@apache.org> | 2014-09-29 23:20:39 +0000 |
---|---|---|
committer | Robert Godfrey <rgodfrey@apache.org> | 2014-09-29 23:20:39 +0000 |
commit | 38e0deb8298e6f4b27255066b8309cd19f703958 (patch) | |
tree | b49e9ab3a2ba9cf2a1b07ea4eeb31951b7f2aa05 /java/common/src/main/java/org/apache/qpid/framing/AccessRequestBody.java | |
parent | 17ff2442352bac23f3776b3a8a6e4e419833e787 (diff) | |
download | qpid-python-38e0deb8298e6f4b27255066b8309cd19f703958.tar.gz |
Merge method body implementation classes
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6125-ProtocolRefactoring@1628336 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/common/src/main/java/org/apache/qpid/framing/AccessRequestBody.java')
-rw-r--r-- | java/common/src/main/java/org/apache/qpid/framing/AccessRequestBody.java | 144 |
1 files changed, 133 insertions, 11 deletions
diff --git a/java/common/src/main/java/org/apache/qpid/framing/AccessRequestBody.java b/java/common/src/main/java/org/apache/qpid/framing/AccessRequestBody.java index 38701385d6..695e41bc13 100644 --- a/java/common/src/main/java/org/apache/qpid/framing/AccessRequestBody.java +++ b/java/common/src/main/java/org/apache/qpid/framing/AccessRequestBody.java @@ -22,25 +22,147 @@ /* * This file is auto-generated by Qpid Gentools v.0.1 - do not modify. * Supported AMQP version: - * 0-9 - * 0-91 - * 8-0 - */ + * 8-0 + */ package org.apache.qpid.framing; -public interface AccessRequestBody extends EncodableAMQDataBlock, AMQMethodBody +import java.io.DataOutput; +import java.io.IOException; + +import org.apache.qpid.AMQException; +import org.apache.qpid.codec.MarkableDataInput; + +public class AccessRequestBody extends AMQMethodBodyImpl implements EncodableAMQDataBlock, AMQMethodBody { - public boolean getActive(); + public static final int CLASS_ID = 30; + public static final int METHOD_ID = 10; + + // Fields declared in specification + private final AMQShortString _realm; // [realm] + private final byte _bitfield0; // [exclusive, passive, active, write, read] + + // Constructor + public AccessRequestBody(MarkableDataInput buffer) throws AMQFrameDecodingException, IOException + { + _realm = readAMQShortString( buffer ); + _bitfield0 = readBitfield( buffer ); + } + + public AccessRequestBody( + AMQShortString realm, + boolean exclusive, + boolean passive, + boolean active, + boolean write, + boolean read + ) + { + _realm = realm; + byte bitfield0 = (byte)0; + if( exclusive ) + { + bitfield0 = (byte) (((int) bitfield0) | (1 << 0)); + } + + if( passive ) + { + bitfield0 = (byte) (((int) bitfield0) | (1 << 1)); + } + + if( active ) + { + bitfield0 = (byte) (((int) bitfield0) | (1 << 2)); + } + + if( write ) + { + bitfield0 = (byte) (((int) bitfield0) | (1 << 3)); + } + + if( read ) + { + bitfield0 = (byte) (((int) bitfield0) | (1 << 4)); + } + _bitfield0 = bitfield0; + } + + public int getClazz() + { + return CLASS_ID; + } + + public int getMethod() + { + return METHOD_ID; + } + + public final AMQShortString getRealm() + { + return _realm; + } + public final boolean getExclusive() + { + return (((int)(_bitfield0)) & ( 1 << 0)) != 0; + } + public final boolean getPassive() + { + return (((int)(_bitfield0)) & ( 1 << 1)) != 0; + } + public final boolean getActive() + { + return (((int)(_bitfield0)) & ( 1 << 2)) != 0; + } + public final boolean getWrite() + { + return (((int)(_bitfield0)) & ( 1 << 3)) != 0; + } + public final boolean getRead() + { + return (((int)(_bitfield0)) & ( 1 << 4)) != 0; + } - public boolean getExclusive(); + protected int getBodySize() + { + int size = 1; + size += getSizeOf( _realm ); + return size; + } - public boolean getPassive(); + public void writeMethodPayload(DataOutput buffer) throws IOException + { + writeAMQShortString( buffer, _realm ); + writeBitfield( buffer, _bitfield0 ); + } - public boolean getRead(); + public boolean execute(MethodDispatcher dispatcher, int channelId) throws AMQException + { + return dispatcher.dispatchAccessRequest(this, channelId); + } - public AMQShortString getRealm(); + public String toString() + { + StringBuilder buf = new StringBuilder("[AccessRequestBodyImpl: "); + buf.append( "realm=" ); + buf.append( getRealm() ); + buf.append( ", " ); + buf.append( "exclusive=" ); + buf.append( getExclusive() ); + buf.append( ", " ); + buf.append( "passive=" ); + buf.append( getPassive() ); + buf.append( ", " ); + buf.append( "active=" ); + buf.append( getActive() ); + buf.append( ", " ); + buf.append( "write=" ); + buf.append( getWrite() ); + buf.append( ", " ); + buf.append( "read=" ); + buf.append( getRead() ); + buf.append("]"); + return buf.toString(); + } - public boolean getWrite(); } |