com.proofpoint.log.Logger.error()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(11.1k)|赞(0)|评价(0)|浏览(262)

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

Logger.error介绍

[英]Logs a message at ERROR level.

Usage example:

  1. logger.error("something really bad happened when connecting to %s:%d", host, port);

If the format string is invalid or the arguments are insufficient, an error will be logged and execution will continue.
[中]在错误级别记录消息。
用法示例：

  1. logger.error("something really bad happened when connecting to %s:%d", host, port);

如果格式字符串无效或参数不足，将记录错误并继续执行。

代码示例

代码示例来源：origin: com.proofpoint.platform/log

  1. /**
  2.  * Logs a message at ERROR level.
  3.  * <p>
  4.  * Usage example:
  5.  * <pre>
  6.  *    logger.error("something really bad happened when connecting to %s:%d", host, port);
  7.  * </pre>
  8.  * If the format string is invalid or the arguments are insufficient, an error will be logged and execution
  9.  * will continue.
  10.  *
  11.  * @param format a format string compatible with String.format()
  12.  * @param args arguments for the format string
  13.  */
  14. public void error(String format, Object... args)
  15. {
  16.   error(null, format, args);
  17. }

代码示例来源：origin: com.proofpoint.galaxy/galaxy-coordinator

  1. private void expectedStateStoreDown(Exception e)
  2. {
  3.   if (storeUp.compareAndSet(true, false)) {
  4.     log.error(e, "Expected state store is down");
  5.   }
  6. }

代码示例来源：origin: com.proofpoint.platform/concurrent

  1. private void drainQueue()
  2.   {
  3.     // INVARIANT: queue has at least one task available when this method is called
  4.     do {
  5.       try {
  6.         queue.poll().run();
  7.       }
  8.       catch (Throwable e) {
  9.         log.error(e, "Task failed");
  10.       }
  11.     }
  12.     while (queueSize.getAndDecrement() > maxThreads);
  13.   }
  14. }

代码示例来源：origin: com.proofpoint.platform/concurrent

  1. @Override
  2. public void execute(Runnable task)
  3. {
  4.   checkState(!failed.get(), "BoundedExecutor is in a failed state");
  5.   queue.add(task);
  6.   int size = queueSize.incrementAndGet();
  7.   if (size <= maxThreads) {
  8.     // If able to grab a permit (aka size <= maxThreads), then we are short exactly one draining thread
  9.     try {
  10.       coreExecutor.execute(this::drainQueue);
  11.     }
  12.     catch (Throwable e) {
  13.       failed.set(true);
  14.       log.error("BoundedExecutor state corrupted due to underlying executor failure");
  15.       throw e;
  16.     }
  17.   }
  18. }

代码示例来源：origin: com.proofpoint.galaxy/galaxy-coordinator

  1. @Override
  2.   public void run()
  3.   {
  4.     try {
  5.       updateAllCoordinators();
  6.     }
  7.     catch (Throwable e) {
  8.       log.error(e, "Unexpected exception updating coordinators");
  9.     }
  10.     try {
  11.       updateAllAgents();
  12.     }
  13.     catch (Throwable e) {
  14.       log.error(e, "Unexpected exception updating agents");
  15.     }
  16.   }
  17. }, 0, (long) statusExpiration.toMillis(), TimeUnit.MILLISECONDS);

代码示例来源：origin: com.proofpoint.galaxy/galaxy-coordinator

  1. @Override
  2.   public void setExpectedState(ExpectedSlotStatus slotStatus)
  3.   {
  4.     Preconditions.checkNotNull(slotStatus, "slotStatus is null");
  5.     try {
  6.       Files.write(codec.toJson(slotStatus), new File(dataDir, slotStatus.getId().toString() + ".json"), Charsets.UTF_8);
  7.     }
  8.     catch (Exception e) {
  9.       log.error(e, "Error writing expected slot status");
  10.     }
  11.   }
  12. }

代码示例来源：origin: com.proofpoint.platform/bootstrap

  1. private Bootstrap(Module applicationNameModule, Iterable<? extends Module> modules, boolean initializeLogging)
  2. {
  3.   if (initializeLogging) {
  4.     logging = Logging.initialize();
  5.     Thread.setDefaultUncaughtExceptionHandler((t, e) -> log.error(e, "Uncaught exception in thread %s", t.getName()));
  6.   }
  7.   else {
  8.     logging = null;
  9.   }
  10.   this.modules = ImmutableList.<Module>builder()
  11.       .add(requireNonNull(applicationNameModule, "applicationNameModule is null"))
  12.       .add(new LifeCycleModule())
  13.       .addAll(modules)
  14.       .build();
  15. }

代码示例来源：origin: com.proofpoint.platform/bootstrap

  1. private void stopList(Queue<Object> instances, Class<? extends Annotation> annotation)
  2. {
  3.   List<Object> reversedInstances = Lists.newArrayList(instances);
  4.   Collections.reverse(reversedInstances);
  5.   for (Object obj : reversedInstances) {
  6.     log.debug("Stopping %s", obj.getClass().getName());
  7.     LifeCycleMethods methods = methodsMap.get(obj.getClass());
  8.     for (Method preDestroy : methods.methodsFor(annotation)) {
  9.       log.debug("\t%s()", preDestroy.getName());
  10.       try {
  11.         preDestroy.invoke(obj);
  12.       }
  13.       catch (Exception e) {
  14.         log.error(e, "Stopping %s.%s() failed:", obj.getClass().getName(), preDestroy.getName());
  15.       }
  16.     }
  17.   }
  18. }

代码示例来源：origin: com.proofpoint.galaxy/galaxy-coordinator

  1. private void createInstanceTagsWithRetry(List<String> instanceIds, List<Tag> tags)
  2. {
  3.   Exception lastException = null;
  4.   for (int i = 0; i < 5; i++) {
  5.     try {
  6.       ec2Client.createTags(new CreateTagsRequest(instanceIds, tags));
  7.       return;
  8.     }
  9.     catch (Exception e) {
  10.       lastException = e;
  11.     }
  12.   }
  13.   log.error(lastException, "failed to create tags for instances: %s", instanceIds);
  14. }

代码示例来源：origin: com.proofpoint.galaxy/galaxy-agent

  1. @Override
  2. public SlotLifecycleState start(Deployment deployment)
  3. {
  4.   updateNodeConfig(deployment);
  5.   Command command = createCommand("start", deployment, launcherTimeout);
  6.   try {
  7.     command.execute(executor);
  8.     return RUNNING;
  9.   }
  10.   catch (CommandFailedException e) {
  11.     log.error("ENVIRONMENT:\n    %s", Joiner.on("\n    ").withKeyValueSeparator("=").join(command.getEnvironment()));
  12.     throw new RuntimeException("start failed: " + e.getMessage());
  13.   }
  14. }

代码示例来源：origin: com.proofpoint.platform/cassandra-experimental

  1. @Override
  2. public void stopRPCServer()
  3. {
  4.   synchronized (this) {
  5.     if (isRunning) {
  6.       log.info("Cassandra shutting down...");
  7.       server.stopServer();
  8.       try {
  9.         server.join();
  10.       }
  11.       catch (InterruptedException e) {
  12.         log.error(e, "Interrupted while waiting for thrift server to stop");
  13.         Thread.currentThread().interrupt();
  14.       }
  15.       isRunning = false;
  16.     }
  17.   }
  18. }

代码示例来源：origin: com.proofpoint.platform/rack

  1. Logger.get(Main.class).error(e);
  2. System.err.flush();
  3. System.out.flush();

代码示例来源：origin: com.proofpoint.galaxy/galaxy-coordinator

  1. @Override
  2. public void setServiceInventory(List<ServiceDescriptor> serviceInventory)
  3. {
  4.   if (agentStatus.getState() == ONLINE) {
  5.     Preconditions.checkNotNull(serviceInventory, "serviceInventory is null");
  6.     URI internalUri = agentStatus.getInternalUri();
  7.     try {
  8.       Request request = RequestBuilder.preparePut()
  9.           .setUri(uriBuilderFrom(internalUri).appendPath("/v1/serviceInventory").build())
  10.           .setHeader(CONTENT_TYPE, APPLICATION_JSON)
  11.           .setBodyGenerator(jsonBodyGenerator(serviceDescriptorsCodec, new ServiceDescriptorsRepresentation(environment, serviceInventory)))
  12.           .build();
  13.       httpClient.execute(request, createStatusResponseHandler());
  14.       if (serviceInventoryUp.compareAndSet(false, true)) {
  15.         log.info("Service inventory put succeeded for agent at %s", internalUri);
  16.       }
  17.     }
  18.     catch (Exception e) {
  19.       if (serviceInventoryUp.compareAndSet(true, false) && !log.isDebugEnabled()) {
  20.         log.error("Unable to post service inventory to agent at %s: %s", internalUri, e.getMessage());
  21.       }
  22.       log.debug(e, "Unable to post service inventory to agent at %s: %s", internalUri, e.getMessage());
  23.     }
  24.   }
  25. }

代码示例来源：origin: com.proofpoint.galaxy/galaxy-coordinator

  1. @Override
  2. public SlotStatus terminate()
  3. {
  4.   try {
  5.     Request request = RequestBuilder.prepareDelete()
  6.         .setUri(slotStatus.getSelf())
  7.         .setHeader(GALAXY_AGENT_VERSION_HEADER, agent.status().getVersion())
  8.         .setHeader(GALAXY_SLOT_VERSION_HEADER, slotStatus.getVersion())
  9.         .build();
  10.     SlotStatusRepresentation slotStatusRepresentation = httpClient.execute(request, createJsonResponseHandler(slotStatusCodec, Status.OK.getStatusCode()));
  11.     updateStatus(slotStatusRepresentation.toSlotStatus(slotStatus.getInstanceId()));
  12.     return slotStatus;
  13.   }
  14.   catch (Exception e) {
  15.     log.error(e);
  16.     return setErrorStatus(e.getMessage());
  17.   }
  18. }

代码示例来源：origin: com.proofpoint.galaxy/galaxy-coordinator

  1. @Override
  2.   public SlotStatus stop()
  3.   {
  4.     try {
  5.       Request request = RequestBuilder.preparePut()
  6.           .setUri(uriBuilderFrom(slotStatus.getSelf()).appendPath("lifecycle").build())
  7.           .setHeader(GALAXY_AGENT_VERSION_HEADER, agent.status().getVersion())
  8.           .setHeader(GALAXY_SLOT_VERSION_HEADER, slotStatus.getVersion())
  9.           .setBodyGenerator(createStaticBodyGenerator("stopped", UTF_8))
  10.           .build();
  11.       SlotStatusRepresentation slotStatusRepresentation = httpClient.execute(request, createJsonResponseHandler(slotStatusCodec, Status.OK.getStatusCode()));
  13.       updateStatus(slotStatusRepresentation.toSlotStatus(slotStatus.getInstanceId()));
  14.       return slotStatus;
  15.     }
  16.     catch (Exception e) {
  17.       log.error(e);
  18.       return setErrorStatus(e.getMessage());
  19.     }
  20.   }
  21. }

代码示例来源：origin: com.proofpoint.galaxy/galaxy-coordinator

  1. @Override
  2. public SlotStatus start()
  3. {
  4.   try {
  5.     Request request = RequestBuilder.preparePut()
  6.         .setUri(uriBuilderFrom(slotStatus.getSelf()).appendPath("lifecycle").build())
  7.         .setHeader(GALAXY_AGENT_VERSION_HEADER, agent.status().getVersion())
  8.         .setHeader(GALAXY_SLOT_VERSION_HEADER, slotStatus.getVersion())
  9.         .setBodyGenerator(createStaticBodyGenerator("running", UTF_8))
  10.         .build();
  11.     SlotStatusRepresentation slotStatusRepresentation = httpClient.execute(request, createJsonResponseHandler(slotStatusCodec, Status.OK.getStatusCode()));
  12.     updateStatus(slotStatusRepresentation.toSlotStatus(slotStatus.getInstanceId()));
  13.     return slotStatus;
  14.   }
  15.   catch (Exception e) {
  16.     log.error(e);
  17.     return setErrorStatus(e.getMessage());
  18.   }
  19. }

代码示例来源：origin: com.proofpoint.galaxy/galaxy-coordinator

  1. @Override
  2. public SlotStatus restart()
  3. {
  4.   try {
  5.     Request request = RequestBuilder.preparePut()
  6.         .setUri(uriBuilderFrom(slotStatus.getSelf()).appendPath("lifecycle").build())
  7.         .setHeader(GALAXY_AGENT_VERSION_HEADER, agent.status().getVersion())
  8.         .setHeader(GALAXY_SLOT_VERSION_HEADER, slotStatus.getVersion())
  9.         .setBodyGenerator(createStaticBodyGenerator("restarting", UTF_8))
  10.         .build();
  11.     SlotStatusRepresentation slotStatusRepresentation = httpClient.execute(request, createJsonResponseHandler(slotStatusCodec, Status.OK.getStatusCode()));
  12.     updateStatus(slotStatusRepresentation.toSlotStatus(slotStatus.getInstanceId()));
  13.     return slotStatus;
  14.   }
  15.   catch (Exception e) {
  16.     log.error(e);
  17.     return setErrorStatus(e.getMessage());
  18.   }
  19. }

代码示例来源：origin: com.proofpoint.galaxy/galaxy-coordinator

  1. @Override
  2. public SlotStatus assign(Installation installation)
  3. {
  4.   try {
  5.     Request request = RequestBuilder.preparePut()
  6.         .setUri(uriBuilderFrom(slotStatus.getSelf()).appendPath("assignment").build())
  7.         .setHeader(CONTENT_TYPE, APPLICATION_JSON)
  8.         .setHeader(GALAXY_AGENT_VERSION_HEADER, agent.status().getVersion())
  9.         .setHeader(GALAXY_SLOT_VERSION_HEADER, slotStatus.getVersion())
  10.         .setBodyGenerator(jsonBodyGenerator(installationCodec, InstallationRepresentation.from(installation)))
  11.         .build();
  12.     SlotStatusRepresentation slotStatusRepresentation = httpClient.execute(request, createJsonResponseHandler(slotStatusCodec, Status.OK.getStatusCode()));
  13.     updateStatus(slotStatusRepresentation.toSlotStatus(slotStatus.getInstanceId()));
  14.     return slotStatus;
  15.   }
  16.   catch (Exception e) {
  17.     log.error(e);
  18.     return setErrorStatus(e.getMessage());
  19.   }
  20. }

代码示例来源：origin: com.proofpoint.galaxy/galaxy-agent

  1. public static void main(String[] args)
  2.       throws Exception
  3.   {
  4.     try {
  5.       Bootstrap app = new Bootstrap(
  6.           new DiscoveryModule(),
  7.           new NodeModule(),
  8.           new HttpServerModule(),
  9.           new HttpEventModule(),
  10.           new JsonModule(),
  11.           new JaxrsModule(),
  12.           new MBeanModule(),
  13.           new JmxModule(),
  14.           new AgentMainModule());
  16.       app.strictConfig().initialize();
  17.     }
  18.     catch (Exception e) {
  19.       log.error(e, "Startup failed");
  20.       System.exit(1);
  21.     }
  22.   }
  23. }

代码示例来源：origin: com.proofpoint.galaxy/galaxy-coordinator

  1. public static void main(String[] args)
  2.       throws Exception
  3.   {
  4.     try {
  5.       Bootstrap app = new Bootstrap(
  6.           new NodeModule(),
  7.           new HttpServerModule(),
  8.           new HttpClientModule(Global.class),
  9.           new HttpEventModule(),
  10.           new DiscoveryModule(),
  11.           new JsonModule(),
  12.           new JaxrsModule(),
  13.           new MBeanModule(),
  14.           new JmxModule(),
  15.           new CoordinatorMainModule(),
  16.           installIfPropertyEquals(new LocalProvisionerModule(), "coordinator.provisioner", "local"),
  17.           installIfPropertyEquals(new AwsProvisionerModule(), "coordinator.provisioner", "aws"));
  19.       app.strictConfig().initialize();
  20.     }
  21.     catch (Throwable e) {
  22.       log.error(e, "Startup failed");
  23.       System.exit(1);
  24.     }
  25.   }
  26. }

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

Logger

相关文章

    查看更多

    热门标签

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

    最新文章

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