java.util.logging.StreamHandler源码实例Demo-ICode联盟

类java.util.logging.StreamHandler源码实例Demo

下面列出了怎么用java.util.logging.StreamHandler的API类实例代码及写法，或者点击链接到github查看源代码。

源代码1 项目： netbeans 文件： DispatchingHandlerTest.java

public void testOwnFormatter() throws UnsupportedEncodingException {
    class MyFrmtr extends Formatter {
        private int cnt;
        @Override
        public String format(LogRecord record) {
            cnt++;
            return record.getMessage();
        }
    }
    MyFrmtr my = new MyFrmtr();
    
    ByteArrayOutputStream os = new ByteArrayOutputStream();
    StreamHandler sh = new StreamHandler(os, NbFormatter.FORMATTER);
    DispatchingHandler dh = new DispatchingHandler(sh, 10);
    dh.setFormatter(my);
    dh.publish(new LogRecord(Level.WARNING, "Ahoj"));
    dh.flush();
    String res = new String(os.toByteArray(), "UTF-8");
    assertEquals("Only the message is written", "Ahoj", res);
    assertEquals("Called once", 1, my.cnt);
}

源代码2 项目： netbeans 文件： ExceptionTest.java

/**
 * Test PayaraException with no parameters specified throwing
 * and logging.
 */
@Test
public void testPayaraExceptionWithNothing() {
    // this message must match PayaraIdeException() constructor
    // log message.
    String gfieMsg = "Caught PayaraIdeException.";
    java.util.logging.Logger logger = Logger.getLogger();
    Level logLevel = logger.getLevel();
    OutputStream logOut = new ByteArrayOutputStream(256);
    Handler handler = new StreamHandler(logOut, new SimpleFormatter());
    handler.setLevel(Level.WARNING);
    logger.addHandler(handler);       
    logger.setLevel(Level.WARNING);
    try {
        throw new PayaraIdeException();
    } catch (PayaraIdeException gfie) {
        handler.flush();
    } finally {
        logger.removeHandler(handler);
        handler.close();
        logger.setLevel(logLevel);
    }
    String logMsg = logOut.toString();
    int contains = logMsg.indexOf(gfieMsg);
    assertTrue(contains > -1);
}

源代码3 项目： netbeans 文件： ExceptionTest.java

/**
 * Test PayaraException with message throwing and logging.
 */
@Test
public void testPayaraExceptionWithMsg() {
    String gfieMsg = "Test exception";
    java.util.logging.Logger logger = Logger.getLogger();
    Level logLevel = logger.getLevel();
    OutputStream logOut = new ByteArrayOutputStream(256);
    Handler handler = new StreamHandler(logOut, new SimpleFormatter());
    handler.setLevel(Level.WARNING);
    logger.addHandler(handler);       
    logger.setLevel(Level.WARNING);
    try {
        throw new PayaraIdeException(gfieMsg);
    } catch (PayaraIdeException gfie) {
        handler.flush();
    } finally {
        logger.removeHandler(handler);
        handler.close();
        logger.setLevel(logLevel);
    }
    String logMsg = logOut.toString();
    int contains = logMsg.indexOf(gfieMsg);
    assertTrue(contains > -1);
}

源代码4 项目： netbeans 文件： ExceptionTest.java

/**
 * Test GlassFishException with no parameters specified throwing
 * and logging.
 */
@Test
public void testGlassFishExceptionWithNothing() {
    // this message must match GlassFishIdeException() constructor
    // log message.
    String gfieMsg = "Caught GlassFishIdeException.";
    java.util.logging.Logger logger = Logger.getLogger();
    Level logLevel = logger.getLevel();
    OutputStream logOut = new ByteArrayOutputStream(256);
    Handler handler = new StreamHandler(logOut, new SimpleFormatter());
    handler.setLevel(Level.WARNING);
    logger.addHandler(handler);       
    logger.setLevel(Level.WARNING);
    try {
        throw new GlassFishIdeException();
    } catch (GlassFishIdeException gfie) {
        handler.flush();
    } finally {
        logger.removeHandler(handler);
        handler.close();
        logger.setLevel(logLevel);
    }
    String logMsg = logOut.toString();
    int contains = logMsg.indexOf(gfieMsg);
    assertTrue(contains > -1);
}

源代码5 项目： netbeans 文件： ExceptionTest.java

/**
 * Test GlassFishException with message throwing and logging.
 */
@Test
public void testGlassFishExceptionWithMsg() {
    String gfieMsg = "Test exception";
    java.util.logging.Logger logger = Logger.getLogger();
    Level logLevel = logger.getLevel();
    OutputStream logOut = new ByteArrayOutputStream(256);
    Handler handler = new StreamHandler(logOut, new SimpleFormatter());
    handler.setLevel(Level.WARNING);
    logger.addHandler(handler);       
    logger.setLevel(Level.WARNING);
    try {
        throw new GlassFishIdeException(gfieMsg);
    } catch (GlassFishIdeException gfie) {
        handler.flush();
    } finally {
        logger.removeHandler(handler);
        handler.close();
        logger.setLevel(logLevel);
    }
    String logMsg = logOut.toString();
    int contains = logMsg.indexOf(gfieMsg);
    assertTrue(contains > -1);
}

源代码6 项目： copybara 文件： CommandRunnerTest.java

private CommandOutputWithStatus runCommand(CommandRunner commandRunner) throws CommandException {
  Logger logger = Logger.getLogger(CommandRunner.class.getName());
  boolean useParentLogger = logger.getUseParentHandlers();
  logger.setUseParentHandlers(false);
  StreamHandler handler = new StreamHandler() {
    @Override
    public synchronized void publish(LogRecord record) {
      logLines.add(record.getMessage());
    }
  };
  logger.addHandler(handler);
  PrintStream outRestore = System.out;
  PrintStream errRestore = System.err;
  System.setOut(new PrintStream(outContent));
  System.setErr(new PrintStream(errContent));
  try {
    return commandRunner.execute();
  } finally {
    System.setOut(outRestore);
    System.setErr(errRestore);
    logger.removeHandler(handler);
    logger.setUseParentHandlers(useParentLogger);
  }
}

源代码7 项目： birt 文件： Logger.java

private static StreamHandler getTracingHandler( )
{
	if ( tracingHandler == null )
	{
		tracingHandler = AccessController.doPrivileged( new PrivilegedAction<StreamHandler>( ) {

			public StreamHandler run( )
			{
				StreamHandler handler = new StreamHandler( System.out,
						new SimpleFormatter( ) );
				try
				{
					tracingHandler.setLevel( Level.ALL );
				}
				catch ( SecurityException e )
				{
					e.printStackTrace( );
				}
				return handler;
			}
		} );
	}
	return tracingHandler;
}

源代码8 项目： Bukkit-SSHD 文件： ConsoleShellFactory.java

public void start(Environment env) throws IOException {
    try {
        consoleReader = new ConsoleReader(in, new FlushyOutputStream(out), new SshTerminal());
        consoleReader.setExpandEvents(true);
        consoleReader.addCompleter(new ConsoleCommandCompleter());

        StreamHandler streamHandler = new FlushyStreamHandler(out, new ConsoleLogFormatter(), consoleReader);
        streamHandlerAppender = new StreamHandlerAppender(streamHandler);

        ((Logger) LogManager.getRootLogger()).addAppender(streamHandlerAppender);

        environment = env;
        thread = new Thread(this, "SSHD ConsoleShell " + env.getEnv().get(Environment.ENV_USER));
        thread.start();
    } catch (Exception e) {
        throw new IOException("Error starting shell", e);
    }
}

源代码9 项目： camunda-bpm-platform 文件： ProcessScopeTest.java

@Test
public void shouldLogExceptionStacktrace() throws IOException {
  Logger logger = Logger.getLogger(ProcessScope.class.getName());
  try (ByteArrayOutputStream out = new ByteArrayOutputStream();) {
    Handler handler = new StreamHandler(out, new SimpleFormatter());
    logger.addHandler(handler);
    try {
      ProcessScope scope = new ProcessScope();
      Object variable = scope.get("testObject", null);
      assertNull(variable);
    } finally {
      handler.flush();
      handler.close();
      logger.removeHandler(handler);
    }
    // test for logged exception
    String message = new String(out.toByteArray(), StandardCharsets.UTF_8);
    assertTrue(!message.isEmpty());
    assertTrue(message.contains("org.camunda.bpm.engine.spring.components.scope.ProcessScope get"));
    assertTrue(message.contains("couldn't return value from process scope! java.lang.NullPointerException"));
    assertTrue(message.contains("at org.camunda.bpm.engine.spring.components.scope.ProcessScope.getExecutionId(ProcessScope.java:")); 
    assertTrue(message.contains("at org.camunda.bpm.engine.spring.components.scope.ProcessScope.getConversationId(ProcessScope.java:")); 
    assertTrue(message.contains("at org.camunda.bpm.engine.spring.components.scope.ProcessScope.get(ProcessScope.java:")); 
    assertTrue(message.contains("at org.camunda.bpm.engine.spring.test.components.scope.ProcessScopeTest.shouldLogExceptionStacktrace(ProcessScopeTest.java:")); 
  }
}

源代码10 项目： opentelemetry-java 文件： LoggingMetricExporterTest.java

@Test
public void testFlush() {
  final AtomicBoolean flushed = new AtomicBoolean(false);
  Logger.getLogger(LoggingMetricExporter.class.getName())
      .addHandler(
          new StreamHandler(System.err, new SimpleFormatter()) {
            @Override
            public synchronized void flush() {
              flushed.set(true);
            }
          });
  exporter.flush();
  assertThat(flushed.get()).isTrue();
}

源代码11 项目： opentelemetry-java 文件： LoggingSpanExporterTest.java

@Test
public void testFlush() {
  final AtomicBoolean flushed = new AtomicBoolean(false);
  Logger.getLogger(LoggingSpanExporter.class.getName())
      .addHandler(
          new StreamHandler(System.err, new SimpleFormatter()) {
            @Override
            public synchronized void flush() {
              flushed.set(true);
            }
          });
  exporter.flush();
  assertThat(flushed.get()).isTrue();
}

源代码12 项目： netbeans 文件： TopLogging.java

/** Logger for test purposes.
 */
static Handler createStreamHandler (PrintStream pw) {
    StreamHandler s = new StreamHandler (
        pw, NbFormatter.FORMATTER
    );
    return NbLogging.createDispatchHandler(s, 50);
}

源代码13 项目： netbeans 文件： TopLogging.java

private static synchronized Handler streamHandler() {
    if (streamHandler == null) {
        StreamHandler sth = new StreamHandler (OLD_ERR, NbFormatter.FORMATTER);
        sth.setLevel(Level.ALL);
        streamHandler = NbLogging.createDispatchHandler(sth, 500);
    }
    return streamHandler;
}

源代码14 项目： netbeans 文件： ExceptionTest.java

/**
 * Test PayaraException with message and cause <code>Throwable</code>
 * throwing and logging.
 */
@Test
public void testPayaraExceptionWithMsgAndCause() {
    String gfieMsg = "Test exception";
    String causeMsg = "Cause exception";
    java.util.logging.Logger logger = Logger.getLogger();
    Level logLevel = logger.getLevel();
    OutputStream logOut = new ByteArrayOutputStream(256);
    Handler handler = new StreamHandler(logOut, new SimpleFormatter());
    handler.setLevel(Level.WARNING);
    logger.addHandler(handler);       
    logger.setLevel(Level.WARNING);
    try {
        try {
            throw new Exception(causeMsg);
        } catch (Exception e) {
            throw new PayaraIdeException(gfieMsg, e);
        }
    } catch (PayaraIdeException gfie) {
        handler.flush();
    } finally {
        logger.removeHandler(handler);
        handler.close();
        logger.setLevel(logLevel);
    }
    String logMsg = logOut.toString();
    int containsGfieMsg = logMsg.indexOf(gfieMsg);
    int containsCauseMsg = logMsg.indexOf(causeMsg);
    assertTrue(containsGfieMsg > -1 && containsCauseMsg > -1);
}

源代码15 项目： netbeans 文件： ExceptionTest.java

/**
 * Test GlassFishException with message and cause <code>Throwable</code>
 * throwing and logging.
 */
@Test
public void testGlassFishExceptionWithMsgAndCause() {
    String gfieMsg = "Test exception";
    String causeMsg = "Cause exception";
    java.util.logging.Logger logger = Logger.getLogger();
    Level logLevel = logger.getLevel();
    OutputStream logOut = new ByteArrayOutputStream(256);
    Handler handler = new StreamHandler(logOut, new SimpleFormatter());
    handler.setLevel(Level.WARNING);
    logger.addHandler(handler);       
    logger.setLevel(Level.WARNING);
    try {
        try {
            throw new Exception(causeMsg);
        } catch (Exception e) {
            throw new GlassFishIdeException(gfieMsg, e);
        }
    } catch (GlassFishIdeException gfie) {
        handler.flush();
    } finally {
        logger.removeHandler(handler);
        handler.close();
        logger.setLevel(logLevel);
    }
    String logMsg = logOut.toString();
    int containsGfieMsg = logMsg.indexOf(gfieMsg);
    int containsCauseMsg = logMsg.indexOf(causeMsg);
    assertTrue(containsGfieMsg > -1 && containsCauseMsg > -1);
}

源代码16 项目： netbeans 文件： CatalogModelTest.java

public void testDepResolver() throws URISyntaxException, CatalogModelException, IOException {
    
    Logger logger = Logger.getLogger(CatalogModelTest.class.getName());
    logger.setLevel(Level.ALL);
    StreamHandler sh = new MyHandler(System.out, new SimpleFormatter());
    sh.setLevel(logger.getLevel());
    //logger.addHandler(sh);
    CatalogFileWrapperDOMImpl.TEST_ENVIRONMENT = true;
    File catFile = new File(System.getProperty("java.io.tmpdir")+File.separator+CatalogWriteModel.PUBLIC_CATALOG_FILE_NAME+CatalogWriteModel.CATALOG_FILE_EXTENSION+".girish");
    catFile.delete();
    catFile.createNewFile();
    FileObject catFO = FileUtil.toFileObject(FileUtil.normalizeFile(catFile));
    URL url = getClass().getResource("dummyFile.txt");
    FileObject peerfo = FileUtil.toFileObject(new File(url.toURI()).getAbsoluteFile());
    System.out.println(catFile);
    CatalogWriteModel drz = new MyCatalogWriteModel(catFO);
    //CatalogWriteModel drz = new MyCatalogWriteModel(new File(System.getProperty("java.io.tmpdir")));
    drz.addURI(new URI("dummy/dummy"), peerfo);
    int length = drz.getCatalogEntries().size();
    
    assertEquals(1, length);
    
    //System.out.println("%%%%"+drz.getModelSource(new URI("dummy/dummy")).getFileObject());
    
    //System.out.println("$$$$"+LSResourceResolverFactory.getDefault().resolveResource(null, null, null, "dummy/dummy", url.toURI().toString()).getSystemId());
    
    //assertTrue(LSResourceResolverFactory.getDefault().resolveResource(null, null, null, "dummy/dummy", url.toURI().toString()).getSystemId().endsWith("dummyFile.txt"));
    
    FileObject fob = (FileObject) drz.getModelSource(new URI("dummy/dummy")).getLookup().lookup(FileObject.class);
    
    assertNotNull(fob);
    
    drz.removeURI(new URI("dummy/dummy"));
    
    length = drz.getCatalogEntries().size();
    
    assertEquals(0, length);
}

源代码17 项目： openjdk-jdk9 文件： HandlersConfigTest.java

@Override
public void run() {
    // MemoryHandler

    check(new MemoryHandler(),
        Level.ALL, null, null, SimpleFormatter.class,
        ConfiguredHandler.class, 1000, Level.SEVERE);

    check(new MemoryHandler(new SpecifiedHandler(), 100, Level.WARNING),
        Level.ALL, null, null, SimpleFormatter.class,
        SpecifiedHandler.class, 100, Level.WARNING);

    // StreamHandler

    check(new StreamHandler(),
        Level.INFO, null, null, SimpleFormatter.class,
        null);

    check(new StreamHandler(System.out, new SpecifiedFormatter()),
        Level.INFO, null, null, SpecifiedFormatter.class,
        System.out);

    // ConsoleHandler

    check(new ConsoleHandler(),
        Level.INFO, null, null, SimpleFormatter.class,
        System.err);

    // SocketHandler (use the ServerSocket's port)

    try {
        check(new SocketHandler("localhost", serverSocket.getLocalPort()),
            Level.ALL, null, null, XMLFormatter.class);
    } catch (IOException e) {
        throw new RuntimeException("Can't connect to localhost:" + serverSocket.getLocalPort(), e);
    }
}

源代码18 项目： openjdk-jdk9 文件： HandlersConfigTest.java

@Override
public void run() {
    // MemoryHandler

    check(new MemoryHandler(),
        Level.FINE, null, ConfiguredFilter.class, ConfiguredFormatter.class,
        ConfiguredHandler.class, 123, Level.FINE);

    check(new MemoryHandler(new SpecifiedHandler(), 100, Level.WARNING),
        Level.FINE, null, ConfiguredFilter.class, ConfiguredFormatter.class,
        SpecifiedHandler.class, 100, Level.WARNING);

    // StreamHandler

    check(new StreamHandler(),
        Level.FINE, "ASCII", ConfiguredFilter.class, ConfiguredFormatter.class,
        null);

    check(new StreamHandler(System.out, new SpecifiedFormatter()),
        Level.FINE, "ASCII", ConfiguredFilter.class, SpecifiedFormatter.class,
        System.out);

    // ConsoleHandler

    check(new ConsoleHandler(),
        Level.FINE, "ASCII", ConfiguredFilter.class, ConfiguredFormatter.class,
        System.err);

    // SocketHandler (use the ServerSocket's port)

    try {
        check(new SocketHandler("localhost", serverSocket.getLocalPort()),
            Level.FINE, "ASCII", ConfiguredFilter.class, ConfiguredFormatter.class);
    } catch (Exception e) {
        throw new RuntimeException("Can't connect to localhost:" + serverSocket.getLocalPort(), e);
    }
}

源代码19 项目： openjdk-jdk9 文件： HandlersConfigTest.java

void check(StreamHandler handler,
           Level expectedLevel,
           String expectedEncoding,
           Class<? extends Filter> expectedFilterType,
           Class<? extends Formatter> expectedFormatterType,
           OutputStream expectedOutputStream) {
    checkEquals(handler, "outputStream", getOutput(handler), expectedOutputStream);
    check(handler, expectedLevel, expectedEncoding, expectedFilterType, expectedFormatterType);
}

源代码20 项目： openjdk-jdk9 文件： HandlersConfigTest.java

OutputStream getOutput(StreamHandler streamHandler) {
    try {
        return (OutputStream) streamHandlerOutput.get(streamHandler);
    } catch (IllegalAccessException e) {
        throw new IllegalAccessError(e.getMessage());
    }
}

源代码21 项目： aws-codecommit-trigger-plugin 文件： Log.java

public static Log get(Class clazz, PrintStream out, boolean autoFormat) throws IOException {
    Log log = get(clazz);
    log.autoFormat = autoFormat;

    log.streamHandler = new StreamHandler(out, new SimpleFormatter());
    log.logger.addHandler(log.streamHandler);

    return log;
}

源代码22 项目： gemfirexd-oss 文件： DomainObjectsAsValuesJUnitTest.java

@Override
protected void setUp() throws Exception {
  super.setUp();
  PORT = AvailablePortHelper.getRandomAvailableTCPPort();
  this.server = new GemFireMemcachedServer(PORT);
  server.start();
  logger.addHandler(new StreamHandler());
  logger.info("SWAP:Running test:"+getName());
}

源代码23 项目： gemfirexd-oss 文件： GemcachedDevelopmentJUnitTest.java

@Override
protected void setUp() throws Exception {
  super.setUp();
  PORT = AvailablePort.getRandomAvailablePort(AvailablePort.SOCKET);
  this.server = new GemFireMemcachedServer(PORT, getProtocol());
  server.start();
  logger.addHandler(new StreamHandler());
  logger.info("SWAP:Running test:"+getName());
  logger.info("SWAP:userdir:"+System.getProperty("user.dir"));
}

源代码24 项目： sdn-wise-java 文件： ControlPlaneLogger.java

/**
 * Creates a logger using the SimplerFormatter formatter.
 *
 * @param prefix the name of the ControlPlane class
 */
public static void setupLogger(final String prefix) {

    Logger logger = Logger.getLogger(prefix);
    logger.setUseParentHandlers(false);
    SimplerFormatter f = new SimplerFormatter(prefix);
    StreamHandler h = new StreamHandler(System.out, f) {
        @Override
        public synchronized void publish(final LogRecord record) {
            super.publish(record);
            flush();
        }
    };
    logger.addHandler(h);
}

源代码25 项目： jason 文件： ReplAgGUI.java

void initLogger() {
    getTS().getLogger().addHandler( new StreamHandler() {
        @Override
        public synchronized void publish(LogRecord l) {
            output.append(l.getMessage()+"\n");
            output.setCaretPosition( output.getDocument().getLength());
        }
    });
}

源代码26 项目： rapidminer-studio 文件： FixedConsoleHandler.java

@Override
public void close() {
	super.close();

	Method flushAndClose;
	try {
		flushAndClose = StreamHandler.class.getDeclaredMethod("flushAndClose", new Class[0]);
		flushAndClose.setAccessible(true);
		flushAndClose.invoke(this);
	} catch (Exception e) {
		// e.printStackTrace();
	}
}

源代码27 项目： tracecompass 文件： LoggerTest.java

/**
 * Set up logger
 */
@Before
public void before() {
    fLogger = Logger.getAnonymousLogger();
    fLog = new StringOutputStream();
    fStreamHandler = new StreamHandler(fLog, new SimpleFormatter());
    fStreamHandler.setLevel(Level.FINER);
    fLogger.setLevel(Level.ALL);
    fLogger.addHandler(fStreamHandler);
}

源代码28 项目： gemfirexd-oss 文件： DomainObjectsAsValuesJUnitTest.java

@Override
protected void setUp() throws Exception {
  super.setUp();
  PORT = AvailablePortHelper.getRandomAvailableTCPPort();
  this.server = new GemFireMemcachedServer(PORT);
  server.start();
  logger.addHandler(new StreamHandler());
  logger.info("SWAP:Running test:"+getName());
}

源代码29 项目： gemfirexd-oss 文件： GemcachedDevelopmentJUnitTest.java

@Override
protected void setUp() throws Exception {
  super.setUp();
  PORT = AvailablePort.getRandomAvailablePort(AvailablePort.SOCKET);
  this.server = new GemFireMemcachedServer(PORT, getProtocol());
  server.start();
  logger.addHandler(new StreamHandler());
  logger.info("SWAP:Running test:"+getName());
  logger.info("SWAP:userdir:"+System.getProperty("user.dir"));
}

源代码30 项目： ignite 文件： CommandHandler.java

/**
 * @return StreamHandler with empty formatting
 */
public static StreamHandler setupStreamHandler() {
    return new StreamHandler(System.out, new Formatter() {
        @Override public String format(LogRecord record) {
            return record.getMessage() + "\n";
        }
    });
}

类所在包

类方法

同包方法

java.util.Collections