docs: @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);
          }
      }