org.eclipse.jetty.util.log.Log.getLog()方法的使用及代码示例

x33g5p2x  于2022-01-23 转载在 其他  
字(6.6k)|赞(0)|评价(0)|浏览(163)

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

Log.getLog介绍

暂无

代码示例

代码示例来源:origin: apache/incubator-dubbo

Log.getLog().setDebugEnabled(false);

代码示例来源:origin: apache/incubator-dubbo

Log.getLog().setDebugEnabled(false);

代码示例来源:origin: sixt/ja-micro

public static void compose(Server server) {
    //Servlets + Guice
    ServletContextHandler servletContextHandler = new ServletContextHandler(server, "/", ServletContextHandler.SESSIONS);
    servletContextHandler.addFilter(GuiceFilter.class, "/*", EnumSet.allOf(DispatcherType.class));
    servletContextHandler.addServlet(DefaultServlet.class, "/");

    //JMX stuff...
    MBeanContainer mbContainer = new MBeanContainer(ManagementFactory.getPlatformMBeanServer());
    server.addEventListener(mbContainer);
    server.addBean(mbContainer);
    server.addBean(Log.getLog());
  }
}

代码示例来源:origin: io.tesla.aether.test/aether-test-harness

private void behave(HttpServletRequest req, HttpServletResponse resp) throws ServletException {
 Log.getLog().debug("behaving: " + req.getPathInfo() + ", " + Arrays.toString(behaviour));
 try {
  Map<Object, Object> ctx = new HashMap<Object, Object>();
  for (Behaviour b : behaviour) {
   if (!b.execute(req, resp, ctx)) {
    break;
   }
  }
 } catch (Exception e) {
  throw new ServletException(e.getMessage(), e);
 }
}

代码示例来源:origin: org.mule.transports/mule-transport-jetty

protected void setupJettyLogging()
{
  if ((Log.getLog() instanceof JettyLogger) == false)
  {
    Log.setLog(new JettyLogger());
  }
}

代码示例来源:origin: bitronix/btm

protected void doStart() throws Exception {
  Log.getLog().info("Starting Bitronix Transaction Manager");
  TransactionManagerServices.getTransactionManager();
}

代码示例来源:origin: org.apache.hadoop/hadoop-mapreduce-client-app

/**
 * Notify the URL just once. Use best effort.
 */
protected boolean notifyURLOnce() {
 boolean success = false;
 try {
  Log.getLog().info("Job end notification trying " + urlToNotify);
  HttpURLConnection conn =
   (HttpURLConnection) urlToNotify.openConnection(proxyToUse);
  conn.setConnectTimeout(timeout);
  conn.setReadTimeout(timeout);
  conn.setAllowUserInteraction(false);
  if(conn.getResponseCode() != HttpURLConnection.HTTP_OK) {
   Log.getLog().warn("Job end notification to " + urlToNotify
     + " failed with code: " + conn.getResponseCode() + " and message \""
     + conn.getResponseMessage() + "\"");
  }
  else {
   success = true;
   Log.getLog().info("Job end notification to " + urlToNotify
     + " succeeded");
  }
 } catch(IOException ioe) {
  Log.getLog().warn("Job end notification to " + urlToNotify + " failed",
    ioe);
 }
 return success;
}

代码示例来源:origin: io.tesla.aether.test/aether-test-harness

public boolean execute( HttpServletRequest request, HttpServletResponse response, Map<Object, Object> ctx )
  throws Exception
{
  String headers = "";
  @SuppressWarnings( "unchecked" )
  Enumeration<String> names = request.getHeaderNames();
  while ( names.hasMoreElements() )
  {
    String name = names.nextElement();
    String value = request.getHeader( name );
    headers += name + ": " + value + "\n";
  }
  Log.getLog().debug( headers );
  String authHeader = request.getHeader( "Proxy-Authorization" );
  if ( authHeader == null )
  {
    response.setContentType( "text/html" );
    response.addHeader( "Proxy-Authenticate", "BASIC realm=\"Test Proxy\"" );
    response.sendError( 407, "proxy auth required" );
    challenged = true;
    return false;
  }
  else
  {
    String expected = new String( B64Code.encode( ( user + ":" + password ).getBytes( "UTF-8" ) ) );
    this.authorized = expected.equals( authHeader.split( " ", 2 )[1] );
  }
  return this.authorized;
}

代码示例来源:origin: org.apache.hadoop/hadoop-mapreduce-client-app

proxyToUse = new Proxy(proxyType,
  new InetSocketAddress(hostname, port));
 Log.getLog().info("Job end notification using proxy type \""
   + proxyType + "\" hostname \"" + hostname + "\" and port \"" + port
   + "\"");
} catch(NumberFormatException nfe) {
 Log.getLog().warn("Job end notification couldn't parse configured"
   + "proxy's port " + portConf + ". Not going to use a proxy");

代码示例来源:origin: io.tesla.aether.test/aether-test-harness

Log.getLog().debug( request.getMethod() + " " + path );

代码示例来源:origin: bitronix/btm

protected void doStop() throws Exception {
  Log.getLog().info("Shutting down Bitronix Transaction Manager");
  TransactionManagerServices.getTransactionManager().shutdown();
}

代码示例来源:origin: org.atteo.moonshine/jetty

@Override
public void start() {
  server = new Server();
  server.setHandler(handler.getHandler());
  for (ConnectorConfig config : connectors) {
    server.addConnector(config.getConnector(server));
  }
  if (mbeanServer != null) {
    MBeanContainer mbContainer = new MBeanContainer(mbeanServer);
    server.addBean(mbContainer);
    server.addBean(Log.getLog());
  }
  try {
    server.start();
    printPorts();
  } catch (RuntimeException e) {
    throw e;
  } catch (Exception e) {
    throw new RuntimeException(e);
  }
}

代码示例来源:origin: org.apache.hadoop/hadoop-mapreduce-client-app

urlToNotify = new URL(userUrl);
} catch (MalformedURLException mue) {
 Log.getLog().warn("Job end notification couldn't parse " + userUrl, mue);
 return;
 Log.getLog().info("Job end notification attempts left " + numTries);
 success = notifyURLOnce();
 if (!success) {
 Log.getLog().warn("Job end notification failed to notify : "
   + urlToNotify);
} else {
 Log.getLog().info("Job end notification succeeded for "
   + jobReport.getJobId());

代码示例来源:origin: org.apache.hadoop/hadoop-yarn-server-resourcemanager

public NodeHeartbeatResponse nodeHeartbeat(ApplicationAttemptId attemptId,
  long containerId, ContainerState containerState) throws Exception {
 ContainerStatus containerStatus = BuilderUtils.newContainerStatus(
   BuilderUtils.newContainerId(attemptId, containerId), containerState,
   "Success", 0, capability);
 ArrayList<ContainerStatus> containerStatusList =
   new ArrayList<ContainerStatus>(1);
 containerStatusList.add(containerStatus);
 Log.getLog().info("ContainerStatus: " + containerStatus);
 return nodeHeartbeat(containerStatusList,
   Collections.<Container>emptyList(), true, responseId);
}

代码示例来源:origin: pierre/meteo

server.getContainer().addEventListener(mbContainer);
server.addBean(mbContainer);
mbContainer.addBean(Log.getLog());

代码示例来源:origin: org.visallo/visallo-jetty-server

server.addEventListener(mbContainer);
server.addBean(mbContainer);
server.addBean(Log.getLog());

代码示例来源:origin: org.apache.dubbo/dubbo

Log.getLog().setDebugEnabled(false);

代码示例来源:origin: org.apache.dubbo/dubbo-remoting-http

Log.getLog().setDebugEnabled(false);

代码示例来源:origin: org.apache.hadoop/hadoop-yarn-server-applicationhistoryservice

int num = 1000000;
Log.getLog().info("Start test for " + num);
Log.getLog().info("Duration for " + num + ": " + duration);

相关文章