Java 类org.apache.log4j.WriterAppender 实例源码

项目:incubator-servicecomb-java-chassis    文件:TestMicroservicePaths.java   
@Test
public void testPrintPaths() {
  RestOperationMeta staticRes = UnitTestRestUtils.createRestOperationMeta("POST", "/static");
  RestOperationMeta dynamicRes = UnitTestRestUtils.createRestOperationMeta("POST", "/dynamic/{id}");

  MicroservicePaths paths = new MicroservicePaths();
  paths.addResource(staticRes);
  paths.addResource(dynamicRes);

  WriterAppender appender = new WriterAppender();
  Writer writer = new StringWriter();
  appender.setWriter(writer);
  appender.setLayout(new SimpleLayout());
  Logger.getRootLogger().addAppender(appender);

  paths.printPaths();

  String[] lines = writer.toString().split("\n");
  Assert.assertEquals("INFO - Swagger mapped \"{[/static], method=[POST], produces=[application/json]}\" onto null",
      lines[0].trim());
  Assert.assertEquals(
      "INFO - Swagger mapped \"{[/dynamic/{id}], method=[POST], produces=[application/json]}\" onto null",
      lines[1].trim());

  Logger.getRootLogger().removeAppender(appender);
}
项目:semtool    文件:GraphToTreeConverterTest.java   
@Test
public void testPrint() throws Exception {

    DirectedGraph<URI, URI> graph = new DirectedSparseGraph<>();
    graph.addVertex( YURI );
    graph.addVertex( YUGO );
    graph.addEdge( YPY, YURI, YUGO, EdgeType.DIRECTED );

    Collection<URI> roots = Arrays.asList( YURI );
    GraphToTreeConverter.Search search = GraphToTreeConverter.Search.DFS;
    Forest<URI, URI> result = GraphToTreeConverter.convert( graph, roots, search );

    Logger log = Logger.getLogger( GraphToTreeConverter.class );
    StringWriter stringy = new StringWriter();
    WriterAppender app = new WriterAppender( new SimpleLayout(), stringy );
    log.setLevel( Level.DEBUG );
    log.addAppender( app );
    GraphToTreeConverter.printForest( result );
    String output = stringy.toString().replaceAll( "\\s", "" );
    assertEquals( "DEBUG-http://semoss.va.gov/database/T44889381-85ce-43e3-893d-6267fd480660/YuriDEBUG-http://semoss.va.gov/database/T44889381-85ce-43e3-893d-6267fd480660/Yugo", output );
}
项目:minesim    文件:SpriteLoaderTests.java   
/**
 * Tests that the right logger message is executed if the sprite file is
 * invalid.
 */
@Test
public void testMissingSprite() {
    // Set up of logger retrieval
    ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
    Layout layout = new SimpleLayout();
    Appender appender = new WriterAppender(layout, outputStream);
    LOGGER.addAppender(appender);

    // Valid file name
    String inValidSpriteFile = "Sprite asdfsdfSheet";
    SpriteLoader spriteLoader = new SpriteLoader();

    try {
        // The functions to test
        spriteLoader.loadSpriteSheet(inValidSpriteFile, 32, 32);
        spriteLoader.getSprite(1, 0);

        String logMessage = outputStream.toString();
        assertNotNull(logMessage);
        assertTrue(logMessage.contains("ERROR - You are trying to use a"));
    } finally {
        LOGGER.removeAppender(appender);
    }
}
项目:minesim    文件:SpriteLoaderTests.java   
/**
 * Tests that the right logger message is executed if an incorrect position
 * (on the sprite sheet) is entered.
 */
@Test
public void testNegativeDimensions() {

    // Set up logger retrieval
    ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
    Layout layout = new SimpleLayout();
    Appender appender = new WriterAppender(layout, outputStream);
    LOGGER.addAppender(appender);

    // Valid file name
    String validSpriteFile = "peonSheet";
    SpriteLoader spriteLoader = new SpriteLoader();
    try {
        // The functions to test
        spriteLoader.loadSpriteSheet(validSpriteFile, 32, 32);
        spriteLoader.getSprite(-1, -1);

        String logMessage = outputStream.toString();
        assertNotNull(logMessage);
        assertTrue(logMessage.contains("ERROR - You are requesting a grid position"));
    } finally {
        LOGGER.removeAppender(appender);
    }
}
项目:minesim    文件:SpriteLoaderTests.java   
/**
 * Tests that the right logger message is executed if an incorrect position
 * (on the sprite sheet) is entered.
 */
@Test
public void testPositiveDimensions() {

    // Set up logger retrieval
    ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
    Layout layout = new SimpleLayout();
    Appender appender = new WriterAppender(layout, outputStream);
    LOGGER.addAppender(appender);

    // Valid file name
    String validSpriteFile = "peonSheet";
    SpriteLoader spriteLoader = new SpriteLoader();
    try {
        // The functions to test
        spriteLoader.loadSpriteSheet(validSpriteFile, 32, 32);
        spriteLoader.getSprite(6, 6);

        String logMessage = outputStream.toString();
        assertNotNull(logMessage);
        assertTrue(logMessage.contains("ERROR - You are requesting a grid position"));
    } finally {
        LOGGER.removeAppender(appender);
    }
}
项目:minesim    文件:SpriteLoaderTests.java   
/**
 * Tests that the right logger message is executed if an invalid specified
 * sprite dimension is entered.
 */
@Test
public void testInvalidSpriteSheetDimensions() {

    // Set up logger retrieval
    ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
    Layout layout = new SimpleLayout();
    Appender appender = new WriterAppender(layout, outputStream);
    LOGGER.addAppender(appender);

    // Valid file name
    String validSpriteFile = "peonSheet";
    SpriteLoader spriteLoader = new SpriteLoader();
    try {
        // The functions to test
        spriteLoader.loadSpriteSheet(validSpriteFile, 13, 13);
        spriteLoader.getSprite(1, 0);

        String logMessage = outputStream.toString();
        assertNotNull(logMessage);
        assertTrue(logMessage.contains("WARN - Your file is not a multiple of"));
    } finally {
        LOGGER.removeAppender(appender);
    }
}
项目:minesim    文件:SpriteLoaderTests.java   
/**
 * Tests that no logger message is executed if valid specified sprite
 * dimensions are entered.
 */
@Test
public void testValidSpriteDimensions() {
    // Set up logger retrieval
    ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
    Layout layout = new SimpleLayout();
    Appender appender = new WriterAppender(layout, outputStream);
    LOGGER.addAppender(appender);

    // Valid file name
    String validSpriteFile = "peonSheet";
    SpriteLoader spriteLoader = new SpriteLoader();
    try {
        // The functions to test
        spriteLoader.loadSpriteSheet(validSpriteFile, 32, 32);
        spriteLoader.getSprite(1, 0);

        String logMessage = outputStream.toString();
        assertEquals("", logMessage);// should be empty
    } finally {
        LOGGER.removeAppender(appender);
    }
}
项目:minesim    文件:SpriteLoaderTests.java   
/**
 * Tests that the right logger message is executed if a null sprite sheet
 * file name is entered (i.e. does not exist due to trolling, typos)
 */
@Test
public void testNullSpriteSheet() {
    // Set up logger retrieval
    ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
    Layout layout = new SimpleLayout();
    Appender appender = new WriterAppender(layout, outputStream);
    LOGGER.addAppender(appender);

    // Null file name
    String nullSpriteFile = null;
    SpriteLoader spriteLoader = new SpriteLoader();

    try {
        // The function to test
        spriteLoader.loadSpriteSheet(nullSpriteFile, 32, 32);
        assertNull(nullSpriteFile);

        String logMessage = outputStream.toString();
        assertNotNull(logMessage);
        assertTrue(logMessage.contains("ERROR - Could not load file"));

    } finally {
        LOGGER.removeAppender(appender);
    }
}
项目:minesim    文件:SpriteLoaderTests.java   
/**
 * Tests that the right logger message is executed if an invalid sprite
 * sheet file name is entered (i.e. does not exist due to trolling, typos)
 */
@Test
public void testInvalidSpriteSheet() {
    // Set up logger retrieval
    ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
    Layout layout = new SimpleLayout();
    Appender appender = new WriterAppender(layout, outputStream);
    LOGGER.addAppender(appender);

    // Invalid file name
    String invalidSpriteFile = "invalid name";
    SpriteLoader spriteLoader = new SpriteLoader();

    try {
        // The function to test
        spriteLoader.loadSpriteSheet(invalidSpriteFile, 32, 32);

        String logMessage = outputStream.toString();
        assertNotNull(logMessage);
        assertTrue(logMessage.contains("ERROR - Could not load file"));
    } finally {
        LOGGER.removeAppender(appender);
    }
}
项目:minesim    文件:SpriteLoaderTests.java   
/**
 * Tests that no logger message is executed if a valid sprite sheet is
 * entered
 */
@Test
public void testValidSpriteSheet() {
    // Set up logger retrieval
    ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
    Layout layout = new SimpleLayout();
    Appender appender = new WriterAppender(layout, outputStream);
    LOGGER.addAppender(appender);

    // Valid file name
    String validSpriteFile = "peonSheet";
    SpriteLoader spriteLoader = new SpriteLoader();

    try {
        // The function to test
        spriteLoader.loadSpriteSheet(validSpriteFile, 32, 32);
        assertNotNull(validSpriteFile);
        String logMessage = outputStream.toString();
        assertNotNull(logMessage);
        assertEquals("", logMessage);// should be empty
    } finally {
        LOGGER.removeAppender(appender);
    }
}
项目:minesim    文件:FrameTests.java   
/**
 * Tests that no logger message is executed for a valid frame setup.
 */
@Test
public void validFrameInitialisation() {
    // Set up of logger retrieval
    ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
    Layout layout = new SimpleLayout();
    Appender appender = new WriterAppender(layout, outputStream);
    LOGGER.addAppender(appender);

    Image mockSprite = mock(Image.class);

    try {
        // The functions to test
        frame = new Frame(mockSprite, 10);
        assertNotNull(frame.getFrame());
        assertTrue(frame.getDuration() == 10);

        String logMessage = outputStream.toString();
        assertNotNull(logMessage);
        assertEquals("", logMessage);
    } finally {
        LOGGER.removeAppender(appender);
    }
}
项目:minesim    文件:FrameTests.java   
/**
 * Tests that getters are not null if there is a valid Frame initilisation.
 */
@Test
public void validGetters() {
    // Set up of logger retrieval
    ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
    Layout layout = new SimpleLayout();
    Appender appender = new WriterAppender(layout, outputStream);
    LOGGER.addAppender(appender);

    Image mockSprite = mock(Image.class);

    try {
        // The functions to test
        frame = new Frame(mockSprite, 10);
        assertNotNull(frame.getFrame());
        assertNotNull(frame.getDuration());

        String logMessage = outputStream.toString();
        assertNotNull(logMessage);
        assertEquals("", logMessage);
    } finally {
        LOGGER.removeAppender(appender);
    }
}
项目:minesim    文件:FrameTests.java   
/**
 * Tests that the appropriate error message is displayed if the frame image
 * is null.
 */
@Test
public void inValidFrame() {
    // Set up of logger retrieval
    ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
    Layout layout = new SimpleLayout();
    Appender appender = new WriterAppender(layout, outputStream);
    LOGGER.addAppender(appender);

    try {
        // The functions to test
        frame = new Frame(null, 10);
        assertNull(frame.getFrame());

        String logMessage = outputStream.toString();
        assertNotNull(logMessage);
        assertTrue(logMessage.contains("ERROR - You cannot have null frames"));
    } finally {
        LOGGER.removeAppender(appender);
    }
}
项目:minesim    文件:FrameTests.java   
/**
 * Tests that the appropriate logger message is executed if the duration is
 * less than or equal to 0.
 */
@Test
public void inValidDuration() {
    // Set up of logger retrieval
    ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
    Layout layout = new SimpleLayout();
    Appender appender = new WriterAppender(layout, outputStream);
    LOGGER.addAppender(appender);

    Image mockSprite = mock(Image.class);

    try {
        // The functions to test
        frame = new Frame(mockSprite, 0);
        assertTrue(frame.getDuration() == 0);

        String logMessage = outputStream.toString();
        assertNotNull(logMessage);
        assertTrue(logMessage.contains("ERROR - You cannot have a duration equal to or less than 0"));
    } finally {
        LOGGER.removeAppender(appender);
    }
}
项目:minesim    文件:FrameTests.java   
/**
 * Tests that the appropriate logger message is executed if the duration is
 * set to be less than or equal to 0.
 */
@Test
public void invalidSettersDuration() {
    // Set up of logger retrieval
    ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
    Layout layout = new SimpleLayout();
    Appender appender = new WriterAppender(layout, outputStream);
    LOGGER.addAppender(appender);

    Image mockSprite = mock(Image.class);
    frame = new Frame(mockSprite, 10);

    try {
        // The functions to test
        assertTrue(frame.getDuration() == 10);
        frame.setDuration(-1);
        assertTrue(frame.getDuration() == 10);

        String logMessage = outputStream.toString();
        assertNotNull(logMessage);
        assertTrue(logMessage.contains("ERROR - You cannot have a duration"));
    } finally {
        LOGGER.removeAppender(appender);
    }
}
项目:minesim    文件:FrameTests.java   
/**
 * Tests that no logger message is executed if the duration is set to a
 * valid number.
 */
@Test
public void validSettersDuration() {
    // Set up of logger retrieval
    ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
    Layout layout = new SimpleLayout();
    Appender appender = new WriterAppender(layout, outputStream);
    LOGGER.addAppender(appender);

    Image mockSprite = mock(Image.class);
    frame = new Frame(mockSprite, 10);

    try {
        // The functions to test
        assertTrue(frame.getDuration() == 10);
        frame.setDuration(20);
        assertTrue(frame.getDuration() == 20);

        String logMessage = outputStream.toString();
        assertNotNull(logMessage);
        assertEquals("", logMessage);
    } finally {
        LOGGER.removeAppender(appender);
    }
}
项目:minesim    文件:FrameTests.java   
/**
 * Tests that the appropriate logger message is executed if the frame is set
 * to null.
 */
@Test
public void invalidSettersFrame() {
    // Set up of logger retrieval
    ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
    Layout layout = new SimpleLayout();
    Appender appender = new WriterAppender(layout, outputStream);
    LOGGER.addAppender(appender);

    Image mockSprite = mock(Image.class);
    frame = new Frame(mockSprite, 10);

    try {
        // The functions to test
        assertEquals(mockSprite, frame.getFrame());
        frame.setFrame(null);
        assertEquals(mockSprite, frame.getFrame());

        String logMessage = outputStream.toString();
        assertNotNull(logMessage);
        assertTrue(logMessage.contains("ERROR - You cannot have null frames"));
    } finally {
        LOGGER.removeAppender(appender);
    }
}
项目:minesim    文件:FrameTests.java   
/**
 * Tests that no logger message is executed if the frame is set to a valid
 * image.
 */
@Test
public void validSettersFrame() {
    // Set up of logger retrieval
    ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
    Layout layout = new SimpleLayout();
    Appender appender = new WriterAppender(layout, outputStream);
    LOGGER.addAppender(appender);

    Image mockSprite = mock(Image.class);
    Image mockSprite2 = mock(Image.class);
    frame = new Frame(mockSprite, 10);

    try {
        // The functions to test
        assertEquals(mockSprite, frame.getFrame());
        frame.setFrame(mockSprite2);
        assertEquals(mockSprite2, frame.getFrame());

        String logMessage = outputStream.toString();
        assertNotNull(logMessage);
        assertEquals("", logMessage);
    } finally {
        LOGGER.removeAppender(appender);
    }
}
项目:minesim    文件:AnimationTests.java   
/**
 * Tests that the right logger message is executed if an invalid animation
 * initialisation is written (namely invalid duration is entered)
 */
@Test
public void invalidAnimationInitialisation() {
    // Set up of logger retrieval
    ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
    Layout layout = new SimpleLayout();
    Appender appender = new WriterAppender(layout, outputStream);
    LOGGER.addAppender(appender);

    Image mockSprite = mock(Image.class);
    standingRight.add(mockSprite);

    try {
        // The functions to test
        animation = new Animation(standingRight, 0);

        String logMessage = outputStream.toString();
        assertNotNull(logMessage);
        assertTrue(logMessage.contains("ERROR - You cannot have a duration"));
    } finally {
        LOGGER.removeAppender(appender);
    }
}
项目:minesim    文件:AnimationTests.java   
/**
 * Tests that the right logger message is executed if an invalid animation
 * initialisation is written (namely invalid frames entered)
 */
@Test
public void invalidFramesAnimationInitialisation() {
    // Set up of logger retrieval
    ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
    Layout layout = new SimpleLayout();
    Appender appender = new WriterAppender(layout, outputStream);
    LOGGER.addAppender(appender);

    Image mockSprite = mock(Image.class);
    standingRight.add(mockSprite);

    try {
        // The functions to test
        animation = new Animation(null, 10);

        String logMessage = outputStream.toString();
        assertNotNull(logMessage);
        assertTrue(logMessage.contains("ERROR - You cannot have null frames"));
    } finally {
        LOGGER.removeAppender(appender);
    }
}
项目:minesim    文件:AnimationTests.java   
/**
 * Tests that the right logger message is executed if stop function is
 * executed incorrectly (namely invalid frames: null)
 */
@Test
public void testInvalidStop() {
    // Set up of logger retrieval
    ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
    Layout layout = new SimpleLayout();
    Appender appender = new WriterAppender(layout, outputStream);
    LOGGER.addAppender(appender);

    Image mockSprite = mock(Image.class);
    standingRight.add(mockSprite);
    animation = new Animation(null, 10);

    try {
        // The functions to test
        assertTrue(animation.getStopped());
        assertTrue(animation.getFrames().size() <= 0);
        animation.stop();

        String logMessage = outputStream.toString();
        assertNotNull(logMessage);
        assertTrue(logMessage.contains("ERROR - You cannot have null frames"));
    } finally {
        LOGGER.removeAppender(appender);
    }
}
项目:vroom    文件:NovoaBenchmarking.java   
/**
 * Setup the main loggers for Novoa benchmarking routine.
 */
public void setupLoggers() {
    LoggerHelper.setupRootLogger(LoggerHelper.LEVEL_WARN, LoggerHelper.LEVEL_WARN, true);

    // Configuring loggers
    Logger.getRootLogger().setLevel(LoggerHelper.LEVEL_WARN);

    // MSA
    MSALogging.getBaseLogger().setLevel(LoggerHelper.LEVEL_WARN);

    // CW
    CWLogging.getBaseLogger().setLevel(LoggerHelper.LEVEL_WARN);

    // VLS
    VLSLogging.getBaseLogger().setLevel(LoggerHelper.LEVEL_WARN);

    // Heuristics
    HeuristicsLogging.getBaseLogger().setLevel(LoggerHelper.LEVEL_WARN);

    WriterAppender logAppender = new WriterAppender(DEFAULT_LOGGER_LAYOUT, err);
    logAppender.setThreshold(LoggerHelper.LEVEL_WARN);
    logAppender.setImmediateFlush(true);

    Logger.getRootLogger().removeAllAppenders();
    Logger.getRootLogger().addAppender(logAppender);
}
项目:zeppelin    文件:HeliumBundleFactory.java   
private synchronized void configureLogger() {
  org.apache.log4j.Logger npmLogger = org.apache.log4j.Logger.getLogger(
      "com.github.eirslett.maven.plugins.frontend.lib.DefaultYarnRunner");
  Enumeration appenders = org.apache.log4j.Logger.getRootLogger().getAllAppenders();

  if (appenders != null) {
    while (appenders.hasMoreElements()) {
      Appender appender = (Appender) appenders.nextElement();
      appender.addFilter(new Filter() {

        @Override
        public int decide(LoggingEvent loggingEvent) {
          if (loggingEvent.getLoggerName().contains("DefaultYarnRunner")) {
            return DENY;
          } else {
            return NEUTRAL;
          }
        }
      });
    }
  }
  npmLogger.addAppender(new WriterAppender(
      new PatternLayout("%m%n"),
      out
  ));
}
项目:scheduling    文件:TaskLoggerTest.java   
@Test
public void logStreaming() throws Exception {
    taskLogger = new TaskLogger(TaskIdImpl.createTaskId(new JobIdImpl(1000, "job"), "task", 42L), "myhost");

    final StringWriter stringAppender = new StringWriter();
    AppenderProvider stringAppenderProvider = new AppenderProvider() {
        @Override
        public Appender getAppender() throws LogForwardingException {
            return new WriterAppender(new PatternLayout("%m%n"), stringAppender);
        }
    };

    taskLogger.activateLogs(stringAppenderProvider);

    assertEquals("", stringAppender.toString());

    taskLogger.getOutputSink().println("hello");

    // async appender, it gets buffered
    assertEquals("", stringAppender.toString());

    for (int i = 0; i < 1000; i++) {
        taskLogger.getOutputSink().println("hello");
    }
    assertNotEquals("", stringAppender.toString());
}
项目:scheduling    文件:TaskLoggerTest.java   
@Test
public void getStoredLogs() throws Exception {
    taskLogger = new TaskLogger(TaskIdImpl.createTaskId(new JobIdImpl(1000, "job"), "task", 42L), "myhost");

    final StringWriter stringAppender = new StringWriter();
    AppenderProvider stringAppenderProvider = new AppenderProvider() {
        @Override
        public Appender getAppender() throws LogForwardingException {
            return new WriterAppender(new PatternLayout("%m%n"), stringAppender);
        }
    };

    taskLogger.getStoredLogs(stringAppenderProvider);
    assertEquals("", stringAppender.toString());

    taskLogger.getOutputSink().println("hello");

    taskLogger.getStoredLogs(stringAppenderProvider);
    assertEquals(String.format("hello%n"), stringAppender.toString());
}
项目:mlo-net    文件:OdenOSAdapterServiceImplTest.java   
/**
 * Test method for {@link org.o3project.mlo.server.impl.rpc.service.OdenOSAdapterServiceImpl#notifyLinkChanged(java.lang.String)}.
 */
@Test
public void testNotifyLinkChanged_null() {
    StringWriter writer = new StringWriter();
       WriterAppender appender = new WriterAppender(new PatternLayout("%p, %m%n"),writer);
       getLogger().addAppender(appender);
       getLogger().setAdditivity(false);
       try{
           // Outputs any log
        try {
            String linkId = OdenOSConstants.LINK_TL_1;
            obj.setLinkQueue(linkId);
            obj.notifyLinkChanged(null);
        } catch (Exception e) {
            fail();
        }
           // Checks error log
           String logString = writer.toString();
           assertTrue(logString.contains("notifyLinkChanged Incorrect response : "));

       }finally{
           // Removes log appender
           getLogger().removeAppender(appender);
           getLogger().setAdditivity(true);
       }
}
项目:mlo-net    文件:OdenOSAdapterServiceImplTest.java   
/**
 * Test method for {@link org.o3project.mlo.server.impl.rpc.service.OdenOSAdapterServiceImpl#notifyLinkDeleted(java.lang.String)}.
 */
@Test
public void testNotifyFlowDeleted_unmatch() {
    StringWriter writer = new StringWriter();
       WriterAppender appender = new WriterAppender(new PatternLayout("%p, %m%n"),writer);
       getLogger().addAppender(appender);
       getLogger().setAdditivity(false);
       try{
           // Outputs any log
        try {
            obj.setDeleteFlowQueue("test");
            obj.notifyFlowDeleted("test2");
        } catch (Exception e) {
            fail();
        }
           // Checks error log
           String logString = writer.toString();
           assertTrue(logString.contains("notifyFlowDeleted Incorrect response : " + "test2"));

       }finally{
           // Removes log appender
           getLogger().removeAppender(appender);
           getLogger().setAdditivity(true);
       }
}
项目:mlo-net    文件:OdenOSAdapterServiceImplTest.java   
/**
 * Test method for {@link org.o3project.mlo.server.impl.rpc.service.OdenOSAdapterServiceImpl#notifyLinkDeleted(java.lang.String)}.
 */
@Test
public void testNotifyFlowDeleted_null() {
    StringWriter writer = new StringWriter();
       WriterAppender appender = new WriterAppender(new PatternLayout("%p, %m%n"),writer);
       getLogger().addAppender(appender);
       getLogger().setAdditivity(false);
       try{
           // Outputs any log
        try {
            obj.setDeleteFlowQueue("test");
            obj.notifyFlowDeleted(null);
        } catch (Exception e) {
            fail();
        }
           // Checks error log
           String logString = writer.toString();
           assertTrue(logString.contains("notifyFlowDeleted Incorrect response : "));

       }finally{
           // Removes log appender
           getLogger().removeAppender(appender);
           getLogger().setAdditivity(true);
       }
}
项目:mlo-net    文件:OdenOSAdapterServiceImplTest.java   
/**
 * Test method for
 * {@link org.o3project.mlo.server.impl.rpc.service.OdenOSAdapterServiceImpl#notifyLinkChanged(java.lang.String)}
 * .
 */
@Test
public void testNotifyLinkChanged_InterruptedException() {

    StringWriter writer = new StringWriter();
    WriterAppender appender = new WriterAppender(new PatternLayout("%p, %m%n"),writer);
    getLogger().addAppender(appender);
    getLogger().setAdditivity(false);

    try {
        Thread.currentThread().interrupt();

        String linkId = OdenOSConstants.LINK_TL_1;
        obj.setLinkQueue(linkId);
        obj.notifyLinkChanged(linkId);

        String logString = writer.toString();
        assertTrue(logString.contains("Interrupted in the notifyLinkChanged"));

    } catch (Exception e) {
        fail();
    } finally{
        getLogger().removeAppender(appender);
        getLogger().setAdditivity(true);
    }
}
项目:mlo-net    文件:OdenOSAdapterServiceImplTest.java   
/**
 * Test method for
 * {@link org.o3project.mlo.server.impl.rpc.service.OdenOSAdapterServiceImpl#notifyFlowDeleted(java.lang.String)}
 * .
 */
@Test
public void testNotifyFlowDeleted_InterruptedException() {

    StringWriter writer = new StringWriter();
    WriterAppender appender = new WriterAppender(new PatternLayout("%p, %m%n"),writer);
    getLogger().addAppender(appender);
    getLogger().setAdditivity(false);

    try {
        Thread.currentThread().interrupt();
        obj.setDeleteFlowQueue("test");
        obj.notifyFlowDeleted("test");

        String logString = writer.toString();
        assertTrue(logString.contains("Interrupted in the notifyFlowDeleted"));

    } catch (Exception e) {
        fail();
    } finally{
        getLogger().removeAppender(appender);
        getLogger().setAdditivity(true);
    }
}
项目:mlo-net    文件:OdenOSAdapterServiceImplTest.java   
/**
 * Test method for
 * {@link org.o3project.mlo.server.impl.rpc.service.OdenOSAdapterServiceImpl#notifyFlowChanged(java.lang.String)}
 * .
 */
@Test
public void testnotifyFlowChanged_null_element() {

    StringWriter writer = new StringWriter();
    WriterAppender appender = new WriterAppender(new PatternLayout("%p, %m%n"),writer);
    getLogger().addAppender(appender);
    getLogger().setAdditivity(false);

    try {
        obj.notifyFlowChanged(null);
        assertTrue(true);

        String logString = writer.toString();
        assertTrue(logString.contains("notifyFlowChanged Incorrect response"));

    } catch (Exception e) {
        fail();
    } finally{
        getLogger().removeAppender(appender);
        getLogger().setAdditivity(true);
    }
}
项目:mlo-net    文件:SdtncDtoOtherConfigImplTest.java   
/**
 * Test method for {@link org.o3project.mlo.server.impl.rpc.service.SdtncDtoOtherConfigImpl#getVlanProperty(String, String)}.
 */
@Test
public void testGetVlanProperty_500A() {
    StringWriter writer = new StringWriter();
    WriterAppender appender = new WriterAppender(new PatternLayout("%p, %m%n"),writer);
    getLogger().addAppender(appender);
    getLogger().setAdditivity(false);
    setUpObj(DATA_PATH, DATA_FILE_003);
    String vlanId = "500";
    String subKey = ConfigConstants.PROP_SUBKEY_PATH_END_POINT_A_PORT_ID;
    String actual = null;
    try {
        actual = obj.getVlanProperty(vlanId, subKey);
        fail();
    } catch (MloException e) {
        assertTrue(e instanceof ApiCallException);

    }
    String logString = writer.toString();
    assertTrue(logString.contains("Extra portId file read failed [file=src/test/resources/org/o3project/mlo/server/rpc/service/data/test.csv]"));
    assertEquals(null, actual);
    getLogger().removeAppender(appender);
    getLogger().setAdditivity(true);
}
项目:mlo-net    文件:ConfigProviderImplTest.java   
/**
 * Test method for {@link ConfigProviderImpl#getIntegerProperty_NumberFormatException(String)}.
 */
@Test
public void testGetIntegerProperty_NumberFormatException() {

    StringWriter writer = new StringWriter();
    WriterAppender appender = new WriterAppender(new PatternLayout("%p, %m%n"),writer);
    getLogger().addAppender(appender);
    getLogger().setAdditivity(false);
    try {
        String propertiesFilePath = DATA_PATH + "/mlo-srv.003.properties";
        ConfigProviderImpl obj = createConfigProviderImpl(propertiesFilePath);
        obj.getIntegerProperty("あいうえお");
        String logString = writer.toString();
        assertTrue(logString.contains("あいうえお"));
    } catch (Exception e) {
        fail();
    } finally{
        getLogger().removeAppender(appender);
        getLogger().setAdditivity(true);
    }
}
项目:mlo-net    文件:SliceManagerOtherImplTest.java   
/**
 * Test method for {@link org.o3project.mlo.server.impl.logic.SliceManager#updateSlice(org.o3project.mlo.server.dto.RestifRequestDto)}.
 */
@Test
public void testUpdateSlice_unknow() throws Throwable {

    StringWriter writer = new StringWriter();
    WriterAppender appender = new WriterAppender(new PatternLayout("%p, %m%n"),writer);
    getLogger().addAppender(appender);
    getLogger().setAdditivity(false);

    RestifRequestDto reqDto = null;
    reqDto = DtoTestUtils.readReqFromXml(serdes, DATA_PATH, "dummy.n.001.create.req.xml");
    obj.createSlice(reqDto, equConf);
    reqDto = DtoTestUtils.readReqFromXml(serdes, DATA_PATH, "dummy.n.001.update.unknow.req.xml");
    obj.updateSlice(reqDto, equConf);
    String logString = writer.toString();
    assertTrue(logString.contains("Unexpected reqFlow.type, which is ignored"));
}
项目:nabs    文件:Main.java   
private void initialLoad() {
    if(!isLoaded) {
        Layout layout = new PatternLayout("%d{HH:mm:ss} %-5p: %m%n");
        WriterAppender wa = new WriterAppender(layout, System.out);
        BasicConfigurator.configure(wa);

        try {
            Config.setGlobalName("frontend");
        } catch (Exception e) {
            System.out.println("Unable to open configurations database: " + e.getMessage());
            System.exit(1);
        }
        ReceptorManager.v().load();
        isLoaded = true;
    }
}
项目:jcabi-log    文件:LineNumberTest.java   
/**
 * PaternLayout can use %L properly.
 * @throws Exception If something goes wrong
 */
@Test
public void testLineNumber() throws Exception {
    final PatternLayout layout = new PatternLayout();
    layout.setConversionPattern(LineNumberTest.CONV_PATTERN);
    final org.apache.log4j.Logger root = LogManager.getRootLogger();
    final Level level = root.getLevel();
    root.setLevel(Level.INFO);
    final StringWriter writer = new StringWriter();
    final Appender appender = new WriterAppender(layout, writer);
    root.addAppender(appender);
    try {
        Logger.info(this, "Test");
        TimeUnit.MILLISECONDS.sleep(1L);
        MatcherAssert.assertThat(
            writer.toString(),
            Matchers.containsString(
                "com.jcabi.log.LineNumberTest:73"
            )
        );
    } finally {
        root.removeAppender(appender);
        root.setLevel(level);
    }
}
项目:jcabi-log    文件:VerboseProcessTest.java   
/**
 * VerboseProcess.stdoutQuietly() should log stderr messages.
 * @throws Exception If something goes wrong
 */
@Test
public void stdoutQuietlyLogsErrors() throws Exception {
    final StringWriter writer = new StringWriter();
    org.apache.log4j.Logger.getRootLogger().addAppender(
        new WriterAppender(new SimpleLayout(), writer)
    );
    final ProcessBuilder builder;
    final String message = "hello dear friend";
    if (SystemUtils.IS_OS_WINDOWS) {
        builder = new ProcessBuilder("cmd", "/c", "echo", message, "1>&2");
    } else {
        builder = new ProcessBuilder(
            "cat", String.format("/non-existing-file-%s ", message)
        );
    }
    final VerboseProcess process = new VerboseProcess(
        builder, Level.OFF, Level.WARNING
    );
    process.stdoutQuietly();
    MatcherAssert.assertThat(
        writer.toString(),
        Matchers.containsString(message)
    );
}
项目:jcabi-aspects    文件:LoggableTest.java   
/**
 * Loggable can log byte array results.
 */
@Test
public void logsByteArray() {
    final StringWriter writer = new StringWriter();
    org.apache.log4j.Logger.getRootLogger().addAppender(
        new WriterAppender(new SimpleLayout(), writer)
    );
    final byte[] result = new LoggableTest.Foo().logsByteArray();
    MatcherAssert.assertThat(
        writer.toString(),
        Matchers.not(
            Matchers.containsString(
                ClassCastException.class.getSimpleName()
            )
        )
    );
    final Collection<String> bytes = new LinkedList<String>();
    for (final byte part : result) {
        bytes.add(Byte.toString(part));
    }
    MatcherAssert.assertThat(
        writer.toString(),
        Matchers.stringContainsInOrder(bytes)
    );
}
项目:jcabi-aspects    文件:LoggableTest.java   
/**
 * Loggable can log short array results.
 */
@Test
public void logsShortArray() {
    final StringWriter writer = new StringWriter();
    org.apache.log4j.Logger.getRootLogger().addAppender(
        new WriterAppender(new SimpleLayout(), writer)
    );
    final short[] result = new LoggableTest.Foo().logsShortArray();
    MatcherAssert.assertThat(
        writer.toString(),
        Matchers.not(
            Matchers.containsString(
                ClassCastException.class.getSimpleName()
            )
        )
    );
    final Collection<String> shorts = new LinkedList<String>();
    for (final short part : result) {
        shorts.add(Short.toString(part));
    }
    MatcherAssert.assertThat(
        writer.toString(),
        Matchers.stringContainsInOrder(shorts)
    );
}
项目:hadoop-oss    文件:TestLog4Json.java   
public Logger createLogger(Writer writer) {
  TestLoggerRepository repo = new TestLoggerRepository();
  Logger logger = repo.getLogger("test");
  Log4Json layout = new Log4Json();
  WriterAppender appender = new WriterAppender(layout, writer);
  logger.addAppender(appender);
  return logger;
}