/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...] |
/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-notifications-integration/src/main/java/org/forgerock/openam/notifications/integration/ |
H A D | NotificationsShutdown.java | 28 * Responsible for telling the notification broker to shutdown. 37 final NotificationBroker broker = InjectorHolder.getInstance(NotificationBroker.class); 40 Reject.ifNull(broker, "Notification broker must not be null"); 46 broker.shutdown();
|
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | UpdateOperationTest.java | 64 * the replication server broker interface. 266 * FIXME Enable this test when broker suspend/resume receive are implemented. 276 * Open a session to the replicationServer using the broker API. 280 ReplicationBroker broker = 291 broker.publish(addMsg(gen, personWithUUIDEntry, user1entryUUID, baseUUID)); 300 broker.publish(addMsg(gen, personWithUUIDEntry, user1entryUUID, baseUUID)); 307 broker.publish( 315 broker.stop(); 338 * Open a session to the replicationServer using the broker API. 342 ReplicationBroker broker 1230 assertClientReceivesExpectedMsg(ReplicationBroker broker, Class<? extends LDAPUpdateMsg> type, DN expectedDN) argument 1443 consumeAllMessages(ReplicationBroker broker) argument [all...] |
H A D | SchemaReplicationTest.java | 121 ReplicationBroker broker = 137 ReplicationMsg msg = broker.receive(); 166 msg = broker.receive(); 171 broker.stop(); 189 ReplicationBroker broker = 198 broker.publish(modMsg); 207 broker.stop(); 226 ReplicationBroker broker = 244 // receive the message on the broker side. 245 ReplicationMsg msg = broker [all...] |
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-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | UpdateOperationTest.java | 64 * the replication server broker interface. 266 * FIXME Enable this test when broker suspend/resume receive are implemented. 276 * Open a session to the replicationServer using the broker API. 280 ReplicationBroker broker = 291 broker.publish(addMsg(gen, personWithUUIDEntry, user1entryUUID, baseUUID)); 300 broker.publish(addMsg(gen, personWithUUIDEntry, user1entryUUID, baseUUID)); 307 broker.publish( 315 broker.stop(); 338 * Open a session to the replicationServer using the broker API. 342 ReplicationBroker broker 1230 assertClientReceivesExpectedMsg(ReplicationBroker broker, Class<? extends LDAPUpdateMsg> type, DN expectedDN) argument 1443 consumeAllMessages(ReplicationBroker broker) argument [all...] |
H A D | SchemaReplicationTest.java | 121 ReplicationBroker broker = 137 ReplicationMsg msg = broker.receive(); 166 msg = broker.receive(); 171 broker.stop(); 189 ReplicationBroker broker = 198 broker.publish(modMsg); 207 broker.stop(); 226 ReplicationBroker broker = 244 // receive the message on the broker side. 245 ReplicationMsg msg = broker [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/ |
H A D | UpdateOperationTest.java | 68 * the replication server broker interface. 290 * FIXME Enable this test when broker suspend/resume receive are implemented. 299 * Open a session to the replicationServer using the broker API. 303 ReplicationBroker broker = 314 broker.publish(addMsg(gen, personWithUUIDEntry, user1entryUUID, baseUUID)); 323 broker.publish(addMsg(gen, personWithUUIDEntry, user1entryUUID, baseUUID)); 330 broker.publish( 338 broker.stop(); 360 * Open a session to the replicationServer using the broker API. 364 ReplicationBroker broker 1216 assertClientReceivesExpectedMsg(ReplicationBroker broker, Class<? extends LDAPUpdateMsg> type, DN expectedDN) argument 1423 consumeAllMessages(ReplicationBroker broker) argument [all...] |
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 | DependencyTest.java | 135 ReplicationBroker broker = openReplicationSession( 151 broker.publish(addMsg(addDN, entry, sequence + 1, sequence, gen)); 152 broker.publish(modifyMsg(addDN, sequence + 1, generatemods("description", "test"), gen)); 191 broker.publish(delMsg(deleteDN, sequence + 1, gen)); 255 // Create replication server, replication domain and broker. 270 ReplicationBroker broker = openReplicationSession( 279 broker.publish(addMsg(addDN, entry, renamedEntryUuid, 1, gen)); 288 broker.publish(modDNMsg(addDN, "dc=new_name", renamedEntryUuid, 1, gen)); 290 broker.publish(delMsg(delDN, renamedEntryUuid, gen)); 363 ReplicationBroker broker [all...] |
/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/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/ |
H A D | ReplicationServerDynamicConfTest.java | 69 ReplicationBroker broker = openReplicationSession( 73 // broker did connect successfully. 74 assertTrue(broker.getCurrentSendWindow() != 0);
|
/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 | UpdateOperationTest.java | 81 * the replication server broker interface. 298 * FIXME Enable this test when broker suspend/resume receive are implemented. 313 * Open a session to the replicationServer using the broker API. 316 ReplicationBroker broker = 340 broker.publish(addMsg); 360 broker.publish(addMsg); 372 broker.publish(delMsg); 381 broker.stop(); 401 * Open a session to the replicationServer using the broker API. 404 ReplicationBroker broker [all...] |
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/ |
H A D | UpdateOperationTest.java | 81 * the replication server broker interface. 298 * FIXME Enable this test when broker suspend/resume receive are implemented. 313 * Open a session to the replicationServer using the broker API. 316 ReplicationBroker broker = 340 broker.publish(addMsg); 360 broker.publish(addMsg); 372 broker.publish(delMsg); 381 broker.stop(); 401 * Open a session to the replicationServer using the broker API. 404 ReplicationBroker broker [all...] |
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/ |
H A D | UpdateOperationTest.java | 81 * the replication server broker interface. 298 * FIXME Enable this test when broker suspend/resume receive are implemented. 313 * Open a session to the replicationServer using the broker API. 316 ReplicationBroker broker = 340 broker.publish(addMsg); 360 broker.publish(addMsg); 372 broker.publish(delMsg); 381 broker.stop(); 401 * Open a session to the replicationServer using the broker API. 404 ReplicationBroker broker [all...] |
/forgerock/opendj2/src/server/org/opends/server/replication/service/ |
H A D | ReplicationDomain.java | 238 protected ReplicationBroker broker; field in class:ReplicationDomain 369 * An object used to protect the initialization of the underlying broker 503 broker.signalStatusChange(status); 649 return broker.getReplicaInfos(); 681 return broker.getReplicaStates(); 692 return broker.getRsInfos(); 705 return broker.getRsServerId(); 774 msg = broker.receive(true, true, false); 803 This must be done while we are still holding the broker lock 883 by the broker loc [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/ |
H A D | ReplicationDomain.java | 238 protected ReplicationBroker broker; field in class:ReplicationDomain 369 * An object used to protect the initialization of the underlying broker 503 broker.signalStatusChange(status); 649 return broker.getReplicaInfos(); 681 return broker.getReplicaStates(); 692 return broker.getRsInfos(); 705 return broker.getRsServerId(); 774 msg = broker.receive(true, true, false); 803 This must be done while we are still holding the broker lock 883 by the broker loc [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/ |
H A D | ReplicationDomain.java | 227 protected ReplicationBroker broker; field in class:ReplicationDomain 348 * An object used to protect the initialization of the underlying broker 482 broker.signalStatusChange(status); 619 return broker.getReplicaInfos(); 651 return broker.getReplicaStates(); 662 return broker.getRsInfos(); 675 return broker.getRsServerId(); 744 msg = broker.receive(true, true, false); 773 This must be done while we are still holding the broker lock 855 by the broker loc [all...] |
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/ |
H A D | ReplicationDomain.java | 137 protected ReplicationBroker broker = null; field in class:ReplicationDomain 282 * An object used to protect the initialization of the underlying broker 456 broker.signalStatusChange(status); 555 return broker.getDsList(); 590 return broker.getReplicaStates(); 601 return broker.getRsList(); 614 return broker.getRsServerId(); 741 msg = broker.receive(true, true, false); 769 This must be done while we are still holding the broker lock 847 by the broker loc [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/ |
H A D | ReplicationDomain.java | 138 protected ReplicationBroker broker = null; field in class:ReplicationDomain 283 * An object used to protect the initialization of the underlying broker 457 broker.signalStatusChange(status); 556 return broker.getDsList(); 591 return broker.getReplicaStates(); 602 return broker.getRsList(); 615 return broker.getRsServerId(); 742 msg = broker.receive(true, true, false); 770 This must be done while we are still holding the broker lock 848 by the broker loc [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/ |
H A D | ReplicationDomain.java | 137 protected ReplicationBroker broker = null; field in class:ReplicationDomain 282 * An object used to protect the initialization of the underlying broker 456 broker.signalStatusChange(status); 555 return broker.getDsList(); 590 return broker.getReplicaStates(); 601 return broker.getRsList(); 614 return broker.getRsServerId(); 741 msg = broker.receive(true, true, false); 769 This must be done while we are still holding the broker lock 847 by the broker loc [all...] |