code: @Override
      public long getPendingVideoMessages(Number streamId) {
          AtomicInteger pendingCount = pendingVideos.get(streamId.doubleValue());
          if (log.isTraceEnabled()) {
              log.trace("Stream id: {} pendingCount: {} total pending videos: {}", streamId, pendingCount, pendingVideos.size());
          }
          return pendingCount != null ? pendingCount.intValue() : 0;
      }
docs: {@inheritDoc}