org.fusesource.hawtbuf.UTF8Buffer.getData()方法的使用及代码示例

本文整理了Java中org.fusesource.hawtbuf.UTF8Buffer.getData()方法的一些代码示例，展示了UTF8Buffer.getData()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。UTF8Buffer.getData()方法的具体详情如下：
包路径：org.fusesource.hawtbuf.UTF8Buffer
类名称：UTF8Buffer
方法名：getData

UTF8Buffer.getData介绍

暂无

代码示例

代码示例来源：origin: org.fusesource.fuse-extra/fusemq-apollo-mqtt

public void writeExternal(java.io.DataOutput out) throws java.io.IOException {
if( bean.f_name!=null ) {
out.writeInt(bean.f_name.getLength());
out.write(bean.f_name.getData(), bean.f_name.getOffset(), bean.f_name.getLength());
} else {
out.writeInt(-1);
}
out.writeInt(bean.f_qos);
if( bean.f_address!=null ) {
out.writeInt(bean.f_address.getLength());
out.write(bean.f_address.getData(), bean.f_address.getOffset(), bean.f_address.getLength());
} else {
out.writeInt(-1);
}
}

代码示例来源：origin: org.apache.activemq/apollo-mqtt

public void writeExternal(java.io.DataOutput out) throws java.io.IOException {
if( bean.f_name!=null ) {
out.writeInt(bean.f_name.getLength());
out.write(bean.f_name.getData(), bean.f_name.getOffset(), bean.f_name.getLength());
} else {
out.writeInt(-1);
}
out.writeInt(bean.f_qos);
if( bean.f_address!=null ) {
out.writeInt(bean.f_address.getLength());
out.write(bean.f_address.getData(), bean.f_address.getOffset(), bean.f_address.getLength());
} else {
out.writeInt(-1);
}
}

代码示例来源：origin: org.apache.activemq/apollo-mqtt

public void writeExternal(java.io.DataOutput out) throws java.io.IOException {
if( bean.f_clientId!=null ) {
out.writeInt(bean.f_clientId.getLength());
out.write(bean.f_clientId.getData(), bean.f_clientId.getOffset(), bean.f_clientId.getLength());
} else {
out.writeInt(-1);
}
if( bean.f_subscriptions!=null ) {
out.writeShort(bean.f_subscriptions.size());
for(TopicPB.Getter o : bean.f_subscriptions) {
o.copy().writeExternal(out);
}
} else {
out.writeShort(-1);
}
if( bean.f_receivedMessageIds!=null ) {
out.writeShort(bean.f_receivedMessageIds.size());
for(java.lang.Integer o : bean.f_receivedMessageIds) {
out.writeInt(o);
}
} else {
out.writeShort(-1);
}
}

代码示例来源：origin: org.fusesource.fuse-extra/fusemq-apollo-mqtt

public void writeExternal(java.io.DataOutput out) throws java.io.IOException {
if( bean.f_clientId!=null ) {
out.writeInt(bean.f_clientId.getLength());
out.write(bean.f_clientId.getData(), bean.f_clientId.getOffset(), bean.f_clientId.getLength());
} else {
out.writeInt(-1);
}
if( bean.f_subscriptions!=null ) {
out.writeShort(bean.f_subscriptions.size());
for(TopicPB.Getter o : bean.f_subscriptions) {
o.copy().writeExternal(out);
}
} else {
out.writeShort(-1);
}
if( bean.f_receivedMessageIds!=null ) {
out.writeShort(bean.f_receivedMessageIds.size());
for(java.lang.Integer o : bean.f_receivedMessageIds) {
out.writeInt(o);
}
} else {
out.writeShort(-1);
}
}

代码示例来源：origin: org.apache.activemq/activemq-all

@Override
public void writeValue(UTF8Buffer value) {
writeSize(value);
WritableBuffer buffer = getEncoder().getBuffer();
buffer.put(value.getData(), value.getOffset(), value.getLength());
}

代码示例来源：origin: org.apache.activemq/activemq-osgi

@Override
public void writeValue(UTF8Buffer value) {
writeSize(value);
WritableBuffer buffer = getEncoder().getBuffer();
buffer.put(value.getData(), value.getOffset(), value.getLength());
}