Examples of org.apache.log4j.Logger.info()

org.apache.log4j.Logger.info()
Log a message with the INFO level with message formatting done according to the messagePattern and the arguments arg1 and arg2.
This form avoids superflous parameter construction. Whenever possible, you should use this form instead of constructing the message parameter using string concatenation. @param messagePattern The message pattern which will be parsed and formatted @param arg1 The first argument to replace the first formatting element @param arg2 The second argument to replace the second formatting element @since 1.3

          conn.requestStream("1", null, 10000, startScnCp, bstCallback);
        }
      }, "asyncBootstrapReqThread");
      asyncBootstrapReq.setDaemon(true);


      log.info("simultaneously closing connection and sending /bootstrap request");
      bstCallback.reset();
      asyncChannelClose.start();
      Assert.assertTrue(closeSent.await(1000, TimeUnit.MILLISECONDS));
      TestUtil.assertWithBackoff(new ConditionCheck()
      {

View Full Code Here

        {
          return !conn._channel.isConnected();
        }
      }, "waiting for disconnect on the client side", 1000, log);
      Assert.assertEquals(AbstractNettyHttpConnection.State.CONNECTED, conn.getNetworkState());
      log.info("asynchronously sending /bootstrap");
      asyncBootstrapReq.start();


      log.info("letting channelClose get through");
      TestUtil.assertWithBackoff(new ConditionCheck()
      {

View Full Code Here

      }, "waiting for disconnect on the client side", 1000, log);
      Assert.assertEquals(AbstractNettyHttpConnection.State.CONNECTED, conn.getNetworkState());
      log.info("asynchronously sending /bootstrap");
      asyncBootstrapReq.start();


      log.info("letting channelClose get through");
      TestUtil.assertWithBackoff(new ConditionCheck()
      {
        @Override
        public boolean check()
        {

View Full Code Here

        {
          return bstCallback.isStreamRequestError();
        }
      }, "wait for streamRequestError callback", 1000, log);
      passMessage.release();
      log.info("finished");
    }
    finally
    {
      conn.close();
      callback.shutdown();

View Full Code Here

    }
    finally
    {
      conn.close();
      callback.shutdown();
      log.info("cleaned");
    }
  }


  private Channel getServerChannelForClientConn(final AbstractNettyHttpConnection conn)
  {

View Full Code Here


  @Test
  public void testSubscriptionStream() throws Exception
  {
    final Logger log = Logger.getLogger("TestDbusEventBufferMult.testSubscriptionStream");
    log.info("start");


    TestSetup t = new TestSetup();


    PhysicalPartition pp100 = new PhysicalPartition(100, "multBufferTest1");
    PhysicalPartitionKey pk1 = new PhysicalPartitionKey(pp100);

View Full Code Here

    assertEquals(statsColls1.getStatsCollector("multBufferTest2:101").getTotalStats().getNumDataEventsFiltered(), 4);


    baos.reset();
    statsCol1.reset(); statsCol2.reset();


    log.info("end");
  }


  @Test
  public void addRemoveBuffers() throws IOException, ScnNotFoundException, InvalidConfigException, DatabusException, OffsetNotFoundException {
    createBufMult();

View Full Code Here

   */
  public void testFullBootstrapManySources()
  {
    final Logger log = Logger.getLogger("TestBootstrapCheckpointHandler.testFullBootstrapManySources");
    //log.setLevel(Level.INFO);
    log.info("START SNAPSHOT: " + MANY_SOURCES[0]);
    BootstrapCheckpointHandler handler = new BootstrapCheckpointHandler(MANY_SOURCES);
    Checkpoint cp1 = handler.createInitialBootstrapCheckpoint(null, 0L);
    assertStartBootstrapCheckpoint(handler, cp1, MANY_SOURCES[0], 0L);
    cp1.setBootstrapStartScn(1000L);

View Full Code Here

    cp1.setBootstrapStartScn(1000L);




    for (int snapshotSourceIndex = 0; snapshotSourceIndex < MANY_SOURCES.length; ++snapshotSourceIndex)
    {
      log.info("FINISH SNAPSHOT: " + MANY_SOURCES[snapshotSourceIndex]);
      handler.finalizeSnapshotPhase(cp1);
      assertSnapshotCompleteCheckpoint(handler, cp1, snapshotSourceIndex, MANY_SOURCES[snapshotSourceIndex]);


      log.info("    START  CATCHUP: " + MANY_SOURCES[0]);
      handler.advanceAfterSnapshotPhase(cp1);

View Full Code Here

    {
      log.info("FINISH SNAPSHOT: " + MANY_SOURCES[snapshotSourceIndex]);
      handler.finalizeSnapshotPhase(cp1);
      assertSnapshotCompleteCheckpoint(handler, cp1, snapshotSourceIndex, MANY_SOURCES[snapshotSourceIndex]);


      log.info("    START  CATCHUP: " + MANY_SOURCES[0]);
      handler.advanceAfterSnapshotPhase(cp1);
      assertAfterSnapshotCheckpoint(cp1, snapshotSourceIndex + 1,
                                    snapshotSourceIndex < MANY_SOURCES.length - 1 ? MANY_SOURCES[snapshotSourceIndex + 1]
                                                                                  : Checkpoint.NO_SOURCE_NAME);
      Assert.assertTrue(snapshotSourceIndex < MANY_SOURCES.length -1 || !handler.needsMoreSnapshot(cp1));

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.