@Override
    public Collection<IQueueMessage<ID, DATA>> getOrphanMessages(long thresholdTimestampMs) {
        if (isEphemeralDisabled()) {
            return null;
        }
        try (Connection conn = jdbcHelper.getConnection()) {
            return Collections.unmodifiableCollection(
                    _getOrphanMessagesWithRetries(thresholdTimestampMs, conn, 0, this.maxRetries));
        } catch (Exception e) {
            final String logMsg = "(getOrphanMessages) Exception [" + e.getClass().getName() + "]: "
                    + e.getMessage();
            LOGGER.error(logMsg, e);
            throw e instanceof QueueException ? (QueueException) e : new QueueException(e);
        }
    }
@ Override public Collection < IQueueMessage < ID , DATA > > getOrphanMessages ( long thresholdTimestampMs ) { if ( isEphemeralDisabled ( ) ) { return null ; } try ( Connection conn = jdbcHelper . getConnection ( ) ) { return Collections . unmodifiableCollection ( _getOrphanMessagesWithRetries ( thresholdTimestampMs , conn , 0 , this . maxRetries ) ) ; } catch ( Exception e ) { final String logMsg = "(getOrphanMessages) Exception [" + e . getClass ( ) . getName ( ) + "]: " + e . getMessage ( ) ; LOGGER . error ( logMsg , e ) ; throw e instanceof QueueException ? ( QueueException ) e : new QueueException ( e ) ; } }
{@inheritDoc}