Examples of toBuffer()

Examples of org.fusesource.hawtbuf.DataByteArrayOutputStream.toBuffer()

64
65
66
67
68
69
70
71
72
73
74
        // persist the from endpoint as well
        if (exchange.getFromEndpoint() != null) {
            DefaultExchangeHolder.addProperty(pe, "CamelAggregatedFromEndpoint", exchange.getFromEndpoint().getEndpointUri());
        }
        exchangeCodec.encode(pe, baos);
        return baos.toBuffer();
    }

    public Exchange unmarshallExchange(CamelContext camelContext, Buffer buffer) throws IOException {
        DataByteArrayInputStream bais = new DataByteArrayInputStream(buffer);
        DefaultExchangeHolder pe = exchangeCodec.decode(bais);
View Full Code Here

Examples of org.fusesource.hawtbuf.DataByteArrayOutputStream.toBuffer()

235
236
237
238
239
240
241
242
243
244
245
        MessagePB.Bean messageRecord = new MessagePB.Bean();
        messageRecord.setCodec(codec_id);
        messageRecord.setMessageKey(messageKey);
        messageRecord.setSize(message.getSize());
        messageRecord.setValue(mos.toBuffer());
        return messageRecord;
    }

    public File getFile() {
        return file;
View Full Code Here

Examples of org.fusesource.hawtbuf.DataByteArrayOutputStream.toBuffer()

39
40
41
42
43
44
45
46
47
48
49
    private Codec<DefaultExchangeHolder> exchangeCodec = new ObjectCodec<DefaultExchangeHolder>();

    public Buffer marshallKey(String key) throws IOException {
        DataByteArrayOutputStream baos = new DataByteArrayOutputStream();
        keyCodec.encode(key, baos);
        return baos.toBuffer();
    }

    public String unmarshallKey(Buffer buffer) throws IOException {
        DataByteArrayInputStream bais = new DataByteArrayInputStream(buffer);
        String key = keyCodec.decode(bais);
View Full Code Here

Examples of org.fusesource.hawtbuf.DataByteArrayOutputStream.toBuffer()

64
65
66
67
68
69
70
71
72
73
74
        // persist the from endpoint as well
        if (exchange.getFromEndpoint() != null) {
            DefaultExchangeHolder.addProperty(pe, "CamelAggregatedFromEndpoint", exchange.getFromEndpoint().getEndpointUri());
        }
        exchangeCodec.encode(pe, baos);
        return baos.toBuffer();
    }

    public Exchange unmarshallExchange(CamelContext camelContext, Buffer buffer) throws IOException {
        DataByteArrayInputStream bais = new DataByteArrayInputStream(buffer);
        DefaultExchangeHolder pe = exchangeCodec.decode(bais);
View Full Code Here

Examples of org.fusesource.hawtbuf.DataByteArrayOutputStream.toBuffer()

249
250
251
252
253
254
255
256
257
            x.writebody(baos);
        } catch (IOException e) {
            //Shouldn't happen:
            throw new RuntimeException(e);
        }
        return baos.toBuffer();

    }
} // class XidImpl
View Full Code Here

Examples of org.fusesource.hawtbuf.DataByteArrayOutputStream.toBuffer()

248
249
250
251
252
253
254
255
256
257
258
                                    os.write(new UTF8Buffer(options.getPassword()));
                                }
                            } catch (IOException e) {
                                throw new RuntimeException(e);
                            }
                            Buffer buffer = os.toBuffer();
                            sasl.setMechanisms(new String[]{"PLAIN"});
                            sasl.send(buffer.data, buffer.offset, buffer.length);
                        } else if (mechanisims.contains("ANONYMOUS")) {
                            authSent = true;
                            sasl.setMechanisms(new String[]{"ANONYMOUS"});
View Full Code Here

Examples of org.fusesource.hawtbuf.DataByteArrayOutputStream.toBuffer()

251
252
253
254
255
256
257
258
259
260
261
                                os.writeByte(0);
                            }
                        } catch (IOException e) {
                            throw new RuntimeException(e);
                        }
                        Buffer buffer = os.toBuffer();
                        sasl.setMechanisms(new String[]{"PLAIN"});
                        sasl.send(buffer.data, buffer.offset, buffer.length);
                    }
                    return sasl;
                }
View Full Code Here

Examples of org.fusesource.hawtbuf.DataByteArrayOutputStream.toBuffer()

82
83
84
85
86
87
88
89
90
91
92
            }

            MQTTFrame frame = new MQTTFrame();
            frame.header(header());
            frame.commandType(TYPE);
            return frame.buffer(os.toBuffer());
        } catch (IOException e) {
            throw new RuntimeException("The impossible happened");
        }
    }
View Full Code Here

Examples of org.fusesource.hawtbuf.DataByteArrayOutputStream.toBuffer()

81
82
83
84
85
86
87
88
89
90
91
            }

            MQTTFrame frame = new MQTTFrame();
            frame.header(header());
            frame.commandType(TYPE);
            return frame.buffer(os.toBuffer());
        } catch (IOException e) {
            throw new RuntimeException("The impossible happened");
        }
    }
View Full Code Here

Examples of org.fusesource.hawtbuf.DataByteArrayOutputStream.toBuffer()

58
59
60
61
62
63
64
65
66
67
68
            os.writeShort(messageId);
            os.write(grantedQos);

            MQTTFrame frame = new MQTTFrame();
            frame.commandType(TYPE);
            return frame.buffer(os.toBuffer());
        } catch (IOException e) {
            throw new RuntimeException("The impossible happened");
        }
    }
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.