Add a queue length metric (gauge) which is obtained by polling the ApacheHttpSink instance periodically (e.g. when the PeriodicUnitOfWork executes). This will require injecting a reference or reference supplies for the sink back into the event handler.