@Override
    public void handleReply(Reply reply) {
        if (destroyed.get()) {
            reply.discard();
            return;
        }
        if (doAccounting()) {
            synchronized (this) {
                --pendingCount;
                pendingSize -= (Integer)reply.getContext();
            }
        }
        deliverReply(reply, reply.popHandler());
    }
<p>This method handles choking input data so that message bus does not
blindly accept everything. This prevents an application running
out-of-memory in case it fail to choke input data itself. If this method
returns false, it means that it should be rejected.</p>

@param msg The message to count.
@return True if the message was accepted.
messagebus/src/main/java/com/yahoo/messagebus/MessageBus.java