Searched refs:broker (Results 1 - 25 of 103) sorted by relevance

12345

/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...]
/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-notifications-integration/src/main/java/org/forgerock/openam/notifications/integration/
H A DNotificationsShutdown.java28 * 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 DUpdateOperationTest.java64 * 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 DSchemaReplicationTest.java121 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 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-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DUpdateOperationTest.java64 * 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 DSchemaReplicationTest.java121 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 DUpdateOperationTest.java68 * 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 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 DDependencyTest.java135 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 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/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/
H A DReplicationServerDynamicConfTest.java69 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 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 DUpdateOperationTest.java81 * 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 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/
H A DUpdateOperationTest.java81 * 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 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/
H A DUpdateOperationTest.java81 * 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 DReplicationDomain.java238 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 DReplicationDomain.java238 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 DReplicationDomain.java227 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 DReplicationDomain.java137 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 DReplicationDomain.java138 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 DReplicationDomain.java137 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...]

Completed in 93 milliseconds

12345