public boolean sendToDeadLetterQueue()

in DiscardingDLQBroker.java [47:86]
32 lines of code
17 McCabe index (conditional complexity)

    public boolean sendToDeadLetterQueue(ConnectionContext ctx, MessageReference msgRef, Subscription subscription, Throwable poisonCause) {
        if (log.isTraceEnabled()) {
            log.trace("Discarding DLQ BrokerFilter[pass through] - skipping message:" + (msgRef != null ? msgRef.getMessage() : null));
        }
        boolean dropped = true;
        Message msg = null;
        ActiveMQDestination dest = null;
        String destName = null;
        msg = msgRef.getMessage();
        dest = msg.getDestination();
        destName = dest.getPhysicalName();

        if (dest == null || destName == null) {
            // do nothing, no need to forward it
            skipMessage("NULL DESTINATION", msgRef);
        } else if (dropAll) {
            // do nothing
            skipMessage("dropAll", msgRef);
        } else if (dropTemporaryTopics && dest.isTemporary() && dest.isTopic()) {
            // do nothing
            skipMessage("dropTemporaryTopics", msgRef);
        } else if (dropTemporaryQueues && dest.isTemporary() && dest.isQueue()) {
            // do nothing
            skipMessage("dropTemporaryQueues", msgRef);
        } else if (destFilter != null && matches(destName)) {
            // do nothing
            skipMessage("dropOnly", msgRef);
        } else {
            dropped = false;
            return next.sendToDeadLetterQueue(ctx, msgRef, subscription, poisonCause);
        }

        if (dropped && getReportInterval() > 0) {
            if ((++dropCount) % getReportInterval() == 0) {
                log.info("Total of " + dropCount + " messages were discarded, since their destination was the dead letter queue");
            }
        }

        return false;
    }