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

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

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

Util.getMessage介绍

暂无

代码示例

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

  1. public void warning(SAXParseException exception) throws SAXException {
  2.   log.warn(Util.getMessage("ParseFailure"), exception);
  3. }

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

  1. public ConnBuilder method(String method) {
  2.   try {
  3.     con.setRequestMethod(method);
  4.   } catch (ProtocolException e) {
  5.     log.error(Util.getMessage("ProtocolError"), e);
  6.   }
  7.   return this;
  8. }

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

  1. protected boolean deleteFile(File file) {
  2.   boolean result = true;
  3.   if(file != null && file.exists()) {
  4.     try {
  5.       result=file.delete();
  6.       log.trace("deleted file %s: result=%b ", file.getAbsolutePath(), result);
  7.     }
  8.     catch(Throwable e) {
  9.       log.error(Util.getMessage("FailedToDeleteFile") + file.getAbsolutePath(), e);
  10.     }
  11.   }
  12.   return result;
  13. }

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

  1. /**
  2.  * Attempts to delete the provided file.<br>
  3.  * Logging is performed on the result
  4.  * @param file
  5.  * @return
  6.  */
  7. protected boolean deleteFile(File file) {
  8.   boolean result = true;
  9.   if(file != null && file.exists()) {
  10.     try {
  11.       result=file.delete();
  12.       if(log.isTraceEnabled())
  13.         log.trace("Deleted file result: "+file.getAbsolutePath() +" : "+result);
  14.     }
  15.     catch(Throwable e) {
  16.       log.error(Util.getMessage("FailedToDeleteFile") + file.getAbsolutePath(), e);
  17.     }
  18.   }
  19.   return result;
  20. }

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

  1. protected void handleTaskRejectedResponse(Address source, long requestId) {
  2.   Runnable runnable = _awaitingReturn.remove(new Owner(
  3.     source, requestId));
  4.   if (runnable != null) {
  5.     _awaitingConsumer.add(runnable);
  6.     Long taskRequestId = _requestId.get(runnable);
  7.     if (taskRequestId != requestId) {
  8.       log.warn("Task Request Id doesn't match in rejection");
  9.     }
  10.     sendToCoordinator(RUN_REQUEST, taskRequestId, local_addr);
  11.   }
  12.   else {
  13.     log.error(Util.getMessage("ErrorResubmittingTaskForRequestId") + requestId);
  14.   }
  15. }

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

  1. /**
  2.  *
  3.  * @param interfaces List<NetworkInterface>. Guaranteed to have no duplicates
  4.  * @param s
  5.  * @param mcastAddr
  6.  * @throws IOException
  7.  */
  8. protected void bindToInterfaces(List<NetworkInterface> interfaces,
  9.                MulticastSocket s,
  10.                InetAddress mcastAddr) {
  11.   SocketAddress tmp_mcast_addr=new InetSocketAddress(mcastAddr, mcast_port);
  12.   for(NetworkInterface intf: interfaces) {
  13.     //[ JGRP-680] - receive_on_all_interfaces requires every NIC to be configured
  14.     try {
  15.       s.joinGroup(tmp_mcast_addr, intf);
  16.       log.trace("joined %s on %s", tmp_mcast_addr, intf.getName());
  17.     }
  18.     catch(IOException e) {
  19.       log.warn(Util.getMessage("InterfaceJoinFailed"), tmp_mcast_addr, intf.getName());
  20.     }
  21.   }
  22. }

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

  1. protected void clearTable(String clustername) {
  2.   try(Connection conn=getConnection()) {
  3.     try (PreparedStatement ps=conn.prepareStatement(clear_sql)) {
  4.       // check presence of cluster_name parameter for backwards compatibility
  5.       if (clear_sql.indexOf('?') >= 0) {
  6.         ps.setString(1, clustername);
  7.       } else {
  8.         log.debug("Please update your clear_sql to include cluster_name parameter.");
  9.       }
  10.       if(log.isTraceEnabled())
  11.         log.trace("%s: SQL for clearing the table: %s", local_addr, ps);
  12.       ps.execute();
  13.     }
  14.   }
  15.   catch(SQLException e) {
  16.     log.error(Util.getMessage("ErrorClearingTable"), e);
  17.   }
  18. }

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

  1. /** Check if I'm in memberList, too */
  2. /*public void start() throws Exception {
  3.   super.start();
  4.   IpAddress self=(IpAddress)auth.getPhysicalAddress();
  5.   if(!isInMembersList(self))
  6.     throw new IllegalStateException("own physical address " + self + " is not in members (" + memberList + ")");
  7. } */
  8. public boolean authenticate(AuthToken token, Message msg) {
  9.   if ((token != null) && (token instanceof FixedMembershipToken) && (this.memberList != null)) {
  10.     PhysicalAddress src = (PhysicalAddress) auth.down(new Event(Event.GET_PHYSICAL_ADDRESS, msg.getSrc()));
  11.     if (src == null) {
  12.       log.error(Util.getMessage("DidnTFindPhysicalAddressFor") + msg.getSrc());
  13.       return false;
  14.     }
  15.     return isInMembersList((IpAddress)src);
  16.   }
  17.   if (log.isWarnEnabled())
  18.     log.warn("Invalid AuthToken instance - wrong type or null");
  19.   return false;
  20. }

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

  1. protected void deliver(Message msg, Address sender, long seqno, String error_msg) {
  2.   if(is_trace)
  3.     log.trace("%s: delivering %s#%d", local_addr, sender, seqno);
  4.   try {
  5.     up_prot.up(msg);
  6.   }
  7.   catch(Throwable t) {
  8.     log.error(Util.getMessage("FailedToDeliverMsg"), local_addr, error_msg, msg, t);
  9.   }
  10. }

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

  1. protected void deliverMessage(final Message msg, final Address sender, final long seqno) {
  2.   if(is_trace)
  3.     log.trace("%s: delivering %s#%s", local_addr, sender, seqno);
  4.   try {
  5.     up_prot.up(msg);
  6.   }
  7.   catch(Throwable t) {
  8.     log.warn(Util.getMessage("FailedToDeliverMsg"), local_addr, msg.isFlagSet(Message.Flag.OOB) ?
  9.      "OOB message" : "message", msg, t);
  10.   }
  11. }

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

  1. protected void closeConnection(final Connection connection) {
  2.   try {
  3.     connection.close();
  4.   } catch (SQLException e) {
  5.     log.error(Util.getMessage("ErrorClosingConnectionToJDBCPINGDatabase"), e);
  6.   }
  7. }

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

  1. protected Attribute getNamedAttribute(String name) {
  2.   AttributeEntry entry=atts.get(name);
  3.   if(entry != null) {
  4.     try {
  5.       return new Attribute(name, entry.getter.invoke(null));
  6.     }
  7.     catch(Exception e) {
  8.       log.warn(Util.getMessage("AttrReadFailure"), name, e);
  9.     }
  10.   }
  11.   else {
  12.     log.warn(Util.getMessage("MissingAttribute"), name);
  13.   }
  14.   return null;
  15. }

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

  1. @Override
  2. public void findMembers(List<Address> members, boolean initial_discovery, Responses responses) {
  3.   if(this.cluster_name == null) {
  4.     log.error(Util.getMessage("ClusternameIsNullCannotGetMembership"));
  5.     return;
  6.   }
  7.   log.trace("fetching members from GossipRouter(s)");
  8.   stubManager.forEach( stub -> {
  9.     try {
  10.       stub.getMembers(TCPGOSSIP.this.cluster_name, TCPGOSSIP.this);
  11.     }
  12.     catch(Throwable t) {
  13.       log.warn("failed fetching members from %s: %s, cause: %s", stub.gossipRouterAddress(), t, t.getCause());
  14.     }
  15.   });
  16. }

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

  1. @Override
  2. protected void readAll(List<Address> members, String clustername, Responses responses) {
  3.   try {
  4.     List<String> objects = rackspaceClient.listObjects(container);
  5.     for(String object: objects) {
  6.       List<PingData> list=null;
  7.       byte[] bytes = rackspaceClient.readObject(container, object);
  8.       if((list=read(new ByteArrayInputStream(bytes))) == null) {
  9.         log.warn("failed reading " + object);
  10.         continue;
  11.       }
  12.       for(PingData data: list) {
  13.         if(members == null || members.contains(data.getAddress()))
  14.           responses.addResponse(data, data.isCoord());
  15.         if(local_addr != null && !local_addr.equals(data.getAddress()))
  16.           addDiscoveryResponseToCaches(data.getAddress(), data.getLogicalName(), data.getPhysicalAddr());
  17.       }
  18.     }
  19.   } catch (Exception e) {
  20.     log.error(Util.getMessage("ErrorUnmarshallingObject"), e);
  21.   }
  22. }

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

  1. public void handleMergeCancelled(MergeId merge_id) {
  2.   try {
  3.     gms.stopFlush();
  4.   }
  5.   catch(Throwable t) {
  6.     log.error(Util.getMessage("StopFlushFailed"), t.getMessage());
  7.   }
  8.   log.trace("%s: merge %s is cancelled", gms.local_addr, merge_id);
  9.   cancelMerge(merge_id);
  10. }

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

  1. protected void deliverBatch(MessageBatch batch) {
  2.   try {
  3.     if(batch.isEmpty())
  4.       return;
  5.     if(is_trace) {
  6.       Message first=batch.first(), last=batch.last();
  7.       StringBuilder sb=new StringBuilder(local_addr + ": delivering");
  8.       if(first != null && last != null) {
  9.         UnicastHeader3 hdr1=first.getHeader(id), hdr2=last.getHeader(id);
  10.         sb.append(" #").append(hdr1.seqno).append(" - #").append(hdr2.seqno);
  11.       }
  12.       sb.append(" (" + batch.size()).append(" messages)");
  13.       log.trace(sb);
  14.     }
  15.     up_prot.up(batch);
  16.   }
  17.   catch(Throwable t) {
  18.     log.warn(Util.getMessage("FailedToDeliverMsg"), local_addr, "batch", batch, t);
  19.   }
  20. }

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

  1. public ConnBuilder method(String method) {
  2.   try {
  3.     con.setRequestMethod(method);
  4.   } catch (ProtocolException e) {
  5.     log.error(Util.getMessage("ProtocolError"), e);
  6.   }
  7.   return this;
  8. }

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

  1. protected boolean setNamedAttribute(Attribute attribute) {
  2.   AttributeEntry entry=atts.get(attribute.getName());
  3.   if(entry != null) {
  4.     try {
  5.       entry.setter.invoke(attribute.getValue());
  6.       return true;
  7.     }
  8.     catch(Throwable e) {
  9.       log.warn(Util.getMessage("AttrWriteFailure"), attribute.getName(), e);
  10.     }            
  11.   }
  12.   else {
  13.     log.warn(Util.getMessage("MissingAttribute"), attribute.getName());
  14.   }
  15.   return false;
  16. }

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

  1. protected synchronized void writeNodeToDisk(Address logical_addr, PhysicalAddress physical_addr) {
  2.   String filename=addressAsString(logical_addr);
  3.   // first write all data to a temporary file
  4.   // this is because the writing can be very slow under some circumstances
  5.   File tmpFile=null, destination=null;
  6.   try {
  7.     tmpFile=writeToTempFile(root_dir, logical_addr, physical_addr, NameCache.get(logical_addr));
  8.     if(tmpFile == null)
  9.       return;
  10.     destination=new File(root_dir, filename + SUFFIX);
  11.     //do a file move, this is much faster and could be considered atomic on most operating systems
  12.     FileChannel src_ch=new FileInputStream(tmpFile).getChannel();
  13.     FileChannel dest_ch=new FileOutputStream(destination).getChannel();
  14.     src_ch.transferTo(0,src_ch.size(),dest_ch);
  15.     src_ch.close();
  16.     dest_ch.close();
  17.     if(log.isTraceEnabled())
  18.       log.trace("Moved: " + tmpFile.getName() + "->" + destination.getName());
  19.   }
  20.   catch(Exception ioe) {
  21.     log.error(Util.getMessage("AttemptToMoveFailedAt") + tmpFile.getName() + "->" + destination.getName(), ioe);
  22.   }
  23.   finally {
  24.     deleteFile(tmpFile);
  25.   }
  26. }

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

  1. @Override
  2. protected void readAll(List<Address> members, String clustername, Responses responses) {
  3.   try {
  4.     List<String> objects = swiftClient.listObjects(container);
  5.     for(String object: objects) {
  6.       List<PingData> list=null;
  7.       byte[] bytes = swiftClient.readObject(container, object);
  8.       if((list=read(new ByteArrayInputStream(bytes))) == null) {
  9.         log.warn("failed reading " + object);
  10.         continue;
  11.       }
  12.       for(PingData data: list) {
  13.         if(members == null || members.contains(data.getAddress()))
  14.           responses.addResponse(data, data.isCoord());
  15.         if(local_addr != null && !local_addr.equals(data.getAddress()))
  16.           addDiscoveryResponseToCaches(data.getAddress(), data.getLogicalName(), data.getPhysicalAddr());
  17.       }
  18.     }
  19.   } catch (Exception e) {
  20.     log.error(Util.getMessage("ErrorUnmarshallingObject"), e);
  21.   }
  22. }

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

Util

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Util类方法

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