docs: @GuardedBy("maxNumberInvariant")
     private void addQueuesForAddresses(Collection<Address> addresses) {
        for (Address address : addresses) {
           if (interestedInAddress(address)) {
              address2key.put(address, new ArrayBlockingQueue<>(bufferSize));
           } else {
              log.tracef("Skipping address: %s", address);
           }
        }
     }