Examples of addStatus()


Examples of grails.build.logging.GrailsConsole.addStatus()

    @Override
    public void doArtefactConfiguration() {
        GrailsConsole console = GrailsConsole.getInstance();
        long time = System.currentTimeMillis();
        console.addStatus("doArtefactConfiguration started");
        super.doArtefactConfiguration();
        console.addStatus("doArtefactConfiguration took " + (System.currentTimeMillis() - time));
    }
}
View Full Code Here

Examples of grails.build.logging.GrailsConsole.addStatus()

    public void doArtefactConfiguration() {
        GrailsConsole console = GrailsConsole.getInstance();
        long time = System.currentTimeMillis();
        console.addStatus("doArtefactConfiguration started");
        super.doArtefactConfiguration();
        console.addStatus("doArtefactConfiguration took " + (System.currentTimeMillis() - time));
    }
}
View Full Code Here

Examples of org.apache.hadoop.chukwa.inputtools.jplugin.JPluginStatusMetricsList.addStatus()

  }

  @Override
  public JPluginStatusMetricsList getStatus() throws Throwable {
    JPluginStatusMetricsList list = new JPluginStatusMetricsList(this.getClass().getSimpleName());
    list.addStatus("hdfs", hdfs.getUri().toString());
    list.addStatus("path", path);
    return null;
  }

  @Override
View Full Code Here

Examples of org.apache.hadoop.chukwa.inputtools.jplugin.JPluginStatusMetricsList.addStatus()

  @Override
  public JPluginStatusMetricsList getStatus() throws Throwable {
    JPluginStatusMetricsList list = new JPluginStatusMetricsList(this.getClass().getSimpleName());
    list.addStatus("hdfs", hdfs.getUri().toString());
    list.addStatus("path", path);
    return null;
  }

  @Override
  public String getRecordType() {
View Full Code Here

Examples of org.groovymud.object.alive.Player.addStatus()

      if (!shell.getConnection().isActive()) {
        Player p = getObjectRegistry().getPlayerByHandle(shell);
        if (!netDead.containsKey(p)) {
          // not a good way to do it.. but how.. ?
          logger.info(p.getName() + " is net dead..");
          p.addStatus(NET_DEAD_STATUS);
        }
        netDead.increment(p);
      }
    }
  }
View Full Code Here

Examples of org.groovymud.object.alive.Player.addStatus()

      if (!shell.getConnection().isActive()) {
        Player p = getObjectRegistry().getPlayerByHandle(shell);
        if (!netDead.containsKey(p)) {
          // not a good way to do it.. but how.. ?
          logger.info(p.getName() + " is net dead..");
          p.addStatus(NET_DEAD_STATUS);
        }
        netDead.increment(p);
      }
    }
  }
View Full Code Here

Examples of org.groovymud.object.alive.Player.addStatus()

      LoginShell shell = x.next();
      if (!shell.getConnection().isActive()) {
        Player p = getObjectRegistry().getPlayerByHandle(shell);
        if (!netDead.containsKey(p)) {
          logger.info(p.getName() + " is net dead..");
          p.addStatus(netDeadStatus);
        }
        netDead.increment(p);
        p = null;
      }
    }
View Full Code Here

Examples of org.mokai.persist.MessageCriteria.addStatus()

    }

    if (status != null) {
      List<Value> statusList = status.asList();
      for (Value s : statusList) {
        criteria.addStatus(s.asInteger().byteValue());
      }
    }

    return routingEngine.getMessageStore().list(criteria);
  }
View Full Code Here

Examples of org.mokai.persist.MessageCriteria.addStatus()

    MongoMessageStore store = new MongoMessageStore();
    store.setMongo(db);

    MessageCriteria criteria = new MessageCriteria();
    criteria.setDirection(Direction.TO_CONNECTIONS);
    criteria.addStatus(Message.STATUS_FAILED);
    criteria.addStatus(Message.STATUS_RETRYING);
    store.updateStatus(criteria, Message.STATUS_PROCESSED);

    BasicDBObject obj = (BasicDBObject) applicationsCol.findOne();
    Assert.assertNotNull(obj);
View Full Code Here

Examples of org.mokai.persist.MessageCriteria.addStatus()

    store.setMongo(db);

    MessageCriteria criteria = new MessageCriteria();
    criteria.setDirection(Direction.TO_CONNECTIONS);
    criteria.addStatus(Message.STATUS_FAILED);
    criteria.addStatus(Message.STATUS_RETRYING);
    store.updateStatus(criteria, Message.STATUS_PROCESSED);

    BasicDBObject obj = (BasicDBObject) applicationsCol.findOne();
    Assert.assertNotNull(obj);
    Assert.assertEquals( (byte) obj.getInt("status"), Message.STATUS_FAILED);
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.