1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18
| BayeuxParameters params = tokenProvider.login();
EmpConnector connector = new EmpConnector(params);
connector.setBearerTokenProvider(tokenProvider);
connector.start().get(5, TimeUnit.SECONDS);
Map<String, Object> jsonMap = new HashMap<>();
Consumer<Map<String, Object>> consumer = jsonMap::putAll;
// comme d'hab
TopicSubscription subscription = connector.subscribe(argv[2], replayFrom, consumer).get(5, TimeUnit.SECONDS);
System.out.println(String.format("Subscribed: %s", subscription));
// afficher le résultat
System.out.println(jsonMap); |
Partager