@Test public void testEndPoint(final TestContext context) { final Set<Event> all = new ConcurrentHashSet<>(); all.addAll(extractor().extract(ED1.class)); all.addAll(extractor().extract(ED.class)); for (final Event event : all) { getLogger().info("[TEST] Extract event: {0}.", event); } }
public ChoosableSet(final int initialSize) { this.ids = new ConcurrentHashSet<>(initialSize); }
public ChoosableSet(int initialSize) { ids = new ConcurrentHashSet<>(initialSize); }