本文整理了Java中org.fusesource.hawtbuf.Buffer.buffer()
方法的一些代码示例,展示了Buffer.buffer()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Buffer.buffer()
方法的具体详情如下:
包路径:org.fusesource.hawtbuf.Buffer
类名称:Buffer
方法名:buffer
暂无
代码示例来源:origin: org.apache.activemq/activemq-all
public void setBuffer(Buffer value, boolean validate) {
if (validate && !value.startsWith(PREFIX) || value.length() != 8) {
throw new IllegalArgumentException("Not an AMQP header buffer");
}
buffer = value.buffer();
}
代码示例来源:origin: org.apache.qpid/proton-hawtdispatch
public void setBuffer(Buffer value) {
if( !value.startsWith(PREFIX) || value.length()!=8 ) {
throw new IllegalArgumentException("Not an AMQP header buffer");
}
buffer = value.buffer();
}
代码示例来源:origin: org.apache.activemq/activemq-osgi
public void setBuffer(Buffer value, boolean validate) {
if (validate && !value.startsWith(PREFIX) || value.length() != 8) {
throw new IllegalArgumentException("Not an AMQP header buffer");
}
buffer = value.buffer();
}
代码示例来源:origin: apache/activemq-artemis
public void setBuffer(Buffer value, boolean validate) {
if (validate && !value.startsWith(PREFIX) || value.length() != 8) {
throw new IllegalArgumentException("Not an AMQP header buffer");
}
buffer = value.buffer();
}
代码示例来源:origin: org.apache.aries.rsa.provider/org.apache.aries.rsa.provider.fastbin
public void run() {
if(holder!=null)
holder.factory.unget();
final Buffer command = baos.toBuffer();
// Update the size field.
BufferEditor editor = command.buffer().bigEndianEditor();
editor.writeInt(command.length);
queue().execute(new Runnable() {
public void run() {
transport.offer(command);
}
});
}
});
代码示例来源:origin: org.apache.aries.rsa.provider/org.apache.aries.rsa.provider.fastbin
BufferEditor editor = command.buffer().bigEndianEditor();
editor.writeInt(command.length);
handler.lastRequestSize = command.length;
代码示例来源:origin: jboss-fuse/fabric8
BufferEditor editor = command.buffer().bigEndianEditor();
editor.writeInt(command.length);
handler.lastRequestSize = command.length;
内容来源于网络,如有侵权,请联系作者删除!