21 int main(
int argc,
char* argv[])
25 string message_logger;
33 JParser<> zap(
"Example program to test message scheduling.");
35 zap[
'M'] =
make_field(message_logger) =
"localhost";
43 catch(
const exception &error) {
44 FATAL(error.what() << endl);
54 out =
new JStreamLogger(cout);
56 out =
new JControlHostLogger(message_logger);
58 JMessageLogger logger(out, argv[0],
debug);
59 JMessageScheduler scheduler(logger, JTimekeeper(log_s * 1000000));
61 scheduler.setCredit(3);
63 for (
int i = 0; i != numberOfMessages; ++i) {
65 cout <<
"sleep [s] " << i * log_s << endl;
67 usleep(i * log_s * 1000000);
69 for (
int i = 0; i != numberOfMessages; ++i) {
70 JErrorStream(scheduler) << i;