Package org.apache.log4j

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


      DatabusBootstrapClient s = new DatabusBootstrapClient(sources);
      Checkpoint cp;
      while((cp = s.getNextBatch(10, processorCallback)).getConsumptionMode() != DbusClientMode.ONLINE_CONSUMPTION)
      {
      log.debug(cp);
      }
      }

    private void setBootstrapLoginfoTable(BootstrapConn bootstrapConn, long minLogScn, long maxLogScn)
    {
View Full Code Here


      TestUtil.assertWithBackoff(new ConditionCheck()
            {
              @Override
              public boolean check()
              {
                log.debug("countingConsumer.getNumWindows()=" + countingConsumer.getNumWindows());
                return countingConsumer.getNumWindows() == stats.getNumSysEvents();
              }
            }, "wait until client got all events or for maxTimeout", 64 * 1024, log);

      log.info("Client stats=" + countingConsumer);
View Full Code Here

    DatabusRelayTestUtil.RelayRunner r1=null,r2=null;
        final Logger log = Logger.getLogger("TestDatabusRelayMain.testRelayChainingBasic");
        Logger.getRootLogger().setLevel(Level.INFO);
        log.setLevel(Level.DEBUG);

        log.debug("available processors:" + Runtime.getRuntime().availableProcessors());
        log.debug("available memory:" + Runtime.getRuntime().freeMemory());
        log.debug("total memory:" + Runtime.getRuntime().totalMemory());

    ClientRunner cr = null;
    try
View Full Code Here

        final Logger log = Logger.getLogger("TestDatabusRelayMain.testRelayChainingBasic");
        Logger.getRootLogger().setLevel(Level.INFO);
        log.setLevel(Level.DEBUG);

        log.debug("available processors:" + Runtime.getRuntime().availableProcessors());
        log.debug("available memory:" + Runtime.getRuntime().freeMemory());
        log.debug("total memory:" + Runtime.getRuntime().totalMemory());

    ClientRunner cr = null;
    try
    {
View Full Code Here

        Logger.getRootLogger().setLevel(Level.INFO);
        log.setLevel(Level.DEBUG);

        log.debug("available processors:" + Runtime.getRuntime().availableProcessors());
        log.debug("available memory:" + Runtime.getRuntime().freeMemory());
        log.debug("total memory:" + Runtime.getRuntime().totalMemory());

    ClientRunner cr = null;
    try
    {
      String[][] srcNames =
View Full Code Here

      {

        @Override
        public boolean check()
        {
          log.debug("stats2.getNumSysEvents()=" + stats2.getNumSysEvents());
          return stats2.getNumSysEvents() == stats.getNumSysEvents();
        }
      }, "wait for chained relay to catchup", 60000, log);

      log.info("start the client");
View Full Code Here

      {

        @Override
        public boolean check()
        {
          log.debug("countingConsumer.getNumWindows()="
              + countingConsumer.getNumWindows());
          return countingConsumer.getNumWindows() == stats.getNumSysEvents();
        }
      }, "wait until client got all events", 10000, log);
View Full Code Here

      {

        @Override
        public boolean check()
        {
          log.debug("countingConsumer.getNumWindows()="
              + countingConsumer.getNumWindows());
          return countingConsumer.getNumWindows() == stats.getNumSysEvents();
        }
      }, "wait until client got all events", 10000, log);
View Full Code Here

      Assert.fail("InvalidCheckpointException expected");
    }
    catch (InvalidCheckpointException e)
    {
      //ok -- bootstrap_since_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_start_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

TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.