Cluster cluster = new DefaultCluster(); cluster.registerService(MyService.class, new MyServiceImpl()); cluster.subscribeService(OtherService.class, new OtherServiceListener()); Runtime.getRuntime().addShutdownHook(new Thread(() -> { cluster.shutdown(); })); cluster.join();