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

/forgerock/openam-v13/openam-oauth/src/main/java/com/sun/identity/oauth/service/
H A DConsumerResource.java87 List<Consumer> consumers= oauthResMgr.searchConsumers(searchMap);
88 if ((consumers == null) || consumers.isEmpty()) {
92 Consumer consumer = consumers.get(0);
127 List<Consumer> consumers= oauthResMgr.searchConsumers(searchMap);
128 if ((consumers == null) || consumers.isEmpty()) {
131 Consumer consumer = consumers.get(0);
H A DConsumerRequest.java139 List<Consumer> consumers= oauthResMgr.searchConsumers(searchMap);
140 if ((consumers != null) && (!consumers.isEmpty())) {
165 List<Consumer> consumers= oauthResMgr.searchConsumers(searchMap);
166 if ((consumers != null) && (!consumers.isEmpty())) {
H A DRequestTokenRequest.java127 List<Consumer> consumers = oauthResMgr.searchConsumers(searchMap);
128 if ((consumers != null) && (!consumers.isEmpty())) {
129 cons = consumers.get(0);
H A DOAuthResourceManager.java47 * of the OAuth Token Service related entities, i.e. OAuth consumers,
444 * @return a list of consumers that satisfy the search criteria
456 List<Consumer> consumers = new ArrayList<Consumer>();
462 consumers.add(consumer);
465 return consumers;
/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 28 milliseconds