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

/forgerock/openam/openam-notifications-websocket/src/main/java/org/forgerock/openam/notifications/websocket/
H A DNotificationsWebSocket.java55 * Currently only supports the parsing of subscription messages. The expected format is:
80 private Subscription subscription; field in class:NotificationsWebSocket
116 subscription = broker.subscribe(new WebSocketConsumer(session));
134 * When the notification websocket is closed, the subscription is closed.
138 subscription.close();
190 subscription.bindTo(Topic.of(topic));
191 sendMessage(session, id, topic, "subscription registered");
/forgerock/openam/openam-notifications-websocket/src/test/java/org/forgerock/openam/notifications/websocket/
H A DNotificationsWebSocketTest.java64 private Subscription subscription; field in class:NotificationsWebSocketTest
87 when(broker.subscribe(any(Consumer.class))).thenReturn(subscription);
106 verify(subscription, never()).bindTo(any(Topic.class));
142 verify(subscription).bindTo(Topic.of("test_topic"));
156 assertThat(jsonCaptor.getValue()).stringAt("message").isEqualTo("subscription registered");
365 verify(subscription).close();
/forgerock/openam/openam-core/src/main/java/com/sun/identity/sm/
H A DCachedSubEntries.java63 private final SMSEventListenerManager.Subscription subscription; field in class:CachedSubEntries
73 subscription = SMSEventListenerManager.registerForNotifyChangesToSubNodes(dn, this);
207 subscription.cancel();
H A DCachedSMSEntry.java71 private final SMSEventListenerManager.Subscription subscription; field in class:CachedSMSEntry
110 subscription = SMSEventListenerManager.registerForNotifyChangesToNode(smsEntry.getDN(), this);
227 subscription.cancel();
294 subscription.cancel();

Completed in 50 milliseconds