| /forgerock/openam/openam-notifications/src/main/java/org/forgerock/openam/notifications/ |
| H A D | Subscription.java | 29 public interface Subscription extends AutoCloseable { interface in inherits:AutoCloseable
37 Subscription bindTo(Topic topic);
45 Subscription unbindFrom(Topic topic);
|
| H A D | NotificationBroker.java | 53 Subscription subscribe(Consumer consumer);
|
| /forgerock/openam/openam-core/src/main/java/com/sun/identity/sm/ |
| H A D | SMSEventListenerManager.java | 54 private static final SetMultimap<DN, Subscription> nodeChanges = newSubscriberMultimap();
57 private static final SetMultimap<DN, Subscription> subNodeChanges = newSubscriberMultimap();
154 static Subscription registerForNotifyChangesToNode(String dn, SMSEventListener eventListener) {
162 static Subscription registerForNotifyChangesToSubNodes(String dn, SMSEventListener eventListener) {
170 private static Subscription addNotificationObject(SetMultimap<DN, Subscription> nodeChangeSubscribers, DN dn,
173 final Subscription subscription = new Subscription(eventListener, dn, nodeChangeSubscribers);
182 private static void sendNotifications(Set<Subscription> subscribers, DN dn, int event) {
187 for (Subscription n
196 static class Subscription { class in class:SMSEventListenerManager
202 Subscription(SMSEventListener eventListener, DN dn, method in class:SMSEventListenerManager.Subscription
[all...] |
| H A D | CachedSubEntries.java | 63 private final SMSEventListenerManager.Subscription subscription;
|
| H A D | CachedSMSEntry.java | 71 private final SMSEventListenerManager.Subscription subscription;
|
| /forgerock/openam/openam-core/src/main/java/org/forgerock/openam/entitlement/utils/ |
| H A D | NullNotificationBroker.java | 22 import org.forgerock.openam.notifications.Subscription;
44 public Subscription subscribe(Consumer consumer) {
|
| /forgerock/openam/openam-notifications/src/main/java/org/forgerock/openam/notifications/brokers/ |
| H A D | InMemoryNotificationBroker.java | 38 import org.forgerock.openam.notifications.Subscription;
125 public Subscription subscribe(Consumer consumer) {
180 private final class InternalSubscription implements Subscription {
192 public Subscription bindTo(Topic topic) {
193 Reject.rejectStateIfTrue(closed, "Subscription is closed");
201 Reject.rejectStateIfTrue(closed, "Subscription is closed");
207 public Subscription unbindFrom(Topic topic) {
208 Reject.rejectStateIfTrue(closed, "Subscription is closed");
|
| /forgerock/openam/openam-notifications/src/test/java/org/forgerock/openam/notifications/ |
| H A D | InMemoryNotificationBrokerTest.java | 290 Subscription subscription = broker.subscribe(consumer)
301 Subscription subscription = broker.subscribe(consumer)
312 Subscription subscription = broker.subscribe(consumer)
|
| /forgerock/openam/openam-notifications-integration/src/test/java/org/forgerock/openam/notifications/brokers/ |
| H A D | CTSNotificationBrokerTest.java | 44 import org.forgerock.openam.notifications.Subscription;
262 Subscription subscription = mock(Subscription.class);
266 Subscription result = broker.subscribe(consumer);
|
| /forgerock/openam/openam-notifications-websocket/src/main/java/org/forgerock/openam/notifications/websocket/ |
| H A D | NotificationsWebSocket.java | 45 import org.forgerock.openam.notifications.Subscription;
80 private Subscription subscription;
|
| /forgerock/openam/openam-notifications-integration/src/main/java/org/forgerock/openam/notifications/integration/brokers/ |
| H A D | CTSNotificationBroker.java | 56 import org.forgerock.openam.notifications.Subscription;
155 public Subscription subscribe(Consumer consumer) {
|
| /forgerock/openam/openam-notifications-websocket/src/test/java/org/forgerock/openam/notifications/websocket/ |
| H A D | NotificationsWebSocketTest.java | 42 import org.forgerock.openam.notifications.Subscription;
64 private Subscription subscription;
|