194195196197198199200201202203204
{ enc.writeUint16(0x0100); } } method.write(enc); ByteBuffer methodSeg = enc.segment(); byte flags = FIRST_SEG; boolean payload = method.hasPayload(); if (!payload)
217218219220221222223224225226227
for (Struct st : structs) { enc.writeStruct32(st); } } headerSeg = enc.segment(); } synchronized (sendlock) { fragment(flags, type, method, methodSeg);
103104105106107108109110111112113
@ Override protected void writeMapToData() { BBEncoder encoder = new BBEncoder(1024); encoder.writeMap(_map); _data = ByteBuffer.wrap(encoder.segment()); } // for testing Map<String,Object> getMap() {
193194195196197198199200201202203
216217218219220221222223224225226
8081828384858687888990
@ Override public ByteBuffer getData() { BBEncoder encoder = new BBEncoder(1024); encoder.writeMap(getMap()); return encoder.segment(); } @ Override protected void populateMapFromData(ByteBuffer data) throws JMSException {
188189190191192193194195196197198
} 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;
199200201202203204205206207208209
} 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; }