org.jgroups.Message.printHeaders()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(9.2k)|赞(0)|评价(0)|浏览(174)

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

Message.printHeaders介绍

暂无

代码示例

代码示例来源：origin: wildfly/wildfly

  1. public String printHeaders() {
  2.   StringBuilder sb=new StringBuilder().append("dest=" + dest);
  3.   if(sender != null)
  4.     sb.append(", sender=").append(sender);
  5.   sb.append("\n").append(size()).append(":\n");
  6.   int count=1;
  7.   for(Message msg: this)
  8.     sb.append("#").append(count++).append(": ").append(msg.printHeaders()).append("\n");
  9.   return sb.toString();
  10. }

代码示例来源：origin: wildfly/wildfly

  1. protected static void dump(String type, Message msg) {
  2.   StringBuilder sb=new StringBuilder();
  3.   sb.append(String.format("\n%s from %s (%d bytes):\nhdrs: %s\n", type, msg.src(), msg.getLength(), msg.printHeaders()));
  4.   if(msg.getLength() > 0) {
  5.     sb.append("payload: ");
  6.     printPayload(msg, sb);
  7.     sb.append("\n");
  8.   }
  9.   System.out.println(sb.toString());
  10. }

代码示例来源：origin: wildfly/wildfly

  1. public static void main(String[] args) throws FileNotFoundException {
  2.   String file=null;
  3.   for(int i=0; i < args.length; i++) {
  4.     if(args[i].equals("-file")) {
  5.       file=args[++i];
  6.       continue;
  7.     }
  8.     help();
  9.     return;
  10.   }
  11.   List<Message> msgs=parse(file);
  12.   int cnt=1;
  13.   for(Message msg: msgs)
  14.     System.out.println(cnt++ + ": " + msg + ", hdrs: " + msg.printHeaders());
  15. }

代码示例来源：origin: wildfly/wildfly

  1. public static String dump(byte[] buf, int offset, int length) {
  2.   StringBuilder sb=new StringBuilder();
  3.   List<Message> msgs=parse(new ByteArrayInputStream(buf, offset, length));
  4.   if(msgs != null)
  5.     for(Message msg: msgs)
  6.       sb.append(String.format("dst=%s src=%s (%d bytes): hdrs= %s\n", msg.dest(), msg.src(), msg.getLength(), msg.printHeaders()));
  7.   return sb.toString();
  8. }

代码示例来源：origin: wildfly/wildfly

  1. public Object down(Message msg) {
  2.    System.out.println("------------------- TRACE (sent) -----------------------");
  3.    System.out.printf("msg from %s to %s (%d bytes): hdrs=%s\n", msg.src(), msg.dest(), msg.length(), msg.printHeaders());
  4.    System.out.println("--------------------------------------------------------");
  5.    return down_prot.down(msg);
  6.  }

代码示例来源：origin: wildfly/wildfly

  1. public Object down(Message msg) {
  2.   if(print_down)
  3.     System.out.printf("-- to %s (%d bytes): %s\n", msg.dest(), msg.getLength(), msg.printHeaders());
  4.   return down_prot.down(msg);  // Pass on to the layer below us
  5. }

代码示例来源：origin: wildfly/wildfly

  1. public Object up(Message msg) {
  2.   if(print_up)
  3.     System.out.printf("-- [s] from %s (%d bytes): %s\n", msg.src(), msg.getLength(), msg.printHeaders());
  4.   return up_prot.up(msg); // Pass up to the layer above us
  5. }

代码示例来源：origin: wildfly/wildfly

  1. protected static void dump(GossipData data) {
  2.   System.out.println("");
  3.   List<Message> messages=Util.parse(data.buffer, data.offset, data.length);
  4.   if(messages != null)
  5.     for(Message msg : messages)
  6.       System.out.printf("dst=%s src=%s (%d bytes): hdrs= %s\n", msg.dest(), msg.src(), msg.getLength(), msg.printHeaders());
  7. }

代码示例来源：origin: wildfly/wildfly

  1. public void up(MessageBatch batch) {
  2.   if(print_up) {
  3.     for(Message msg : batch)
  4.       System.out.printf("-- [b] from %s (%d bytes): %s\n", msg.src(), msg.getLength(), msg.printHeaders());
  5.   }
  6.   if(!batch.isEmpty())
  7.     up_prot.up(batch);
  8. }

代码示例来源：origin: wildfly/wildfly

  1. protected void dropped(Message msg, boolean down) {
  3.     log.trace("dropped msg %s hdrs: %s\n", down? "to " + msg.dest() : "from " + msg.src(), msg.printHeaders());
  4.   }
  5. }

代码示例来源：origin: wildfly/wildfly

  1. public Object up(Message msg) {
  2.   if(log.isTraceEnabled()) {
  3.     long size=raw_buffer? msg.getLength() : msg.size();
  4.     if(size >= min_size) {
  5.       StringBuilder sb=new StringBuilder(local_addr + ".up(): size of message buffer=");
  6.       sb.append(Util.printBytes(size)).append(", " + numHeaders(msg) + " headers");
  7.       if(print_msg)
  8.         sb.append(", headers=" + msg.printHeaders());
  9.       log.trace(sb);
  10.     }
  11.   }
  12.   return up_prot.up(msg);
  13. }

代码示例来源：origin: wildfly/wildfly

  1. public Object down(Message msg) {
  2.   if(log.isTraceEnabled()) {
  3.     long size=raw_buffer? msg.getLength() : msg.size();
  4.     if(size >= min_size) {
  5.       StringBuilder sb=new StringBuilder(local_addr + ".down(): size of message buffer=");
  6.       sb.append(Util.printBytes(size)).append(", " + numHeaders(msg) + " headers");
  7.       if(print_msg)
  8.         sb.append(", headers=" + msg.printHeaders());
  9.       log.trace(sb);
  10.     }
  11.   }
  12.   return down_prot.down(msg);
  13. }

代码示例来源：origin: wildfly/wildfly

  1. protected void _send(Message msg, Address dest) {
  2.   try {
  3.     send(msg, dest);
  4.   }
  5.   catch(InterruptedIOException iex) {
  6.   }
  7.   catch(InterruptedException interruptedEx) {
  8.     Thread.currentThread().interrupt(); // let someone else handle the interrupt
  9.   }
  10.   catch(SocketException sock_ex) {
  11.     log.trace(Util.getMessage("SendFailure"),
  12.          local_addr, (dest == null? "cluster" : dest), msg.size(), sock_ex.toString(), msg.printHeaders());
  13.   }
  14.   catch(Throwable e) {
  15.     log.error(Util.getMessage("SendFailure"),
  16.          local_addr, (dest == null? "cluster" : dest), msg.size(), e.toString(), msg.printHeaders());
  17.   }
  18. }

代码示例来源：origin: wildfly/wildfly

  1. public void receive(Message msg) {
  2.   byte[] buf=msg.getRawBuffer();
  3.   if(buf == null) {
  4.     System.err.printf("%s: received null buffer from %s, headers: %s\n", channel.getAddress(), msg.src(), msg.printHeaders());
  5.     return;
  6.   }
  7.   try {
  8.     DrawCommand comm=Util.streamableFromByteBuffer(DrawCommand::new, buf, msg.getOffset(), msg.getLength());
  9.     switch(comm.mode) {
  10.       case DrawCommand.DRAW:
  11.         if(panel != null)
  12.           panel.drawPoint(comm);
  13.         break;
  14.       case DrawCommand.CLEAR:
  15.         clearPanel();
  16.         break;
  17.       default:
  18.         System.err.println("***** received invalid draw command " + comm.mode);
  19.         break;
  20.     }
  21.   }
  22.   catch(Exception e) {
  23.     e.printStackTrace();
  24.   }
  25. }

代码示例来源：origin: wildfly/wildfly

  1. protected void loopback(Message msg, final boolean multicast) {
  2.   final Message copy=loopback_copy? msg.copy() : msg;
  3.   if(is_trace)
  4.     log.trace("%s: looping back message %s, headers are %s", local_addr, copy, copy.printHeaders());
  5.   if(!loopback_separate_thread) {
  6.     passMessageUp(copy, null, false, multicast, false);
  7.     return;
  8.   }
  9.   // changed to fix http://jira.jboss.com/jira/browse/JGRP-506
  10.   boolean internal=msg.isFlagSet(Message.Flag.INTERNAL);
  11.   boolean oob=msg.isFlagSet(Message.Flag.OOB);
  12.   // submitToThreadPool(() -> passMessageUp(copy, null, false, multicast, false), internal);
  13.   msg_processing_policy.loopback(msg, oob, internal);
  14. }

代码示例来源：origin: wildfly/wildfly

  1. protected void sendSingleMessage(final Message msg) {
  2.   Address dest=msg.getDest();
  3.   try {
  4.     Util.writeMessage(msg, output, dest == null);
  5.     transport.doSend(output.buffer(), 0, output.position(), dest);
  6.     if(transport.statsEnabled())
  7.       transport.incrNumSingleMsgsSent(1);
  8.   }
  9.   catch(SocketException | SocketTimeoutException sock_ex) {
  10.     log.trace(Util.getMessage("SendFailure"),
  11.          transport.localAddress(), (dest == null? "cluster" : dest), msg.size(), sock_ex.toString(), msg.printHeaders());
  12.   }
  13.   catch(Throwable e) {
  14.     log.error(Util.getMessage("SendFailure"),
  15.          transport.localAddress(), (dest == null? "cluster" : dest), msg.size(), e.toString(), msg.printHeaders());
  16.   }
  17. }

代码示例来源：origin: wildfly/wildfly

  1. protected void sendSingleMessage(final Message msg, final ByteArrayDataOutputStream output) {
  2.   Address dest=msg.getDest();
  3.   try {
  4.     output.position(0);
  5.     Util.writeMessage(msg, output, dest == null);
  6.     transport.doSend(output.buffer(), 0, output.position(), dest);
  7.     if(transport.statsEnabled())
  8.       transport.incrNumSingleMsgsSent(1);
  9.   }
  10.   catch(SocketException | SocketTimeoutException sock_ex) {
  11.     log.trace(Util.getMessage("SendFailure"),
  12.          transport.localAddress(), (dest == null? "cluster" : dest), msg.size(), sock_ex.toString(), msg.printHeaders());
  13.   }
  14.   catch(Throwable e) {
  15.     log.error(Util.getMessage("SendFailure"),
  16.          transport.localAddress(), (dest == null? "cluster" : dest), msg.size(), e.toString(), msg.printHeaders());
  17.   }
  18. }

代码示例来源：origin: wildfly/wildfly

  1. public void run() {
  2.     Message msg=null, copy;
  3.     while(true) {
  4.       synchronized(this) {
  5.         try {
  6.           msg=send_queue.poll(1000, TimeUnit.MILLISECONDS);
  7.           if(msg == null) {
  8.             Util.sleep(1000);
  9.             continue;
  10.           }
  11.         }
  12.         catch(InterruptedException e) {
  13.           return;
  14.         }
  15.         copy=msg.copy().putHeader(id, new ABPHeader(Type.data, bit));
  16.       }
  17.       log.trace("%s: --> %s.msg(%d). Msg: %s", local_addr, copy.dest(), bit, copy.printHeaders());
  18.       down_prot.down(copy);
  19.     }
  20.   }
  21. }

代码示例来源：origin: wildfly/wildfly

  1. public Object down(Message msg) {
  2.   try {
  3.     if(secret_key == null) {
  4.       log.trace("%s: discarded %s message to %s as secret key is null, hdrs: %s",
  5.            local_addr, msg.dest() == null? "mcast" : "unicast", msg.dest(), msg.printHeaders());
  6.       secretKeyNotAvailable();
  7.       return null;
  8.     }
  9.     encryptAndSend(msg);
  10.   }
  11.   catch(Exception e) {
  12.     log.warn("%s: unable to send message down", local_addr, e);
  13.   }
  14.   return null;
  15. }

代码示例来源：origin: wildfly/wildfly

  1. public void passMessageUp(Message msg, byte[] cluster_name, boolean perform_cluster_name_matching,
  2.              boolean multicast, boolean discard_own_mcast) {
  3.   if(is_trace)
  4.     log.trace("%s: received %s, headers are %s", local_addr, msg, msg.printHeaders());
  5.   if(up_prot == null)
  6.     return;
  7.   if(multicast && discard_own_mcast && local_addr != null && local_addr.equals(msg.getSrc()))
  8.     return;
  9.   // Discard if message's cluster name is not the same as our cluster name
  10.   if(perform_cluster_name_matching && this.cluster_name != null && !this.cluster_name.equals(cluster_name)) {
  11.     if(log_discard_msgs && log.isWarnEnabled()) {
  12.       Address sender=msg.getSrc();
  13.       if(suppress_log_different_cluster != null)
  14.         suppress_log_different_cluster.log(SuppressLog.Level.warn, sender,
  15.                           suppress_time_different_cluster_warnings,
  16.                           new AsciiString(cluster_name),this.cluster_name, sender);
  17.       else
  18.         log.warn(Util.getMessage("MsgDroppedDiffCluster"), new AsciiString(cluster_name),this.cluster_name, sender);
  19.     }
  20.     return;
  21.   }
  22.   up_prot.up(msg);
  23. }

内容来源于网络，如有侵权，请联系作者删除！

Message

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com