Searched defs:broker (Results 1 - 25 of 61) sorted by relevance

123

/forgerock/openam/openam-federation/OpenFM/src/test/java/com/sun/identity/entitlement/opensso/
H A DEntitlementServiceTest.java46 private NotificationBroker broker; field in class:EntitlementServiceTest
50 broker = mock(NotificationBroker.class);
55 EntitlementConfiguration ec = new EntitlementService(SubjectUtils.createSubject(adminToken), "/", broker);
/forgerock/openam/openam-core/src/main/java/com/iplanet/dpro/session/service/
H A DSessionNotificationPublisher.java42 private final NotificationBroker broker; field in class:SessionNotificationPublisher
48 final NotificationBroker broker) {
51 this.broker = broker;
85 broker.publish(Topic.of("/agent/session"), notification);
45 SessionNotificationPublisher( final @Named(SessionConstants.SESSION_DEBUG) Debug sessionDebug, final NotificationsConfig notificationsConfig, final NotificationBroker broker) argument
/forgerock/openam/openam-notifications-integration/src/main/java/org/forgerock/openam/notifications/integration/
H A DNotificationsGuiceModule.java85 @LocalOnly NotificationBroker broker,
90 return new CTSNotificationBroker(store, broker, queueSize, tokenExpirySeconds,
84 notificationBroker(CTSPersistentStore store, @LocalOnly NotificationBroker broker, @Named(�) int queueSize, @Named(�) long tokenExpirySeconds, @Named(�) long publishFrequencyMilliseconds, AMExecutorServiceFactory factory) argument
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/entitlement/
H A DSetupInternalNotificationSubscriptions.java51 NotificationBroker broker = InjectorHolder.getInstance(NotificationBroker.class);
53 setUpPolicySetSubscriptions(broker);
56 private void setUpPolicySetSubscriptions(NotificationBroker broker) { argument
57 broker.subscribe(new PolicySetNotificationConsumer()).bindTo(TOPIC_INTERNAL_POLICYSET);
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DStressTest.java97 ReplicationBroker broker =
105 * replicationServer and forwarded to our replicationServer broker session.
121 ReplicationMsg msg = broker.receive();
135 reader = new BrokerReader(broker);
168 broker.stop();
276 * Continuously reads messages from a replicationServer broker until there is nothing
281 private ReplicationBroker broker; field in class:StressTest.BrokerReader
287 * @param broker
289 public BrokerReader(ReplicationBroker broker) argument
291 this.broker
[all...]
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DHistoricalTest.java249 * broker API to simulate the ordering that would happen on the first server
267 * Open a session to the replicationServer using the broker API.
270 ReplicationBroker broker =
325 publishModify(broker, t1, dn1, entryuuid, mod);
337 publishModify(broker, t2, dn1, entryuuid, mod);
348 publishModify(broker, t2, dn2, entryuuid2, mod);
355 publishModify(broker, t1, dn2, entryuuid2, mod);
380 void publishModify(ReplicationBroker broker, ChangeNumber changeNum, argument
386 broker.publish(modMsg);
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DStressTest.java87 ReplicationBroker broker =
95 * replicationServer and forwarded to our replicationServer broker session.
106 ReplicationMsg msg = broker.receive();
117 reader = new BrokerReader(broker);
143 broker.stop();
246 * Continuously reads messages from a replicationServer broker until there is nothing
251 private ReplicationBroker broker; field in class:StressTest.BrokerReader
258 public BrokerReader(ReplicationBroker broker) argument
260 this.broker = broker;
[all...]
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DStressTest.java97 ReplicationBroker broker =
105 * replicationServer and forwarded to our replicationServer broker session.
121 ReplicationMsg msg = broker.receive();
135 reader = new BrokerReader(broker);
168 broker.stop();
276 * Continuously reads messages from a replicationServer broker until there is nothing
281 private ReplicationBroker broker; field in class:StressTest.BrokerReader
287 * @param broker
289 public BrokerReader(ReplicationBroker broker) argument
291 this.broker
[all...]
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DHistoricalTest.java249 * broker API to simulate the ordering that would happen on the first server
267 * Open a session to the replicationServer using the broker API.
270 ReplicationBroker broker =
325 publishModify(broker, t1, dn1, entryuuid, mod);
337 publishModify(broker, t2, dn1, entryuuid, mod);
348 publishModify(broker, t2, dn2, entryuuid2, mod);
355 publishModify(broker, t1, dn2, entryuuid2, mod);
380 void publishModify(ReplicationBroker broker, ChangeNumber changeNum, argument
386 broker.publish(modMsg);
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DStressTest.java87 ReplicationBroker broker =
95 * replicationServer and forwarded to our replicationServer broker session.
106 ReplicationMsg msg = broker.receive();
117 reader = new BrokerReader(broker);
143 broker.stop();
246 * Continuously reads messages from a replicationServer broker until there is nothing
251 private ReplicationBroker broker; field in class:StressTest.BrokerReader
258 public BrokerReader(ReplicationBroker broker) argument
260 this.broker = broker;
[all...]
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DStressTest.java97 ReplicationBroker broker =
105 * replicationServer and forwarded to our replicationServer broker session.
121 ReplicationMsg msg = broker.receive();
135 reader = new BrokerReader(broker);
168 broker.stop();
276 * Continuously reads messages from a replicationServer broker until there is nothing
281 private ReplicationBroker broker; field in class:StressTest.BrokerReader
287 * @param broker
289 public BrokerReader(ReplicationBroker broker) argument
291 this.broker
[all...]
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DHistoricalTest.java249 * broker API to simulate the ordering that would happen on the first server
267 * Open a session to the replicationServer using the broker API.
270 ReplicationBroker broker =
325 publishModify(broker, t1, dn1, entryuuid, mod);
337 publishModify(broker, t2, dn1, entryuuid, mod);
348 publishModify(broker, t2, dn2, entryuuid2, mod);
355 publishModify(broker, t1, dn2, entryuuid2, mod);
380 void publishModify(ReplicationBroker broker, ChangeNumber changeNum, argument
386 broker.publish(modMsg);
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/
H A DSchemaReplicationTest.java126 ReplicationBroker broker =
138 ModifyMsg modMsg = receiveModifyMsg(broker);
145 receiveModifyMsg(broker);
149 broker.stop();
172 ReplicationBroker broker =
181 broker.publish(modMsg);
188 broker.stop();
206 ReplicationBroker broker =
222 // receive the message on the broker side.
223 ModifyMsg modMsg = receiveModifyMsg(broker);
270 receiveModifyMsg(ReplicationBroker broker) argument
[all...]
H A DStressTest.java86 ReplicationBroker broker =
94 * replicationServer and forwarded to our replicationServer broker session.
105 ReplicationMsg msg = broker.receive();
116 reader = new BrokerReader(broker);
142 broker.stop();
241 * Continuously reads messages from a replicationServer broker until there is nothing
246 private ReplicationBroker broker; field in class:StressTest.BrokerReader
253 public BrokerReader(ReplicationBroker broker) argument
255 this.broker = broker;
[all...]
/forgerock/openam/openam-notifications-websocket/src/main/java/org/forgerock/openam/notifications/websocket/
H A DNotificationsWebSocket.java77 private final NotificationBroker broker; field in class:NotificationsWebSocket
89 broker = null;
97 * @param broker the notification broker
100 public NotificationsWebSocket(NotificationBroker broker, TimeService timeService, argument
102 Reject.ifNull(broker, "Broker must not be null");
103 this.broker = broker;
116 subscription = broker.subscribe(new WebSocketConsumer(session));
/forgerock/openam/openam-federation/OpenFM/src/test/java/com/sun/identity/entitlement/
H A DTestAttributeEvaluator.java74 private NotificationBroker broker; field in class:TestAttributeEvaluator
86 broker = Mockito.mock(NotificationBroker.class);
101 applicationServiceFactory, resourceTypeService, constraintValidator, broker, notificationsConfig);
128 applicationServiceFactory, resourceTypeService, constraintValidator, broker, notificationsConfig);
H A DTestGroupEvaluator.java75 private NotificationBroker broker; field in class:TestGroupEvaluator
87 broker = Mockito.mock(NotificationBroker.class);
102 applicationServiceFactory, resourceTypeService, constraintValidator, broker, notificationsConfig);
125 applicationServiceFactory, resourceTypeService, constraintValidator, broker, notificationsConfig);
H A DSubRealmGroupTest.java77 private NotificationBroker broker; field in class:SubRealmGroupTest
101 broker = mock(NotificationBroker.class);
103 EntitlementConfiguration ec = new EntitlementService(adminSubject, "/", broker);
137 EntitlementConfiguration ec = new EntitlementService(adminSubject, "/", broker);
/forgerock/openam/openam-federation/OpenFM/src/test/java/com/sun/identity/policy/
H A DOpenProvisioning.java86 private NotificationBroker broker; field in class:OpenProvisioning
95 broker = Mockito.mock(NotificationBroker.class);
113 applicationServiceFactory, resourceTypeService, constraintValidator, broker, notificationsConfig);
151 applicationServiceFactory, resourceTypeService, constraintValidator, broker, notificationsConfig);
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DHistoricalTest.java221 * broker API to simulate the ordering that would happen on the first server
237 * Open a session to the replicationServer using the broker API.
240 ReplicationBroker broker =
287 publishModify(broker, t1, dn1, entryuuid, attrType, "A");
297 publishModify(broker, t2, dn1, entryuuid, attrType, "B");
305 publishModify(broker, t2, dn2, entryuuid2, attrType, "B");
310 publishModify(broker, t1, dn2, entryuuid2, attrType, "A");
331 private static void publishModify(ReplicationBroker broker, CSN changeNum, argument
338 broker.publish(new ModifyMsg(changeNum, dn, mods, entryuuid));
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DHistoricalTest.java221 * broker API to simulate the ordering that would happen on the first server
237 * Open a session to the replicationServer using the broker API.
240 ReplicationBroker broker =
287 publishModify(broker, t1, dn1, entryuuid, attrType, "A");
297 publishModify(broker, t2, dn1, entryuuid, attrType, "B");
305 publishModify(broker, t2, dn2, entryuuid2, attrType, "B");
310 publishModify(broker, t1, dn2, entryuuid2, attrType, "A");
331 private static void publishModify(ReplicationBroker broker, CSN changeNum, argument
338 broker.publish(new ModifyMsg(changeNum, dn, mods, entryuuid));
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/
H A DHistoricalTest.java225 * broker API to simulate the ordering that would happen on the first server
239 * Open a session to the replicationServer using the broker API.
242 ReplicationBroker broker =
288 publishModify(broker, t1, dn1, entryuuid, attrType, "A");
292 publishModify(broker, t2, dn1, entryuuid, attrType, "B");
300 publishModify(broker, t2, dn2, entryuuid2, attrType, "B");
304 publishModify(broker, t1, dn2, entryuuid2, attrType, "A");
341 private static void publishModify(ReplicationBroker broker, CSN changeNum, argument
346 broker.publish(new ModifyMsg(changeNum, dn, mods, entryuuid));
/forgerock/openam/openam-notifications-websocket/src/test/java/org/forgerock/openam/notifications/websocket/
H A DNotificationsWebSocketTest.java62 private NotificationBroker broker; field in class:NotificationsWebSocketTest
86 notificationsWebSocket = new NotificationsWebSocket(broker, timeService, executorService);
87 when(broker.subscribe(any(Consumer.class))).thenReturn(subscription);
98 verify(broker).subscribe(any(Consumer.class));
291 verify(broker).subscribe(consumerCaptor.capture());
308 verify(broker).subscribe(consumerCaptor.capture());
324 verify(broker).subscribe(consumerCaptor.capture());
342 verify(broker).subscribe(consumerCaptor.capture());
/forgerock/openam/openam-entitlements/src/main/java/com/sun/identity/entitlement/opensso/
H A DPolicyPrivilegeManager.java75 private final NotificationBroker broker; field in class:PolicyPrivilegeManager
98 NotificationBroker broker,
101 this.broker = broker;
309 broker.publish(Topic.of("/agent/policy"), json);
95 PolicyPrivilegeManager(ApplicationServiceFactory applicationServiceFactory, ResourceTypeService resourceTypeService, ConstraintValidator constraintValidator, NotificationBroker broker, NotificationsConfig notificationsConfig) argument
/forgerock/openam/openam-notifications/src/test/java/org/forgerock/openam/notifications/
H A DInMemoryNotificationBrokerTest.java62 private NotificationBroker broker; field in class:InMemoryNotificationBrokerTest
68 broker = new InMemoryNotificationBroker(executorServiceFactory, timeService, 2, CONSUMERS);
74 broker.subscribe(consumer).bindTo(Topic.of("test_topic"));
78 broker.publish(Topic.of("test_topic"), notification);
84 broker.shutdown();
98 broker.subscribe(badConsumer).bindTo(Topic.of("test_topic"));
99 broker.subscribe(consumer).bindTo(Topic.of("test_topic"));
103 broker.publish(Topic.of("test_topic"), notification);
109 broker.shutdown();
118 broker
[all...]

Completed in 107 milliseconds

123