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

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

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

Message.setDest介绍

暂无

代码示例

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

  1. /**
  2. * Constructs a message given a destination address
  3. * @param dest The Address of the receiver. If it is null, then the message is sent to the group. Otherwise, it is
  4. *             sent to a single member.
  5. */
  6. public Message(Address dest) {
  7.   setDest(dest);
  8.   headers=createHeaders(Util.DEFAULT_HEADERS);
  9. }

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

  1. protected Message msgFromXmitRsp(Message msg, NakAckHeader2 hdr) {
  2.   if(msg == null)
  3.     return null;
  4.   if(stats)
  5.     xmit_rsps_received.increment();
  6.   msg.setDest(null);
  7.   NakAckHeader2 newhdr=hdr.copy();
  8.   newhdr.type=NakAckHeader2.MSG; // change the type back from XMIT_RSP --> MSG
  9.   msg.putHeader(id,newhdr);
  10.   return msg;
  11. }

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

  1. private void send(Collection<Address> destinations, Message msg, boolean sendToMyself) {
  2.   if (log.isTraceEnabled()) {
  3.     log.trace("sending anycast total order message %s to %s", msg, destinations);
  4.   }
  5.   for (Address address : destinations) {
  6.     if (!sendToMyself && address.equals(localAddress)) {
  7.       continue;
  8.     }
  9.     Message cpy = msg.copy();
  10.     cpy.setDest(address);
  11.     down_prot.down(cpy);
  12.   }
  13. }

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

  1. public static List<Message> readMessageList(DataInput in, short transport_id) throws Exception {
  2.   List<Message> list=new LinkedList<>();
  3.   Address dest=Util.readAddress(in);
  4.   Address src=Util.readAddress(in);
  5.   // AsciiString cluster_name=Bits.readAsciiString(in); // not used here
  6.   short length=in.readShort();
  7.   byte[] cluster_name=length >= 0? new byte[length] : null;
  8.   if(cluster_name != null)
  9.     in.readFully(cluster_name, 0, cluster_name.length);
  10.   int len=in.readInt();
  11.   for(int i=0; i < len; i++) {
  12.     Message msg=new Message(false);
  13.     msg.readFrom(in);
  14.     msg.setDest(dest);
  15.     if(msg.getSrc() == null)
  16.       msg.setSrc(src);
  17.     // Now add a TpHeader back on, was not marshalled. Every message references the *same* TpHeader, saving memory !
  18.     msg.putHeader(transport_id, new TpHeader(cluster_name));
  19.     list.add(msg);
  20.   }
  21.   return list;
  22. }

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

  1. @Override
  2. public void deliver(Message message) {
  3.   message.setDest(localAddress);
  4.   if (log.isTraceEnabled()) {
  5.     log.trace("Deliver message %s (%s) in total order", message, message.getHeader(id));
  6.   }
  7.   up_prot.up(message);
  8.   statsCollector.incrementMessageDeliver();
  9. }

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

  1. protected void handleXmitRsp(Message msg, NakAckHeader2 hdr) {
  2.   if(msg == null)
  3.     return;
  4.   try {
  5.     if(stats)
  6.       xmit_rsps_received.increment();
  7.     msg.setDest(null);
  8.     NakAckHeader2 newhdr=hdr.copy();
  9.     newhdr.type=NakAckHeader2.MSG; // change the type back from XMIT_RSP --> MSG
  10.     msg.putHeader(id, newhdr);
  11.     handleMessage(msg, newhdr);
  12.     if(rebroadcasting)
  13.       checkForRebroadcasts();
  14.   }
  15.   catch(Exception ex) {
  16.     log.error(Util.getMessage("FailedToDeliverMsg"), local_addr, "retransmitted message", msg, ex);
  17.   }
  18. }

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

  1. protected static Message deserialize(Message msg) throws Exception {
  2.     try {
  3.       Message ret=Util.streamableFromBuffer(Message::new, msg.getRawBuffer(), msg.getOffset(), msg.getLength());
  4.       if(ret.getDest() == null)
  5.         ret.setDest(msg.getDest());
  6.       if(ret.getSrc() == null)
  7.         ret.setSrc(msg.getSrc());
  8.       return ret;
  9.     }
  10.     catch(Exception e) {
  11.       throw new Exception(String.format("failed deserialize message from %s", msg.src()), e);
  12.     }
  13.   }
  14. }

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

  1. forward_msg.setDest(target);
  2. forward_msg.setFlag(Message.Flag.DONT_BUNDLE);
  3. if(log.isTraceEnabled())
  4. if(flushing && running) {
  5.   forward_msg=val.copy();
  6.   forward_msg.setDest(target);
  7.   forward_msg.setFlag(Message.Flag.DONT_BUNDLE);
  8.   if(log.isTraceEnabled())

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

  1. public Object down(Message msg) {
  2.   if(msg.getDest() != null)
  3.     return down_prot.down(msg); // only process multicast messages
  4.   if(next == null) // view hasn'<></> been received yet, use the normal transport
  5.     return down_prot.down(msg);
  6.   // we need to copy the message, as we cannot do a msg.setSrc(next): the next retransmission
  7.   // would use 'next' as destination  !
  8.   Message copy=msg.copy(true);
  9.   short hdr_ttl=(short)(loopback? view_size -1 : view_size);
  10.   DaisyHeader hdr=new DaisyHeader(hdr_ttl);
  11.   copy.setDest(next);
  12.   copy.putHeader(getId(), hdr);
  13.   msgs_sent++;
  14.   if(loopback) {
  15.     if(log.isTraceEnabled()) log.trace(new StringBuilder("looping back message ").append(msg));
  16.     if(msg.getSrc() == null)
  17.       msg.setSrc(local_addr);
  18.     default_pool.execute(() -> up_prot.up(msg));
  19.   }
  20.   return down_prot.down(copy);
  21. }

代码示例来源：origin: apache/geode

  1. private Message createJGMessage(byte[] msgBytes, Address src, Address dest, short version) {
  2.  Message msg = new Message();
  3.  msg.setDest(dest);
  4.  msg.setSrc(src);
  5.  msg.setObject(msgBytes);
  6.  msg.setFlag(Message.Flag.NO_RELIABILITY);
  7.  msg.setFlag(Message.Flag.NO_FC);
  8.  msg.setFlag(Message.Flag.DONT_BUNDLE);
  9.  msg.setFlag(Message.Flag.OOB);
  10.  return msg;
  11. }

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

  1. message.setDest(destinations.iterator().next());

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

  1. Message msg=new Message(false);
  2. msg.readFrom(in);
  3. msg.setDest(dest);
  4. if(msg.getSrc() == null)
  5.   msg.setSrc(src);

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

  1. public Object up(Message msg) {
  2.   DaisyHeader hdr=msg.getHeader(getId());
  3.   if(hdr == null)
  4.     return up_prot.up(msg);
  5.   // 1. forward the message to the next in line if ttl > 0
  6.   short ttl=hdr.getTTL();
  7.   if(log.isTraceEnabled())
  8.     log.trace(local_addr + ": received message from " + msg.getSrc() + " with ttl=" + ttl);
  9.   if(--ttl > 0) {
  10.     Message copy=msg.copy(true);
  11.     copy.setDest(next);
  12.     copy.putHeader(getId(), new DaisyHeader(ttl));
  13.     msgs_forwarded++;
  14.     if(log.isTraceEnabled())
  15.       log.trace(local_addr + ": forwarding message to " + next + " with ttl=" + ttl);
  16.     down_prot.down(copy);
  17.   }
  18.   // 2. Pass up
  19.   msg.setDest(null);
  20.   return up_prot.up(msg);
  21. }

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

  1. public void up(MessageBatch batch) {
  2.   for(Message msg: batch) {
  3.     DaisyHeader hdr=msg.getHeader(getId());
  4.     if(hdr != null) {
  5.       // 1. forward the message to the next in line if ttl > 0
  6.       short ttl=hdr.getTTL();
  7.       if(log.isTraceEnabled())
  8.         log.trace(local_addr + ": received message from " + msg.getSrc() + " with ttl=" + ttl);
  9.       if(--ttl > 0) {
  10.         Message copy=msg.copy(true);
  11.         copy.setDest(next);
  12.         copy.putHeader(getId(), new DaisyHeader(ttl));
  13.         msgs_forwarded++;
  14.         if(log.isTraceEnabled())
  15.           log.trace(local_addr + ": forwarding message to " + next + " with ttl=" + ttl);
  16.         down_prot.down(copy);
  17.       }
  18.       // 2. Pass up
  19.       msg.setDest(null);
  20.     }
  21.   }
  22.   if(!batch.isEmpty())
  23.     up_prot.up(batch);
  24. }

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

  1. public Object down(Event evt) {
  2.   switch(evt.getType()) {
  3.     case Event.FORWARD_TO_COORD:
  4.       Address target=coord;
  5.       if(target == null)
  6.         throw new IllegalStateException("coord is null; dropping message");
  7.       Message msg=evt.getArg();
  8.       long msg_id=getNextId();
  9.       ForwardHeader hdr=new ForwardHeader(ForwardHeader.MSG, msg_id);
  10.       msg.putHeader(id, hdr);
  11.       msg.setDest(target);
  12.       if(log.isTraceEnabled())
  13.         log.trace(local_addr + ": forwarding message with id=" + msg_id + " to current coordinator " + target);
  14.       fwd_queue.send(msg_id, msg);
  15.       return null; // FORWARD_TO_COORD is not passed down any further
  16.     case Event.VIEW_CHANGE:
  17.       handleViewChange(evt.getArg());
  18.       break;
  19.     case Event.SET_LOCAL_ADDRESS:
  20.       local_addr=evt.getArg();
  21.       fwd_queue.setLocalAddr(local_addr);
  22.       break;
  23.   }
  24.   return down_prot.down(evt);
  25. }

代码示例来源：origin: apache/geode

  1. jmsg.setFlag(Message.Flag.NO_RELIABILITY);
  2. tmp.setDest(to);
  3. tmp.setSrc(this.jgAddress);
  4. logger.trace("Unicasting to {}", to);

代码示例来源：origin: apache/geode

  1. msg.setDest(null);
  2. msg.setSrc(src);
  3. setMessageFlags(gfmsg, msg);

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

  1. Message msg=msg_queue[i];
  2. if(msg != null && (dest == msg.getDest() || (Objects.equals(dest, msg.getDest())))) {
  3.   msg.setDest(dest); // avoid further equals() calls
  4.   numMsgs++;

代码示例来源：origin: org.jgroups/com.springsource.org.jgroups

  1. /** Public constructor
  2.  *  @param dest Address of receiver. If it is <em>null</em> then the message sent to the group.
  3.  *              Otherwise, it contains a single destination and is sent to that member.<p>
  4.  */
  5. public Message(Address dest) {
  6.   setDest(dest);
  7.   headers=createHeaders(7);
  8. }

代码示例来源：origin: org.jgroups/com.springsource.org.jgroups

  1. private void broadcast(Message msg) {
  2.   SequencerHeader hdr=(SequencerHeader)msg.getHeader(name);
  3.   hdr.type=SequencerHeader.BCAST; // we change the type of header, but leave the tag intact
  4.   msg.setDest(null); // mcast
  5.   msg.setSrc(local_addr); // the coord is sending it - this will be replaced with sender in deliver()
  6.   down_prot.down(new Event(Event.MSG, msg));
  7.   bcast_msgs++;
  8. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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