@@ -271,15 +271,16 @@ fn topology() -> elfo::Topology {
271271 // * `RUST_LOG=info,[{actor_group=aggregators}]`
272272 //
273273 // However, it's more useful to control logging in the config file.
274- let logger = elfo:: batteries:: logger:: init ( ) ;
274+ console_subscriber:: init ( ) ;
275+ // let logger = elfo::batteries::logger::init();
275276 // Setup up telemetry (based on the `metrics` crate).
276277 let telemeter = elfo:: batteries:: telemeter:: init ( ) ;
277278
278279 // Define actor groups.
279280 let producers = topology. local ( "producers" ) ;
280281 let aggregators = topology. local ( "aggregators" ) ;
281282 let reporters = topology. local ( "reporters" ) ;
282- let loggers = topology. local ( "system.loggers" ) ;
283+ // let loggers = topology.local("system.loggers");
283284 let telemeters = topology. local ( "system.telemeters" ) ;
284285 let dumpers = topology. local ( "system.dumpers" ) ;
285286 let pingers = topology. local ( "system.pingers" ) ;
@@ -295,7 +296,7 @@ fn topology() -> elfo::Topology {
295296 producers. mount ( producer:: new ( ) ) ;
296297 aggregators. mount ( aggregator:: new ( ) ) ;
297298 reporters. mount ( reporter:: new ( ) ) ;
298- loggers. mount ( logger) ;
299+ // loggers.mount(logger);
299300 telemeters. mount ( telemeter) ;
300301 dumpers. mount ( elfo:: batteries:: dumper:: new ( ) ) ;
301302 pingers. mount ( elfo:: batteries:: pinger:: new ( & topology) ) ;
0 commit comments