code: protected void drain() {
          Message msg;
          while((msg=queue.poll()) != null)
              addAndSendIfSizeExceeded(msg);
          _sendBundledMessages();
      }
docs: Takes all messages from the queue, adds them to the hashmap and then sends all bundled messages