code: public void raActive() {
          activities = new ConcurrentHashMap<HttpClientNIORequestActivityHandle, HttpClientNIORequestActivity>();
          try {
              if (httpClientFactory != null) {
                  httpAsyncClient = httpClientFactory.newHttpAsyncClient();
              } else {
                  httpAsyncClient = buildHttpAsyncClient();
              }
  
              // Can't be sure whether factory produced closeable client or some specialization of AbstractHttpAsyncClient
              if (httpAsyncClient instanceof CloseableHttpAsyncClient) {
                  ((CloseableHttpAsyncClient) httpAsyncClient).start();
              }
  
              isActive = true;
              if (tracer.isInfoEnabled()) {
                  tracer.info(String.format("HttpClientNIOResourceAdaptor=%s entity activated.",
                          this.resourceAdaptorContext.getEntityName()));
              }
          } catch (Exception e) {
              throw new RuntimeException(e);
          }
      }
docs: /*
  (non-Javadoc)
  
  @see javax.slee.resource.ResourceAdaptor#raActive()