Searched defs:consumers (Results 1 - 1 of 1) sorted by relevance

/forgerock/openam/openam-notifications/src/main/java/org/forgerock/openam/notifications/brokers/
H A DInMemoryNotificationBroker.java79 @Named("queueSize") int queueSize, @Named("consumers") int consumers) {
83 Reject.ifTrue(consumers <= 0, "Number of consumer threads must be a positive integer");
89 executorService = executorServiceFactory.createFixedThreadPool(consumers, "InMemoryNotificationsBroker");
90 for (int i = 0; i < consumers; i++) {
78 InMemoryNotificationBroker(AMExecutorServiceFactory executorServiceFactory, TimeService timeService, @Named(�) int queueSize, @Named(�) int consumers) argument

Completed in 34 milliseconds