Package org.apache.qpid.transport.codec

Examples of org.apache.qpid.transport.codec.BBEncoder.segment()

81
82
83
84
85
86
87
88
89
90
91
    @ Override
    public ByteBuffer getData()
    {
        BBEncoder encoder = new BBEncoder(1024);
        encoder.writeMap(_map);
        return encoder.segment();
    }
   
    @ Override
    protected void populateMapFromData(ByteBuffer data) throws JMSException
    {
View Full Code Here
81
82
83
84
85
86
87
88
89
90
91
    public void testListBehaviorForIncommingMsg() throws Exception
    {
        BBEncoder encoder = new BBEncoder(1024);
        encoder.writeList(_list);
        AMQPEncodedListMessage m = new AMQPEncodedListMessage(new AMQMessageDelegate_0_10(),encoder.segment());

        assertTrue("contains(Object) method did not return true as expected",m.contains(1));
        assertFalse("contains(Object) method did not return false as expected",m.contains(5));
        assertEquals("get(index) method returned incorrect value",((Integer)m.get(1)).intValue(),2);
        assertEquals("indexOf(Object) method returned incorrect index",m.indexOf(2),1);
View Full Code Here
101
102
103
104
105
106
107
108
109
110
111
    public void testStreamMessageInterfaceForIncommingMsg() throws Exception
    {
        BBEncoder encoder = new BBEncoder(1024);
        encoder.writeList(getList());
        AMQPEncodedListMessage m = new AMQPEncodedListMessage(new AMQMessageDelegate_0_10(),encoder.segment());

        assertEquals(true,m.readBoolean());
        assertEquals((byte)256,m.readByte());
        assertEquals(Short.MAX_VALUE,m.readShort());
        assertEquals(Integer.MAX_VALUE,m.readInt());
View Full Code Here
119
120
121
122
123
124
125
126
127
128
129
    public void testMapMessageInterfaceForIncommingMsg() throws Exception
    {
        BBEncoder encoder = new BBEncoder(1024);
        encoder.writeList(getList());
        AMQPEncodedListMessage m = new AMQPEncodedListMessage(new AMQMessageDelegate_0_10(),encoder.segment());

        assertEquals(true,m.getBoolean("0"));
        assertEquals((byte)256,m.getByte("1"));
        assertEquals(Short.MAX_VALUE,m.getShort("2"));
        assertEquals(Integer.MAX_VALUE,m.getInt("3"));
View Full Code Here
335
336
337
338
339
340
341
342
343
344
345
                {
                    short innerType = Util.qmfType(obj);
                    lEnc.writeUint8(innerType);
                    this.encodeValue(lEnc, innerType, obj);
                }
                enc.writeVbin32(lEnc.segment().array());
                break;
            case 22: // Array
                ArrayList<Object> aItems = (ArrayList<Object>) val;
                BBEncoder aEnc = new BBEncoder(1);
                aEnc.init();
View Full Code Here
353
354
355
356
357
358
359
360
361
362
363
                    for (Object obj : aItems)
                    {
                        this.encodeValue(aEnc, innerType, obj);
                    }
                }
                enc.writeVbin32(aEnc.segment().array());
                break;
            default:
                throw new ConsoleException(String.format(
                        "Invalid Type Code: %s", type));
            }
View Full Code Here
175
176
177
178
179
180
181
182
183
184
185
        }
        else if(object instanceof Map)
        {
            BBEncoder encoder = new BBEncoder(1024);
            encoder.writeMap((Map)object);
            ByteBuffer buf = encoder.segment();
            int remaining = buf.remaining();
            byte[] data = new byte[remaining];
            buf.get(data);
            return data;
View Full Code Here
201
202
203
204
205
206
207
208
209
210
211
                }
                else
                {
                    BBEncoder encoder = new BBEncoder(1024);
                    encoder.writeList((List) object);
                    buf = encoder.segment();
                }
                int remaining = buf.remaining();
                byte[] data = new byte[remaining];
                buf.get(data);
                return data;
View Full Code Here
154
155
156
157
158
159
160
161
162
163
164
        }
        else if(object instanceof Map)
        {
            BBEncoder encoder = new BBEncoder(1024);
            encoder.writeMap((Map)object);
            ByteBuffer buf = encoder.segment();
            int remaining = buf.remaining();
            byte[] data = new byte[remaining];
            buf.get(data);
            return data;
View Full Code Here
165
166
167
168
169
170
171
172
173
174
175
        }
        else if(object instanceof List)
        {
            BBEncoder encoder = new BBEncoder(1024);
            encoder.writeList((List) object);
            ByteBuffer buf = encoder.segment();
            int remaining = buf.remaining();
            byte[] data = new byte[remaining];
            buf.get(data);
            return data;
        }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.