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

/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/entitlement/utils/
H A DNullNotificationBroker.java44 public Subscription subscribe(Consumer consumer) { argument
/forgerock/openam/openam-notifications/src/main/java/org/forgerock/openam/notifications/
H A DNotificationBroker.java48 * The given consumer will be called for each notification that is published to any of the bound topics.
50 * @param consumer a consumer that will be called once per published notification
53 Subscription subscribe(Consumer consumer); argument
/forgerock/openidm-v4/openidm-smartevent/src/main/java/org/forgerock/openidm/smartevent/core/
H A DBlockingPublisher.java44 private static Runnable consumer = new Runnable() { field in class:BlockingPublisher
65 consumerThread = new Thread(consumer);
/forgerock/openam-v13/openam-oauth/src/main/java/com/sun/identity/oauth/service/
H A DOAuthResourceManager.java80 * Creates a consumer entity into the data store.
83 * @param consumer the consumer entity to create in the data store
86 public void createConsumer(String entitySubject, Consumer consumer) argument
88 if (consumer == null) {
89 throw new OAuthServiceException("The consumer is null");
92 String consumerName = consumer.getConsName();
94 String consumerSecret = consumer.getConsSecret();
96 String consumerRASKey = consumer.getConsRsakey();
98 String consumerKey = consumer
354 updateConsumer(Consumer consumer) argument
532 deleteConsumer(Consumer consumer) argument
[all...]
/forgerock/openam/openam-notifications/src/main/java/org/forgerock/openam/notifications/brokers/
H A DInMemoryNotificationBroker.java83 Reject.ifTrue(consumers <= 0, "Number of consumer threads must be a positive integer");
125 public Subscription subscribe(Consumer consumer) { argument
126 Reject.ifNull(consumer, "Consumer must not be null");
127 InternalSubscription subscription = new InternalSubscription(consumer);
183 private final Consumer consumer; field in class:InMemoryNotificationBroker.InternalSubscription
186 private InternalSubscription(Consumer consumer) { argument
187 this.consumer = consumer;
222 if (consumer == null) {
227 consumer
[all...]
/forgerock/openam/openam-notifications/src/test/java/org/forgerock/openam/notifications/
H A DInMemoryNotificationBrokerTest.java53 private Consumer consumer; field in class:InMemoryNotificationBrokerTest
74 broker.subscribe(consumer).bindTo(Topic.of("test_topic"));
87 verify(consumer).accept(notificationCapture.capture());
99 broker.subscribe(consumer).bindTo(Topic.of("test_topic"));
112 verify(consumer).accept(any(JsonValue.class));
118 broker.subscribe(consumer).bindTo(Topic.of("test_topic"));
132 verify(consumer).accept(notificationCapture.capture());
141 broker.subscribe(consumer).bindTo(Topic.of("test_topic"));
154 verify(consumer).accept(notificationCapture.capture());
185 broker.subscribe(consumer)
[all...]
/forgerock/openam/openam-notifications-integration/src/main/java/org/forgerock/openam/notifications/integration/brokers/
H A DCTSNotificationBroker.java155 public Subscription subscribe(Consumer consumer) { argument
156 return localBroker.subscribe(consumer);
/forgerock/opendj-b2.6/tests/staf-tests/shared/resource/
H A Dsvnkit.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/tigris/ org/tigris/subversion/ org/tigris/subversion/javahl/ ...
/forgerock/opendj2/tests/staf-tests/shared/resource/
H A Dsvnkit.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/tigris/ org/tigris/subversion/ org/tigris/subversion/javahl/ ...
/forgerock/opendj2.6.2/tests/staf-tests/shared/resource/
H A Dsvnkit.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/tigris/ org/tigris/subversion/ org/tigris/subversion/javahl/ ...
/forgerock/opendj2-jel-hg/tests/staf-tests/shared/resource/
H A Dsvnkit.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/tigris/ org/tigris/subversion/ org/tigris/subversion/javahl/ ...
/forgerock/opendj2-hg/tests/staf-tests/shared/resource/
H A Dsvnkit.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/tigris/ org/tigris/subversion/ org/tigris/subversion/javahl/ ...
/forgerock/opendj-b2.6/ext/svnkit/
H A Dsvnkit.jarMETA-INF/ META-INF/MANIFEST.MF META-INF/LICENSE.txt org/ org/tmatesoft/ org/ ...
/forgerock/opendj2.6.2/ext/svnkit/
H A Dsvnkit.jarMETA-INF/ META-INF/MANIFEST.MF META-INF/LICENSE.txt org/ org/tmatesoft/ org/ ...
/forgerock/opendj2/ext/svnkit/lib/
H A Dsvnkit-1.8.5.jarMETA-INF/ META-INF/MANIFEST.MF META-INF/LICENSE.txt org/ org/tmatesoft/ org/ ...
/forgerock/opendj2-hg/ext/svnkit/lib/
H A Dsvnkit-1.8.5.jarMETA-INF/ META-INF/MANIFEST.MF META-INF/LICENSE.txt org/ org/tmatesoft/ org/ ...

Completed in 104 milliseconds