org.jgroups.util.Util.writeMessageListHeader()方法的使用及代码示例

x33g5p2x  于2022-02-01 转载在 其他  
字(3.1k)|赞(0)|评价(0)|浏览(209)

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

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);

相关文章

Util类方法