import org.glassfish.jersey.server.monitoring.RequestEventListener; //导入依赖的package包/类
/** The req listener. */

  /*
   * (non-Javadoc)
   *
   * @see
   * org.glassfish.jersey.server.monitoring.ApplicationEventListener#onRequest(org.glassfish.jersey.server.monitoring
   * .RequestEvent)
   */
  @Override
  public RequestEventListener onRequest(RequestEvent requestEvent) {
    // Request start events are sent to application listener and not request listener
    if (RequestEvent.Type.START == requestEvent.getType()) {
      MetricsService metricsSvc = LensServices.get().getService(MetricsService.NAME);
      if (metricsSvc != null) {
        metricsSvc.incrCounter(LensRequestListener.class, LensRequestListener.HTTP_REQUESTS_STARTED);
      }
    }
    return new LensRequestListener();
  }
 

import org.glassfish.jersey.server.monitoring.RequestEventListener; //导入依赖的package包/类
@Override
public RequestEventListener onRequest(RequestEvent event) {
  if (Timer.enabled()) {
    return new TimingRequestEventListener(nextReqId ++);
  }
  return null;
}
 

import org.glassfish.jersey.server.monitoring.RequestEventListener; //导入依赖的package包/类
private void execute() {
    this.listener.onEvent(this.appEvent);
    final RequestEventListener requestListener = this.listener
            .onRequest(this.requestStartEvent);
    requestListener.onEvent(this.requestMethodStartEvent);
    requestListener.onEvent(this.responseFiltersStartEvent);
}
 

import org.glassfish.jersey.server.monitoring.RequestEventListener; //导入依赖的package包/类
private void executeWithException() {
    this.listener.onEvent(this.appEvent);
    final RequestEventListener requestListener = this.listener
            .onRequest(this.requestStartEvent);
    requestListener.onEvent(this.requestMethodStartEvent);
    requestListener.onEvent(this.requestMethodExceptionEvent);
}
 

import org.glassfish.jersey.server.monitoring.RequestEventListener; //导入依赖的package包/类
@Test
public void commitsAndClosesOnSuccessfulFinish() throws SQLException, NoSuchMethodException {
    prepareAppEvent("methodWithDefaultAnnotation");
    listener.onEvent(appEvent);
    RequestEventListener requestListener = listener.onRequest(requestStartEvent);

    when(requestFinishEvent.isSuccess()).thenReturn(true);

    requestListener.onEvent(requestFinishEvent);

    verify(connection).commit();
    verify(connection).close();
    verify(connection, never()).rollback();
}
 

import org.glassfish.jersey.server.monitoring.RequestEventListener; //导入依赖的package包/类
@Test
public void doesNotCommitOrCloseOnUnsuccessfulFinish() throws SQLException, NoSuchMethodException {
    prepareAppEvent("methodWithDefaultAnnotation");
    listener.onEvent(appEvent);
    RequestEventListener requestListener = listener.onRequest(requestStartEvent);

    when(requestFinishEvent.isSuccess()).thenReturn(false);

    requestListener.onEvent(requestFinishEvent);

    verify(connection, never()).commit();
    verify(connection, never()).close();
}
 

import org.glassfish.jersey.server.monitoring.RequestEventListener; //导入依赖的package包/类
@Test
public void rollbackAndCloseOnException() throws SQLException, NoSuchMethodException {
    prepareAppEvent("methodWithDefaultAnnotation");
    listener.onEvent(appEvent);
    RequestEventListener requestListener = listener.onRequest(requestStartEvent);

    requestListener.onEvent(requestMethodExceptionEvent);

    verify(connection).rollback();
    verify(connection).close();
    verify(connection, never()).commit();

}
 

import org.glassfish.jersey.server.monitoring.RequestEventListener; //导入依赖的package包/类
private void execute() {
    listener.onEvent(appEvent);
    RequestEventListener requestListener = listener.onRequest(requestStartEvent);
    requestListener.onEvent(requestMethodStartEvent);
    requestListener.onEvent(responseFiltersStartEvent);
    requestListener.onEvent(responseFinishedEvent);
}
 

import org.glassfish.jersey.server.monitoring.RequestEventListener; //导入依赖的package包/类
private void executeWithException() {
    listener.onEvent(appEvent);
    RequestEventListener requestListener = listener.onRequest(requestStartEvent);
    requestListener.onEvent(requestMethodStartEvent);
    requestListener.onEvent(requestMethodExceptionEvent);
    requestListener.onEvent(responseFiltersStartEvent);
    requestListener.onEvent(responseFinishedEvent);
}
 

import org.glassfish.jersey.server.monitoring.RequestEventListener; //导入依赖的package包/类
@Test
public void shouldReturnOpenSessionInViewFilterOnRequestEvent() {
	DatabaseConfiguration configuration = mock(DatabaseConfiguration.class);
	JerseyApplicationEventListener listener = new JerseyApplicationEventListener(configuration);
	RequestEvent requestEvent = mock(RequestEvent.class);
	RequestEventListener eventListener = listener.onRequest(requestEvent);
	assertTrue(eventListener instanceof OpenSessionInViewFilter);
	assertEquals(((OpenSessionInViewFilter)eventListener).getConfiguration(), configuration);
}
 

import org.glassfish.jersey.server.monitoring.RequestEventListener; //导入依赖的package包/类
@Override
public RequestEventListener onRequest(RequestEvent requestEvent) {
    return new MetricsRequestEventListener(meterRegistry, tagsProvider, metricName, autoTimeRequests, annotationFinder);
}
 

import org.glassfish.jersey.server.monitoring.RequestEventListener; //导入依赖的package包/类
@Override
public RequestEventListener onRequest(RequestEvent requestEvent) {
    return null;
}
 

import org.glassfish.jersey.server.monitoring.RequestEventListener; //导入依赖的package包/类
@Override
public RequestEventListener onRequest(RequestEvent requestEvent) {
    return new APIxRequestEventListener();
}
 

import org.glassfish.jersey.server.monitoring.RequestEventListener; //导入依赖的package包/类
@Override
public synchronized RequestEventListener onRequest(RequestEvent requestEvent) {
  return null;
}
 

import org.glassfish.jersey.server.monitoring.RequestEventListener; //导入依赖的package包/类
@Override
public RequestEventListener onRequest(RequestEvent requestEvent) {
	return new ExceptionRequestEventListener();
}
 

import org.glassfish.jersey.server.monitoring.RequestEventListener; //导入依赖的package包/类
@Override
public RequestEventListener onRequest(final RequestEvent event) {
    return new UnitOfWorkEventListener(this.methodMap, this.bundles);
}
 

import org.glassfish.jersey.server.monitoring.RequestEventListener; //导入依赖的package包/类
@Override
public RequestEventListener onRequest(RequestEvent requestEvent) {
    return null; // no request processing
}
 

import org.glassfish.jersey.server.monitoring.RequestEventListener; //导入依赖的package包/类
@Override
public RequestEventListener onRequest(RequestEvent requestEvent) {
    return new UnitOfWorkEventListener(methodMap, transactionManager, runWithTxnIfNotConfigured);
}
 

import org.glassfish.jersey.server.monitoring.RequestEventListener; //导入依赖的package包/类
@Override
public RequestEventListener onRequest(RequestEvent requestEvent) {
    // Do nothing per request
    return null;
}
 

import org.glassfish.jersey.server.monitoring.RequestEventListener; //导入依赖的package包/类
@Override
public RequestEventListener onRequest(RequestEvent requestEvent) {
	requestCounter++;
	LOG.info("Request " + requestCounter + " started.");
	return new LoggingRequestEventListener(requestCounter);
}