// try {
// if (lock.tryAcquire(0, TimeUnit.SECONDS)) {
while (!queue.isEmpty() && payLoadSize < MAXIMUM_PAYLOAD_SIZE
&& !isWindowExceeded()) {
p.addMessage(queue.poll());
payLoadSize++;
try {
if (queue.isEmpty())
Thread.sleep(currentTimeMillis() - endWindow);