broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/codec/SymbolWriter.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.server.protocol.v1_0.codec;

import org.apache.qpid.server.protocol.v1_0.type.Symbol;
import org.apache.qpid.bytebuffer.QpidByteBuffer;

import java.nio.charset.Charset;

public class SymbolWriter extends VariableWidthWriter<Symbol>
{
    private static final Charset ENCODING_CHARSET = Charset.forName("US-ASCII");
    public static final byte LARGE_ENCODING_CODE = (byte) 0xb3;
    public static final byte SMALL_ENCODING_CODE = (byte) 0xa3;
    private Symbol _value;


    @Override
    protected byte getFourOctetEncodingCode()
    {
        return LARGE_ENCODING_CODE;
    }

    @Override
    protected byte getSingleOctetEncodingCode()
    {
        return SMALL_ENCODING_CODE;
    }

    @Override
    public void setValue(Symbol value)
    {
        _value = value;
        super.setValue(value);
    }

    public boolean isCacheable()
    {
        return true;
    }

    @Override
    protected void clearValue()
    {
        _value = null;
    }

    @Override
    protected boolean hasValue()
    {
        return _value != null;
    }

    @Override
    protected int getLength()
    {
        return _value.length();
    }

    @Override
    protected void writeBytes(QpidByteBuffer buf, int offset, int length)
    {
        int end = offset + length;
        for(int i = offset; i < end; i++)
        {
            buf.put((byte)_value.charAt(i));
        }
    }

    private static Factory<Symbol> FACTORY = new Factory<Symbol>()
                                            {

                                                public ValueWriter<Symbol> newInstance(Registry registry)
                                                {
                                                    return new SymbolWriter();
                                                }
                                            };

    public static void register(ValueWriter.Registry registry)
    {
        registry.register(Symbol.class, FACTORY);
    }
}