Searched defs:topic (Results 1 - 25 of 30) sorted by relevance

12

/forgerock/openam-v13/openam-audit/openam-audit-configuration/src/main/java/org/forgerock/openam/audit/configuration/
H A DJdbcFieldToColumnDefaultValues.java112 String topic = null;
116 Set<String> values = keyValues.get("topic");
118 topic = values.iterator().next();
122 return getDefaultValues(topic);
126 * Get the default values for the given topic.
128 * @param topic The topic for which the default values are required.
131 public static Set<String> getDefaultValues(String topic) { argument
132 if (DEFAULT_VALUES.isDefined(topic)) {
133 return DEFAULT_VALUES.get(topic)
[all...]
/forgerock/openam/openam-audit/openam-audit-configuration/src/main/java/org/forgerock/openam/audit/configuration/
H A DJdbcFieldToColumnDefaultValues.java115 String topic = null;
118 Set<String> values = keyValues.get("topic");
120 topic = values.iterator().next();
124 return getDefaultValues(topic);
128 * Get the default values for the given topic.
130 * @param topic The topic for which the default values are required.
133 public static Set<String> getDefaultValues(String topic) { argument
134 if (DEFAULT_VALUES.isDefined(topic)) {
135 return DEFAULT_VALUES.get(topic)
[all...]
/forgerock/openam/openam-notifications/src/main/java/org/forgerock/openam/notifications/
H A DSubscription.java32 * Updates the subscription to receive notifications for the given topic.
34 * @param topic the new topic to bind to
37 Subscription bindTo(Topic topic); argument
40 * Updates the subscription to stop receiving notifications for the given topic.
42 * @param topic the topic to be unbound from
45 Subscription unbindFrom(Topic topic); argument
48 * Determines whether the subscription is bound to the given topic.
50 * @param topic th
53 isBoundTo(Topic topic) argument
[all...]
H A DNotificationBroker.java32 * Publish passes the notification onto subscribers of the topic. If there
33 * are no subscribers to the same topic, the notification is discarded.
38 * @param topic topic
40 * @return attempts to give some indication whether the topic was successfully published. False gives a guarantee
43 boolean publish(Topic topic, JsonValue notification); argument
/forgerock/openam-v13/openam-audit/openam-audit-core/src/main/java/org/forgerock/openam/audit/
H A DAMAuditService.java44 * Determines if the audit service is auditing the specified {@literal topic} and {@literal eventName}. If you
47 * @param topic The auditing topic.
49 * @return {@code true} if Auditing is switched on and if the topic and eventName should be audited.
51 boolean isAuditEnabled(String topic, EventName eventName); argument
H A DAuditEventPublisher.java28 * Tries to publish the provided AuditEvent to the specified topic of the AuditService.
34 * @param topic Coarse-grained categorization of the AuditEvent's type.
37 void tryPublish(String topic, AuditEvent auditEvent); argument
40 * Determines if the audit service is auditing the specified {@literal topic} in the specified {@literal realm}. If
47 * @param topic The auditing topic.
49 * @return {@code true} if the topic should be audited.
51 boolean isAuditing(String realm, String topic, AuditConstants.EventName eventName); argument
H A DRealmAuditServiceProxy.java72 public boolean isAuditEnabled(String topic, EventName eventName) { argument
80 && isAuditing(topic)
83 return defaultDelegate.isAuditEnabled(topic, eventName);
H A DDefaultAuditServiceProxy.java84 public boolean isAuditEnabled(String topic, EventName eventName) { argument
93 && isAuditing(topic)
H A DAuditEventPublisherImpl.java60 public void tryPublish(String topic, AuditEvent auditEvent) { argument
64 publishToDefault(topic, auditEvent);
66 publishForRealm(realm, topic, auditEvent);
69 logException(e, topic, auditEvent);
74 public boolean isAuditing(String realm, String topic, EventName eventName) { argument
76 return auditServiceProvider.getDefaultAuditService().isAuditEnabled(topic, eventName);
78 return auditServiceProvider.getAuditService(realm).isAuditEnabled(topic, eventName);
82 private void publishToDefault(String topic, AuditEvent auditEvent) throws ResourceException { argument
86 CreateRequest request = newCreateRequest(topic, auditEvent.getValue());
91 private void publishForRealm(String realm, String topic, AuditEven argument
104 logException(Exception exception, String topic, AuditEvent auditEvent) argument
[all...]
/forgerock/openam/openam-audit/openam-audit-core/src/main/java/org/forgerock/openam/audit/
H A DAMAuditService.java44 * Determines if the audit service is auditing the specified {@literal topic} and {@literal eventName}. If you
47 * @param topic The auditing topic.
49 * @return {@code true} if Auditing is switched on and if the topic and eventName should be audited.
51 boolean isAuditEnabled(String topic, EventName eventName); argument
H A DAuditEventPublisher.java28 * Tries to publish the provided AuditEvent to the specified topic of the AuditService.
34 * @param topic Coarse-grained categorization of the AuditEvent's type.
37 void tryPublish(String topic, AuditEvent auditEvent); argument
40 * Determines if the audit service is auditing the specified {@literal topic} in the specified {@literal realm}. If
47 * @param topic The auditing topic.
49 * @return {@code true} if the topic should be audited.
51 boolean isAuditing(String realm, String topic, AuditConstants.EventName eventName); argument
H A DRealmAuditServiceProxy.java72 public boolean isAuditEnabled(String topic, EventName eventName) { argument
80 && isAuditing(topic)
83 return defaultDelegate.isAuditEnabled(topic, eventName);
H A DAuditEventPublisherImpl.java60 public void tryPublish(String topic, AuditEvent auditEvent) { argument
64 publishToDefault(topic, auditEvent);
66 publishForRealm(realm, topic, auditEvent);
69 logException(e, topic, auditEvent);
74 public boolean isAuditing(String realm, String topic, EventName eventName) { argument
76 return auditServiceProvider.getDefaultAuditService().isAuditEnabled(topic, eventName);
78 return auditServiceProvider.getAuditService(realm).isAuditEnabled(topic, eventName);
82 private void publishToDefault(String topic, AuditEvent auditEvent) throws ResourceException { argument
86 CreateRequest request = newCreateRequest(topic, auditEvent.getValue());
91 private void publishForRealm(String realm, String topic, AuditEven argument
104 logException(Exception exception, String topic, AuditEvent auditEvent) argument
[all...]
H A DDefaultAuditServiceProxy.java63 name = "topic",
93 .paths(paths().put("{topic}",
125 public boolean isAuditEnabled(String topic, EventName eventName) { argument
134 && isAuditing(topic)
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/entitlement/utils/
H A DNullNotificationBroker.java39 public boolean publish(Topic topic, JsonValue notification) { argument
/forgerock/openam/openam-federation/openam-federation-library/src/main/java/org/forgerock/openam/plugin/configuration/
H A DFedletAuditEventPublisherImpl.java28 public void tryPublish(String topic, AuditEvent auditEvent) { argument
33 public boolean isAuditing(String realm, String topic, AuditConstants.EventName eventName) { argument
/forgerock/openam-v13/openam-sts/openam-soap-sts/openam-soap-sts-server/src/main/java/org/forgerock/openam/sts/soap/audit/
H A DSoapSTSAuditEventPublisher.java71 * @param topic Coarse-grained categorization of the AuditEvent's type.
75 public void tryPublish(String topic, AuditEvent auditEvent) { argument
111 public boolean isAuditing(String realm, String topic, EventName eventName) { argument
/forgerock/openam/openam-notifications-websocket/src/main/java/org/forgerock/openam/notifications/websocket/
H A DNotificationsWebSocket.java60 * "topic": "/some/topic/string"
179 if (!json.isDefined("topic")) {
180 sendError(session, id, "missing required field \"topic\"");
183 if (!json.get("topic").isString()) {
184 sendError(session, id, "\"topic\" must be a string");
188 String topic = json.get("topic").asString();
190 subscription.bindTo(Topic.of(topic));
191 sendMessage(session, id, topic, "subscriptio
219 sendMessage(Session session, String id, String topic, String message) argument
[all...]
/forgerock/openam/openam-sts/openam-soap-sts/openam-soap-sts-server/src/main/java/org/forgerock/openam/sts/soap/audit/
H A DSoapSTSAuditEventPublisher.java72 * @param topic Coarse-grained categorization of the AuditEvent's type.
76 public void tryPublish(String topic, AuditEvent auditEvent) { argument
109 public boolean isAuditing(String realm, String topic, EventName eventName) { argument
/forgerock/openam-v13/openam-cli/openam-cli-impl/src/main/java/com/sun/identity/cli/
H A DLogWriter.java165 String topic;
168 topic = AuditConstants.AUTHENTICATION_TOPIC;
171 topic = AuditConstants.ACCESS_TOPIC;
184 sendEvent(topic, eventJson, sessionId, new SessionID(sessionId).getSessionServerURL());
187 private static void sendEvent(String topic, JsonValue eventJson, String sessionId, String baseUrl) throws HttpApplicationException, URISyntaxException { argument
197 request.setUri(baseUrl + topic + "?_action=create");
/forgerock/openam/openam-cli/openam-cli-impl/src/main/java/com/sun/identity/cli/
H A DLogWriter.java168 String topic;
171 topic = AuditConstants.AUTHENTICATION_TOPIC;
174 topic = AuditConstants.ACCESS_TOPIC;
187 sendEvent(topic, eventJson, sessionId, WebtopNaming.mapSiteToServer(new SessionID(sessionId)));
190 private static void sendEvent(String topic, JsonValue eventJson, String sessionId, String baseUrl) throws HttpApplicationException, URISyntaxException { argument
199 request.setUri(baseUrl + topic + "?_action=create");
/forgerock/openam/openam-notifications/src/main/java/org/forgerock/openam/notifications/brokers/
H A DInMemoryNotificationBroker.java96 public boolean publish(Topic topic, JsonValue notification) { argument
97 Reject.ifNull(topic, "Topic must not be null");
105 NotificationEntry entry = NotificationEntry.of(topic, packageNotification(topic, notification));
115 private JsonValue packageNotification(Topic topic, JsonValue notification) { argument
119 field("topic", topic.getIdentifier()),
171 subscription.consumeIfApplicable(entry.topic, entry.notification);
192 public Subscription bindTo(Topic topic) { argument
194 Reject.ifNull(topic, "Topi
200 isBoundTo(Topic topic) argument
207 unbindFrom(Topic topic) argument
221 consumeIfApplicable(Topic topic, JsonValue notification) argument
234 private final Topic topic; field in class:InMemoryNotificationBroker.NotificationEntry
237 NotificationEntry(Topic topic, JsonValue notification) argument
242 of(Topic topic, JsonValue notification) argument
[all...]
/forgerock/openam/openam-notifications-integration/src/main/java/org/forgerock/openam/notifications/integration/brokers/
H A DCTSNotificationBroker.java138 public boolean publish(Topic topic, JsonValue notification) { argument
139 Reject.ifNull(topic, "Topic must not be null");
147 if (!queue.offer(NotificationEntry.of(topic, notification))) {
191 String topic = entry.get("topic").asString();
194 localBroker.publish(Topic.of(topic), content);
230 field("topic", entry.topic.getIdentifier()),
258 private final Topic topic; field in class:CTSNotificationBroker.NotificationEntry
261 private NotificationEntry(Topic topic, JsonValu argument
266 of(Topic topic, JsonValue notification) argument
[all...]
/forgerock/opendj2/resource/dsml/lib/
H A Dj2ee.jarMETA-INF/MANIFEST.MF javax/servlet/jsp/resources/jspxml.dtd javax/servlet/jsp/resources/web- ...
/forgerock/opendj-b2.6/resource/dsml/lib/
H A Dj2ee.jarMETA-INF/MANIFEST.MF javax/servlet/jsp/resources/jspxml.dtd javax/servlet/jsp/resources/web- ...

Completed in 142 milliseconds

12