/forgerock/openam/openam-federation/OpenFM/src/test/java/com/sun/identity/entitlement/opensso/ |
H A D | EntitlementServiceTest.java | 46 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 D | SessionNotificationPublisher.java | 42 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 D | NotificationsGuiceModule.java | 85 @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 D | SetupInternalNotificationSubscriptions.java | 51 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 D | StressTest.java | 97 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 D | HistoricalTest.java | 249 * 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 D | StressTest.java | 87 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 D | StressTest.java | 97 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 D | HistoricalTest.java | 249 * 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 D | StressTest.java | 87 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 D | StressTest.java | 97 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 D | HistoricalTest.java | 249 * 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 D | SchemaReplicationTest.java | 126 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 D | StressTest.java | 86 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 D | NotificationsWebSocket.java | 77 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 D | TestAttributeEvaluator.java | 74 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 D | TestGroupEvaluator.java | 75 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 D | SubRealmGroupTest.java | 77 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 D | OpenProvisioning.java | 86 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 D | HistoricalTest.java | 221 * 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 D | HistoricalTest.java | 221 * 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 D | HistoricalTest.java | 225 * 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 D | NotificationsWebSocketTest.java | 62 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 D | PolicyPrivilegeManager.java | 75 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 D | InMemoryNotificationBrokerTest.java | 62 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...] |