(String[] args)
| 12 | private static final Logger logger = LogManager.getLogger(TestBinLogger.class); |
| 13 | |
| 14 | public static void main(String[] args) throws Exception { |
| 15 | Thread.setDefaultUncaughtExceptionHandler((t, e) -> { |
| 16 | //noinspection CallToPrintStackTrace |
| 17 | e.printStackTrace(); |
| 18 | logger.error("uncaught exception in {}:", t, e); |
| 19 | }); |
| 20 | Task.initThreadPool(Task.newCriticalThreadPool("ZezeTaskPool"), |
| 21 | Executors.newSingleThreadScheduledExecutor(new ThreadFactoryWithName("ZezeScheduledPool"))); |
| 22 | |
| 23 | var service = new BinLogger.BinLoggerService("binlog"); |
| 24 | service.start(null, 5004); |
| 25 | |
| 26 | var agent = new BinLogger.BinLoggerAgent(); |
| 27 | agent.start("127.0.0.1", 5004).waitReady(); |
| 28 | |
| 29 | var b = new BValue.Data(); |
| 30 | b.setInt_1(9); |
| 31 | logger.info("sendLog: {}", agent.sendLog(12345, b)); |
| 32 | |
| 33 | Thread.sleep(1000); |
| 34 | agent.stop(); |
| 35 | service.stop(); |
| 36 | logger.info("end"); |
| 37 | } |
| 38 | } |
nothing calls this directly
no test coverage detected