public void processSync(T message) {
        // If this batcher has been shutdown, do not accept any more messages
        if (isShutDown) {
            return;
        }

        try {
            queueSizeTracer.record(queue.size());
        } catch (Throwable ignored) {
        }

        try {
            Stopwatch s = batchSyncPutTracer.start();
            queue.put(message);
            s.stop();
        } catch (InterruptedException e) {
            return;
        }
        numberAdded.incrementAndGet();
    }
public void processSync ( T message ) { if ( isShutDown ) { return ; } try { queueSizeTracer . record ( queue . size ( ) ) ; } catch ( Throwable ignored ) { } try { Stopwatch s = batchSyncPutTracer . start ( ) ; queue . put ( message ) ; s . stop ( ) ; } catch ( InterruptedException e ) { return ; } numberAdded . incrementAndGet ( ) ; }
Processes the message sent to the batcher. This method tries to write to
the queue. If the queue is full, the send blocks and waits for the
available space.

@param message
- The message to be processed