Is there a way to know how many requests are currently being served?

[Emad Jamal]

Hi.. I am asking this because I need to shutdown some pubsub queues only after all requests being served are completed (Some request might consume or produce messages). Right now I implemented a filter to count those requests and here is its code:

public class CurrentRequestCountFilter implements ContainerRequestFilter, ContainerResponseFilter {

private final AtomicInteger currentRequestCount;

@Inject
public CurrentRequestCountFilter(AtomicInteger currentRequestCount) {
this.currentRequestCount = currentRequestCount;
}

public void filter(ContainerRequestContext containerRequestContext) {
int currentCount = currentRequestCount.incrementAndGet();
}

@Override
public void filter(
ContainerRequestContext containerRequestContext,
ContainerResponseContext containerResponseContext) {
int currentCount = currentRequestCount.decrementAndGet();
}
}