1 2 3 4 5 6 7 8 9 10 11 12 13
| BayeuxParameters params = tokenProvider.login();
Consumer<Map<String, Object>> consumer = event -> System.out.println(String.format("Received:\n%s", JSON.toString(event)));
EmpConnector connector = new EmpConnector(params);
connector.setBearerTokenProvider(tokenProvider);
connector.start().get(5, TimeUnit.SECONDS);
TopicSubscription subscription = connector.subscribe(argv[2], replayFrom, consumer).get(5, TimeUnit.SECONDS);
System.out.println(String.format("Subscribed: %s", subscription)); |
Partager