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

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

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

Message.getObject介绍

[英]Uses Java serialization to create an object from the buffer of the message. Note that this is dangerous when using your own classloader, e.g. inside of an application server ! Most likely, JGroups will use the system classloader to deserialize the buffer into an object, whereas (for example) a web application will want to use the webapp's classloader, resulting in a ClassCastException. The recommended way is for the application to use their own serialization and only pass byte[] buffer to JGroups.
[中]使用Java序列化从消息缓冲区创建对象。请注意，使用自己的类加载器（例如在应用程序服务器内部）时，这是危险的！最有可能的情况是，JGroups将使用系统类加载器将缓冲区反序列化为对象，而（例如）web应用程序将希望使用webapp的类加载器，从而导致ClassCastException。建议应用程序使用自己的序列化，只将字节[]缓冲区传递给JGroup。

代码示例

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

  1. public <T extends Object> T getObject() {
  2.   return getObject(null);
  3. }

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

  1. public void receive(Message msg) {
  2.     System.out.println("<< " + msg.getObject() + " [" + msg.getSrc() + "]");
  3.   }
  4. });

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

  1. public void receive(Message msg) {
  2.   String line="[" + msg.getSrc() + "]: " + msg.getObject();
  3.   System.out.println(line);
  4. }

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

  1. public void receive(Message msg) {
  2.   System.out.println("-- received msg " + msg.getObject() + " from " + msg.getSrc());
  3. }

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

  1. public void receive(Message msg) {
  2.   T obj=raw_msgs? (T)msg : (T)msg.getObject();
  3.   list.add(obj);
  4.   if(verbose) {
  5.     System.out.println((name() != null? name() + ":" : "") + " received message from " + msg.getSrc() + ": " + obj);
  6.   }
  7. }

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

  1. @Override
  2. public void receive(Message msg) {
  3.   DataMessage dataMessage = (DataMessage) msg.getObject();
  4.   switch (dataMessage.type) {
  5.     case DataMessage.FINISH:
  6.       testGroupMulticastOrder.memberFinished(msg.getSrc());
  7.       break;
  8.     case DataMessage.DATA:
  9.       if (start == 0) {
  10.         start = System.nanoTime();
  11.       }
  12.       synchronized (messageList) {
  13.         messageList.add(dataMessage.data);
  14.       }
  15.       receivedBytes += (dataMessage.data.getBytes().length + 1);
  16.       receivedMsgs++;
  17.       stop = System.nanoTime();
  18.       break;
  19.     default:
  20.       break;
  21.   }
  22. }

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

  1. public void receive(Message msg) {
  2.   Address sender=msg.getSrc();
  3.   System.out.println("<< " + msg.getObject() + " from " + sender);
  4.   Address dst=msg.getDest();
  5.   if(dst == null) {
  6.     Message rsp=new Message(msg.getSrc(), "this is a response");
  7.     try {
  8.       ch.send(rsp);
  9.     }
  10.     catch(Exception e) {
  11.       e.printStackTrace();
  12.     }
  13.   }
  14. }

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

  1. public Object down(Message msg) {
  2.     if(msg.getLength() > 0) {
  3.       try {
  4.         Long payload=msg.getObject();
  5.         if(payload != null) {
  6.           if(payload == seqno) {
  7.             synchronized(this) {
  8.               if(num_discards < 3) {
  9.                 num_discards++;
  10.                 return null;
  11.               }
  12.             }
  13.           }
  14.           if(payload == duplicate) { // inject a duplicate message
  15.             super.down(msg); // pass it down, will passed down a second time by the default down_prot.down(evt)
  16.           }
  17.         }
  18.       }
  19.       catch(Throwable t) {
  20.         ;
  21.       }
  22.     }
  23.     return down_prot.down(msg);
  24.   }
  25. }

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

  1. Result res=msg.getObject();
  2. results.add(msg.getSrc(), res);
  3. if(initiator && results.hasAllResponses()) {
  4. ConfigChange config_change=msg.getObject();
  5. handleConfigChange(config_change);
  6. break;
  7. handleConfigResponse(msg.getObject());
  8. break;

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

  1. /** Callback. Process the contents of the message; typically an _add() or _set() request */
  2. public void receive(Message msg) {
  3.   Request req=null;
  4.   if(msg == null || msg.getLength() == 0)
  5.     return;
  6.   try {
  7.     req=msg.getObject();
  8.     String fqn=req.fqn;
  9.     switch(req.type) {
  10.       case Request.PUT:
  11.         if(req.key != null && req.value != null)
  12.           _put(fqn, req.key, req.value);
  13.         else
  14.           _put(fqn, req.data);
  15.         break;
  16.       case Request.REMOVE:
  17.         if(req.key != null)
  18.           _remove(fqn, req.key);
  19.         else
  20.           _remove(fqn);
  21.         break;
  22.       default:
  23.         if(log.isErrorEnabled()) log.error("type " + req.type + " unknown");
  24.         break;
  25.     }
  26.   }
  27.   catch(Exception ex) {
  28.     if(log.isErrorEnabled()) log.error("failed unmarshalling request: " + ex);
  29.   }
  30. }

代码示例来源：origin: org.jboss.errai/errai-bus

  1. public static Message getErraiMessage(final org.jgroups.Message message) {
  2.  return MessageFactory.createCommandMessage(IntrabusQueueSession.INSTANCE, String.valueOf(message.getObject()));
  3. }

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

  1. return up_prot.up(msg);
  2. Request req=msg.getObject();
  3. if(log.isTraceEnabled())
  4.   log.trace("[" + local_addr + "] <-- [" + msg.getSrc() + "] " + req);

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

  1. /** Tries to read an object from the message's buffer and prints it */
  2. public String toStringAsObject() {
  3.   if(buf == null) return null;
  4.   try {
  5.     Object obj=getObject();
  6.     return obj != null ? obj.toString() : "";
  7.   }
  8.   catch(Exception e) {  // it is not an object
  9.     return "";
  10.   }
  11. }

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

  1. public void receive(Message msg) {
  2.   Object o;
  3.   try {
  4.     o=msg.getObject();
  5.     ta.append(o + " [" + msg.getSrc() + "]\n");
  6.     history.add(o);
  7.   }
  8.   catch(Exception e) {
  9.     ta.append("Chat.receive(): " + e);
  10.   }
  11. }

代码示例来源：origin: org.apache.camel/camel-jgroups

  1. public Exchange createExchange(Message message) {
  2.   Exchange exchange = createExchange();
  3.   exchange.getIn().setHeader(HEADER_JGROUPS_ORIGINAL_MESSAGE, message);
  4.   exchange.getIn().setHeader(HEADER_JGROUPS_SRC, message.getSrc());
  5.   exchange.getIn().setHeader(HEADER_JGROUPS_DEST, message.getDest());
  6.   exchange.getIn().setBody(message.getObject());
  7.   return exchange;
  8. }

代码示例来源：origin: org.codehaus.hydra-cache/harmony

  1. @Override
  2. public void receive(Message msg) {
  3.   Validate.notNull(msg, "Response message can not be null");
  4.   Object payload = msg.getObject();
  5.   if (log.isDebugEnabled())
  6.     log.debug("Received message: " + msg + " with object: " + payload);
  7.   Validate.isTrue(payload instanceof ControlMessage);
  8.   ControlMessage controlMessage = (ControlMessage) payload;
  9.   handleControlMessage(controlMessage);
  10. }

代码示例来源：origin: org.xwiki.platform/xwiki-platform-observation-remote

  1. @Override
  2.   public void receive(Message msg)
  3.   {
  4.     RemoteEventData remoteEvent = (RemoteEventData) msg.getObject();
  6.     this.logger.debug("Received JGroups remote event [{}]", remoteEvent);
  8.     getRemoteObservationManager().notify(remoteEvent);
  9.   }
  10. }

代码示例来源：origin: org.atmosphere/atmosphere-jgroups

  1. /** {@inheritDoc} */
  2.   @Override
  3.   public void receive(final Message message) {
  4.     final Object msg = message.getObject();
  5.     if (msg != null && BroadcastMessage.class.isAssignableFrom(msg.getClass())) {
  6.       BroadcastMessage b = BroadcastMessage.class.cast(msg);
  7.       if (b.getTopicId().equalsIgnoreCase(getID())) {
  8.         broadcastReceivedMessage(b.getMessage());
  9.       }
  10.     }
  11.   }
  12. });

代码示例来源：origin: org.jboss.eap/wildfly-client-all

  1. public void receive(Message msg) {
  2.   T obj=raw_msgs? (T)msg : (T)msg.getObject();
  3.   list.add(obj);
  4.   if(verbose) {
  5.     System.out.println((name() != null? name() + ":" : "") + " received message from " + msg.getSrc() + ": " + obj);
  6.   }
  7. }

代码示例来源：origin: org.axonframework/axon-distributed-commandbus

  1. @Override
  2. public void receive(Message msg) {
  3.   Object message = msg.getObject();
  4.   if (message instanceof JoinMessage) {
  5.     processJoinMessage(msg, (JoinMessage) message);
  6.   } else if (message instanceof DispatchMessage) {
  7.     processDispatchMessage(msg, (DispatchMessage) message);
  8.   } else if (message instanceof ReplyMessage) {
  9.     processReplyMessage((ReplyMessage) message);
  10.   }
  11. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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