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

org.apache.log4j.Logger.debug()
Log a message with the DEBUG 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

      Assert.fail("InvalidCheckpointException expected");
    }
    catch (InvalidCheckpointException e)
    {
      //ok -- bootstrap_target_scn must be set
      log.debug("exception thrown: " + e);
    }


    try
    {
      cp = new Checkpoint("{\"consumption_mode\":\"BOOTSTRAP_CATCHUP\", \"bootstrap_since_scn\":0," +

View Full Code Here

      Assert.fail("InvalidCheckpointException expected");
    }
    catch (InvalidCheckpointException e)
    {
      //ok -- bootstrap_target_scn < bootstrap_start_scn
      log.debug("exception thrown: " + e);
    }


    try
    {
      cp = new Checkpoint("{\"consumption_mode\":\"BOOTSTRAP_CATCHUP\", \"bootstrap_since_scn\":0," +

View Full Code Here

      Assert.fail("InvalidCheckpointException expected");
    }
    catch (InvalidCheckpointException e)
    {
      //ok - missing bootstrap_catchup_source_index
      log.debug("exception thrown: " + e);
    }


    try
    {
      cp = new Checkpoint("{\"consumption_mode\":\"BOOTSTRAP_CATCHUP\", \"bootstrap_since_scn\":0," +

View Full Code Here

      Assert.fail("InvalidCheckpointException expected");
    }
    catch (InvalidCheckpointException e)
    {
      //ok -- bootstrap_catchup_snapshot index must be set
      log.debug("exception thrown: " + e);
    }


    try
    {
      cp = new Checkpoint("{\"consumption_mode\":\"BOOTSTRAP_CATCHUP\", \"bootstrap_since_scn\":0," +

View Full Code Here

      Assert.fail("InvalidCheckpointException expected");
    }
    catch (InvalidCheckpointException e)
    {
      //ok - bootstrap_offset must be -1
      log.debug("exception thrown: " + e);
    }


    try
    {
      cp = new Checkpoint("{\"consumption_mode\":\"BOOTSTRAP_CATCHUP\", \"bootstrap_since_scn\":0," +

View Full Code Here

      Assert.fail("InvalidCheckpointException expected");
    }
    catch (InvalidCheckpointException e)
    {
      //ok - bootstrap_catchup_source_index > bootstrap_catchup_snapshot index
      log.debug("exception thrown: " + e);
    }


    cp = new Checkpoint("{\"consumption_mode\":\"BOOTSTRAP_CATCHUP\", \"bootstrap_since_scn\":0," +
        "\"bootstrap_start_scn\":1000,\"bootstrap_target_scn\":2000,\"bootstrap_catchup_source_index\":1," +
        "\"bootstrap_snapshot_source_index\":1}");

View Full Code Here

          objCapture.clear();


          respStartOfs = eventOfs.get(2).get(1);
          respEndOfs = eventOfs.get(2).get(84);


          log.debug("Checkpoint String is :" + cpString);


          cp = new Checkpoint(cpString);
          log.info("last window read was partial. So the client would have reset the windowOffset");
          assertTrue("Is WindowOffset Cleared",cp.getWindowOffset() == -1);
          assertEquals( "WindowSCN == PrevSCN. Ckpt :" + cp, cp.getWindowScn(), cp.getPrevScn());

View Full Code Here

                                                           respEndOfs - respStartOfs,
                                                           stats);
          NettyTestUtils.sendServerResponses(relay, clientAddr, streamResp,
                                             new DefaultHttpChunk(streamRes));


          log.debug("NumEvents already seen :" + numEvents);


          log.info("make sure the client processes the response correctly");
          TestUtil.assertWithBackoff(new ConditionCheck()
          {
            @Override

View Full Code Here

          TestUtil.assertWithBackoff(new ConditionCheck()
          {
            @Override
            public boolean check()
            {
              log.debug("lastWrittenScn=" + clientConn.getDataEventsBuffer().lastWrittenScn() + ", NumEvents :" + stats.getTotalStats().getNumDataEvents() );
              return clientConn.getDataEventsBuffer().lastWrittenScn() == 90;
            }
          }, "client receives /stream response, Sequences :" + consumer.getSequences(),
             timeoutMult * 1100, log);

View Full Code Here

          TestUtil.assertWithBackoff(new ConditionCheck()
          {
            @Override
            public boolean check()
            {
              log.debug("events num=" + consumer.getEventNum());
              return stats.getTotalStats().getNumDataEvents() == consumer.getEventNum();
            }
          }, "client processes /stream response", timeoutMult * 1100, log);


          log.info("one more onStartDataEventSequence because of the rollback");

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.