RC9/qpid/java/management/client/src/main/java/org/apache/qpid/management/messages/AmqpCoDec.java

/*
*
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 *
 */

package org.apache.qpid.management.messages;

import java.io.UnsupportedEncodingException;
import java.nio.ByteBuffer;

/**
 * AMQP Management messages codec.
 * 
 * @author Andrea Gazzarini
 */
public class AmqpCoDec
{
    private byte [] _buffer;
    private int _position;
        
    /**
     * Builds a new codec.
     */
    AmqpCoDec()
    {
        _buffer = new byte [1000];
        _buffer[0] = 'A';
        _buffer[1] = 'M';
        _buffer[2] = '2';
        _position = 3;
    }
    
    
    /**
     * Int32-to-4 byte array marshalling.
     * Marshalles an integer using four bytes.
     * 
     * @param data the result array.
     * @param pos the starting position of the array to be filled.
     * @param value the value to be marshalled.
     */
    public final void pack32(int value) {
        _buffer[_position++] = (byte) (value >> 24 & 0xff);
        _buffer[_position++] = (byte) (value >> 16 & 0xff);
        _buffer[_position++] = (byte) (value >> 8 & 0xff);
        _buffer[_position++] = (byte) (value & 0xff);
    }

    /**
     * Int32-to-4 byte array marshalling.
     * Marshalles an integer using four bytes.
     * 
     * @param data the result array.
     * @param pos the starting position of the array to be filled.
     * @param value the value to be marshalled.
     */
    public final void pack16(int value) {
        _buffer[_position++] = (byte) (value >> 8 & 0xff);
        _buffer[_position++] = (byte) (value & 0xff);
    }
    
    /**
     * Int32-to-4 byte array marshalling.
     * Marshalles an integer using four bytes.
     * 
     * @param data the result array.
     * @param pos the starting position of the array to be filled.
     * @param value the value to be marshalled.
     */
    public final void pack64(long value) {
        _buffer[_position++] = (byte) (value >> 56 & 0xff);
        _buffer[_position++] = (byte) (value >> 48 & 0xff);
        _buffer[_position++] = (byte) (value >> 40 & 0xff);
        _buffer[_position++] = (byte) (value >> 32 & 0xff);
        _buffer[_position++] = (byte) (value >> 24 & 0xff);
        _buffer[_position++] = (byte) (value >> 16 & 0xff);
        _buffer[_position++] = (byte) (value >> 8 & 0xff);
        _buffer[_position++] = (byte) (value & 0xff);
    }
    
    /**
     * Int32-to-byte array marshalling.
     * Marshalles an integer using two bytes.
     * 
     * @param data the result array.
     * @param pos the starting position of the array to be filled.
     * @param value the value to be marshalled.
     */
    public final void pack24(int value) {
        _buffer[_position++] = (byte) (value >> 16 & 0xff);
        _buffer[_position++] = (byte) (value >> 8 & 0xff);
        _buffer[_position++] = (byte) (value & 0xff);
    }    

    public final void pack8(int value) {
        _buffer[_position++] = (byte) (value & 0xff);
    }    

    public void pack8 (byte aByte)
    {
        _buffer[_position++] = aByte;
    }    

    public void packStr8(String aString)
    {
        try
        {
            byte [] toBytes = aString.getBytes("UTF-8");
            int length = toBytes.length;
            pack8(length);
            System.arraycopy(toBytes, 0, _buffer, _position, length);  
            _position+=length;
        } catch (UnsupportedEncodingException exception)
        {
            throw new RuntimeException(exception);
        }
    }
    
    public void packStr16(String aString)
    {
        try
        {
            byte [] toBytes = aString.getBytes("UTF-8");
            int length = toBytes.length;
            pack16(length);
            System.arraycopy(toBytes, 0, _buffer, _position, length);  
            _position+=length;
        } catch (UnsupportedEncodingException exception)
        {
            throw new RuntimeException(exception);
        }
    }

	public static final long unpack64(byte data[]) {
		return (
				((long) (data[0] & 0xff) << 56) | 
				((long)(data[1] & 0xff) << 48) | 
				((long)(data[2] & 0xff) << 40) | 
				((long)(data[3] & 0xff) << 32) | 
				((long)(data[4] & 0xff) << 24) | 
				((long)(data[5] & 0xff) << 16) | 
				((long)(data[6] & 0xff) << 8) | 
				(long) data[7] & 0xff);		
	}

    
    public void pack (byte[] bytes)
    {
        System.arraycopy(bytes, 0, _buffer, _position, bytes.length);
        _position+=bytes.length;
    }
    
    /**
     * Retruns the byte buffer that is wrapping the backing array of this codec.
     * 
     * @return the byte buffer that is wrapping the backing array of this codec.
     */
    public ByteBuffer getEncodedBuffer ()
    {
        return ByteBuffer.wrap(_buffer,0,_position);
    }
}