Searched refs:eventBus (Results 1 - 18 of 18) sorted by relevance

/forgerock/openam-v13/openam-radius/openam-radius-server/src/test/java/org/forgerock/openam/radius/server/monitoring/
H A DRadiusServerEventRegistrarTest.java38 EventBus eventBus = new EventBus();
40 final RadiusServerEventRegistrator eventRegistrar = new RadiusServerEventRegistrar(eventBus);
53 EventBus eventBus = new EventBus();
54 final RadiusServerEventRegistrar eventRegistrar = new RadiusServerEventRegistrar(eventBus);
69 EventBus eventBus = new EventBus();
70 final RadiusServerEventRegistrar eventRegistrar = new RadiusServerEventRegistrar(eventBus);
85 EventBus eventBus = new EventBus();
86 final RadiusServerEventRegistrar eventRegistrar = new RadiusServerEventRegistrar(eventBus);
101 EventBus eventBus = new EventBus();
102 final RadiusServerEventRegistrar eventRegistrar = new RadiusServerEventRegistrar(eventBus);
[all...]
/forgerock/openam/openam-radius/openam-radius-server/src/test/java/org/forgerock/openam/radius/server/monitoring/
H A DRadiusServerEventRegistrarTest.java38 EventBus eventBus = new EventBus();
40 final RadiusServerEventRegistrator eventRegistrar = new RadiusServerEventRegistrar(eventBus);
53 EventBus eventBus = new EventBus();
54 final RadiusServerEventRegistrar eventRegistrar = new RadiusServerEventRegistrar(eventBus);
69 EventBus eventBus = new EventBus();
70 final RadiusServerEventRegistrar eventRegistrar = new RadiusServerEventRegistrar(eventBus);
85 EventBus eventBus = new EventBus();
86 final RadiusServerEventRegistrar eventRegistrar = new RadiusServerEventRegistrar(eventBus);
101 EventBus eventBus = new EventBus();
102 final RadiusServerEventRegistrar eventRegistrar = new RadiusServerEventRegistrar(eventBus);
[all...]
/forgerock/openam-v13/openam-radius/openam-radius-server/src/main/java/org/forgerock/openam/radius/server/
H A DRequestListenerFactory.java52 private final EventBus eventBus; field in class:RequestListenerFactory
63 * @param eventBus is used to publish or register for notifications of RADIUS server events.
68 @Named("RadiusEventBus") EventBus eventBus,
71 this.eventBus = eventBus;
92 return new RadiusRequestListener(serviceConfig, executorService, eventBus, accessRequestHandlerFactory);
67 RequestListenerFactory(ExecutorServiceFactory serviceFactory, @Named(�) EventBus eventBus, AccessRequestHandlerFactory accessRequestHandlerFactory) argument
H A DRadiusRequestHandler.java81 private final EventBus eventBus; field in class:RadiusRequestHandler
98 * @param eventBus used to notify interested parties of events occurring during the processing of radius requests.
104 final EventBus eventBus) {
110 this.eventBus = eventBus;
193 eventBus.post(new AuthRequestAcceptedEvent(request, response, requestContext));
196 eventBus.post(new AuthRequestChallengedEvent(request, response, requestContext));
199 eventBus.post(new AuthRequestRejectedEvent(request, response, requestContext));
100 RadiusRequestHandler(AccessRequestHandlerFactory accessRequestHandlerFactory, final RadiusRequestContext reqCtx, final ByteBuffer buffer, final ResultHandler<RadiusResponse> resultHandler, final ExceptionHandler<RadiusProcessingException> errorHandler, final EventBus eventBus) argument
H A DRadiusRequestListener.java92 private EventBus eventBus; field in class:RadiusRequestListener
105 * @param eventBus may used to notify interested parties when events occur during the processing of radius events.
112 final EventBus eventBus,
118 this.eventBus = eventBus;
253 eventBus.post(new PacketReceivedEvent());
287 eventBus);
293 eventBus.post(new PacketProcessedEvent());
110 RadiusRequestListener(final RadiusServiceConfig config, final ExecutorService executorService, final EventBus eventBus, final AccessRequestHandlerFactory accessRequestHandlerFactory) argument
/forgerock/openam/openam-radius/openam-radius-server/src/main/java/org/forgerock/openam/radius/server/
H A DRequestListenerFactory.java49 private final EventBus eventBus; field in class:RequestListenerFactory
60 * @param eventBus is used to publish or register for notifications of RADIUS server events.
65 @Named("RadiusEventBus") EventBus eventBus,
68 this.eventBus = eventBus;
89 return new RadiusRequestListener(serviceConfig, executorService, eventBus, accessRequestHandlerFactory);
64 RequestListenerFactory(AMExecutorServiceFactory serviceFactory, @Named(�) EventBus eventBus, AccessRequestHandlerFactory accessRequestHandlerFactory) argument
H A DRadiusRequestHandler.java70 private final EventBus eventBus; field in class:RadiusRequestHandler
84 * @param eventBus used to notify interested parties of events occurring during the processing of radius requests.
88 final EventBus eventBus) {
92 this.eventBus = eventBus;
145 eventBus.post(new PacketProcessedEvent());
173 eventBus.post(new AuthRequestAcceptedEvent(request, response, requestContext));
176 eventBus.post(new AuthRequestChallengedEvent(request, response, requestContext));
179 eventBus.post(new AuthRequestRejectedEvent(request, response, requestContext));
270 eventBus
86 RadiusRequestHandler(AccessRequestHandlerFactory accessRequestHandlerFactory, final RadiusRequestContext reqCtx, final ByteBuffer buffer, final EventBus eventBus) argument
[all...]
H A DRadiusRequestListener.java94 private EventBus eventBus; field in class:RadiusRequestListener
107 * @param eventBus may used to notify interested parties when events occur during the processing of radius events.
114 final EventBus eventBus,
120 this.eventBus = eventBus;
275 eventBus.post(new PacketReceivedEvent());
294 eventBus.post(new PacketDroppedSilentlyEvent());
300 eventBus.post(new PacketDroppedSilentlyEvent());
309 reqCtx, bfr, eventBus);
112 RadiusRequestListener(final RadiusServiceConfig config, final ExecutorService executorService, final EventBus eventBus, final AccessRequestHandlerFactory accessRequestHandlerFactory) argument
/forgerock/openam/openam-radius/openam-radius-server/src/test/java/org/forgerock/openam/radius/server/
H A DRadiusRequestHandlerTest.java77 EventBus eventBus = new EventBus();
81 final RadiusRequestHandler handler = new RadiusRequestHandler(accessRequestHandlerFactory, reqCtx, bfr, eventBus);
114 EventBus eventBus = new EventBus();
119 final RadiusRequestHandler handler = new RadiusRequestHandler(accessRequestHandlerFactory, reqCtx, bfr, eventBus);
151 EventBus eventBus = new EventBus();
156 final RadiusRequestHandler handler = new RadiusRequestHandler(accessRequestHandlerFactory, reqCtx, bfr, eventBus);
/forgerock/openam-v13/openam-radius/openam-radius-server/src/test/java/org/forgerock/openam/radius/server/
H A DRadiusRequestHandlerTest.java77 EventBus eventBus = new EventBus();
82 promise, eventBus);
118 EventBus eventBus = new EventBus();
124 promise, eventBus);
158 EventBus eventBus = new EventBus();
164 promise, eventBus);
/forgerock/openam-v13/openam-radius/openam-radius-server/src/main/java/org/forgerock/openam/radius/server/monitoring/
H A DRadiusServerEventRegistrar.java60 * @param eventBus - the event bus that this class will register as a subscriber with.
63 public RadiusServerEventRegistrar(@Named("RadiusEventBus") EventBus eventBus) { argument
65 LOG.message("RadiusServerEventRegistrar - Registering with EventBus hashCode; " + eventBus.hashCode());
66 eventBus.register(this);
92 * Once an object of this class has registered with the eventBus (passed into the constructor) the
128 * Once an object of this class has registered with the eventBus (passed into the constructor) the
165 * Once an object of this class has registered with the eventBus (passed into the constructor) the
207 * Once an object of this class has registered with the eventBus (passed into the constructor) the
241 * Once an object of this class has registered with the eventBus (passed into the constructor) the
/forgerock/openam/openam-radius/openam-radius-server/src/main/java/org/forgerock/openam/radius/server/monitoring/
H A DRadiusServerEventRegistrar.java60 * @param eventBus - the event bus that this class will register as a subscriber with.
63 public RadiusServerEventRegistrar(@Named("RadiusEventBus") EventBus eventBus) { argument
65 LOG.message("RadiusServerEventRegistrar - Registering with EventBus hashCode; " + eventBus.hashCode());
66 eventBus.register(this);
92 * Once an object of this class has registered with the eventBus (passed into the constructor) the
128 * Once an object of this class has registered with the eventBus (passed into the constructor) the
165 * Once an object of this class has registered with the eventBus (passed into the constructor) the
207 * Once an object of this class has registered with the eventBus (passed into the constructor) the
241 * Once an object of this class has registered with the eventBus (passed into the constructor) the
/forgerock/openam-v13/openam-radius/openam-radius-server/src/main/java/org/forgerock/openam/radius/server/audit/
H A DRadiusAuditLoggerEventBus.java77 * @param eventBus - and event bus that the constructed object will register with in order to be notified of RADIUS
84 public RadiusAuditLoggerEventBus(@Named("RadiusEventBus") EventBus eventBus, AuditEventFactory eventFactory, argument
87 LOG.message("Registering RadiusAuditLogger with the eventBus, hashCode; {}", eventBus.hashCode());
88 eventBus.register(this);
/forgerock/openam/openam-radius/openam-radius-server/src/main/java/org/forgerock/openam/radius/server/audit/
H A DRadiusAuditLoggerEventBus.java76 * @param eventBus - and event bus that the constructed object will register with in order to be notified of RADIUS
83 public RadiusAuditLoggerEventBus(@Named("RadiusEventBus") EventBus eventBus, AuditEventFactory eventFactory, argument
86 LOG.message("Registering RadiusAuditLogger with the eventBus, hashCode; {}", eventBus.hashCode());
87 eventBus.register(this);
/forgerock/openam-v13/openam-radius/openam-radius-server/src/main/java/org/forgerock/openam/radius/server/spi/handlers/
H A DOpenAMAuthHandler.java166 private EventBus eventBus; field in class:OpenAMAuthHandler
175 * @param eventBus - the Radius event bus that will be used to notify interested parties of
180 @Named("RadiusEventBus") EventBus eventBus) {
183 this.eventBus = eventBus;
253 eventBus.post(new AuthRequestReceivedEvent(request, response, context));
265 eventBus.post(new AuthRequestReceivedEvent(request, response, context));
179 OpenAMAuthHandler(OpenAMAuthFactory amAuthFactory, ContextHolderCache contextHolderCache, @Named(�) EventBus eventBus) argument
/forgerock/openam/openam-radius/openam-radius-server/src/main/java/org/forgerock/openam/radius/server/spi/handlers/
H A DOpenAMAuthHandler.java169 private EventBus eventBus; field in class:OpenAMAuthHandler
178 * @param eventBus - the Radius event bus that will be used to notify interested parties of
183 @Named("RadiusEventBus") EventBus eventBus) {
186 this.eventBus = eventBus;
256 eventBus.post(new AuthRequestReceivedEvent(request, response, context));
275 eventBus.post(new AuthRequestReceivedEvent(request, response, context));
182 OpenAMAuthHandler(OpenAMAuthFactory amAuthFactory, ContextHolderCache contextHolderCache, @Named(�) EventBus eventBus) argument
/forgerock/openam-v13/openam-radius/openam-radius-server/src/test/java/org/forgerock/openam/radius/server/spi/handlers/
H A DOpenAMAuthHandlerTest.java101 EventBus eventBus = new EventBus();
103 final OpenAMAuthHandler handler = new OpenAMAuthHandler(ctxHolderFactory, ctxHolderCache, eventBus);
/forgerock/openam/openam-radius/openam-radius-server/src/test/java/org/forgerock/openam/radius/server/spi/handlers/
H A DOpenAMAuthHandlerTest.java101 EventBus eventBus = new EventBus();
103 final OpenAMAuthHandler handler = new OpenAMAuthHandler(ctxHolderFactory, ctxHolderCache, eventBus);

Completed in 110 milliseconds