本文整理了Java中org.jgroups.util.Util.writeMessageListHeader()
方法的一些代码示例,展示了Util.writeMessageListHeader()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Util.writeMessageListHeader()
方法的具体详情如下:
包路径:org.jgroups.util.Util
类名称:Util
方法名:writeMessageListHeader
暂无
代码示例来源:origin: wildfly/wildfly
/**
* Write a list of messages with the *same* destination and src addresses. The message list is
* marshalled as follows (see doc/design/MarshallingFormat.txt for details):
* <pre>
* List: * | version | flags | dest | src | cluster-name | [Message*] |
*
* Message: | presence | leading | flags | [src] | length | [buffer] | size | [Headers*] |
*
* </pre>
* @param dest
* @param src
* @param msgs
* @param dos
* @param multicast
* @throws Exception
*/
public static void writeMessageList(Address dest, Address src, byte[] cluster_name,
List<Message> msgs, DataOutput dos, boolean multicast, short transport_id) throws Exception {
writeMessageListHeader(dest, src, cluster_name, msgs != null ? msgs.size() : 0, dos, multicast);
if(msgs != null)
for(Message msg: msgs)
msg.writeToNoAddrs(src, dos, transport_id); // exclude the transport header
}
代码示例来源:origin: wildfly/wildfly
Util.writeMessageListHeader(dest, msg_queue[start].getSrc(), transport.cluster_name.chars(), numMsgs, output, dest == null);
for(int i=start; i < MSG_BUF_SIZE; ++i) {
Message msg=msg_queue[i];
代码示例来源:origin: wildfly/wildfly
try {
output.position(0);
Util.writeMessageListHeader(dest, msg.src(), cluster_name, 1, output, dest == null);
代码示例来源:origin: wildfly/wildfly
try {
output.position(0);
Util.writeMessageListHeader(dest, msg.src(), cluster_name, 1, output, dest == null);
代码示例来源:origin: wildfly/wildfly
try {
output.position(0);
Util.writeMessageListHeader(dest, msg.src(), cluster_name, 1, output, dest == null);
代码示例来源:origin: org.jboss.eap/wildfly-client-all
/**
* Write a list of messages with the *same* destination and src addresses. The message list is
* marshalled as follows (see doc/design/MarshallingFormat.txt for details):
* <pre>
* List: * | version | flags | dest | src | cluster-name | [Message*] |
*
* Message: | presence | leading | flags | [src] | length | [buffer] | size | [Headers*] |
*
* </pre>
* @param dest
* @param src
* @param msgs
* @param dos
* @param multicast
* @throws Exception
*/
public static void writeMessageList(Address dest, Address src, byte[] cluster_name,
List<Message> msgs, DataOutput dos, boolean multicast, short transport_id) throws Exception {
writeMessageListHeader(dest, src, cluster_name, msgs != null ? msgs.size() : 0, dos, multicast);
if(msgs != null)
for(Message msg: msgs)
msg.writeToNoAddrs(src, dos, transport_id); // exclude the transport header
}
代码示例来源:origin: org.jboss.eap/wildfly-client-all
Util.writeMessageListHeader(dest, msg_queue[start].getSrc(), transport.cluster_name.chars(), numMsgs, output, dest == null);
for(int i=start; i < MSG_BUF_SIZE; ++i) {
Message msg=msg_queue[i];
代码示例来源:origin: org.jboss.eap/wildfly-client-all
try {
output.position(0);
Util.writeMessageListHeader(dest, msg.src(), cluster_name, 1, output, dest == null);
代码示例来源:origin: org.jboss.eap/wildfly-client-all
try {
output.position(0);
Util.writeMessageListHeader(dest, msg.src(), cluster_name, 1, output, dest == null);
代码示例来源:origin: org.jboss.eap/wildfly-client-all
try {
output.position(0);
Util.writeMessageListHeader(dest, msg.src(), cluster_name, 1, output, dest == null);
内容来源于网络,如有侵权,请联系作者删除!