code: @Override
      protected Collection<UniversalIdIntQueueMessage> getOrphanFromEphemeralStorage(Connection conn,
              long thresholdTimestampMs) {
          Date threshold = new Date(System.currentTimeMillis() - thresholdTimestampMs);
          Collection<UniversalIdIntQueueMessage> result = new ArrayList<>();
          try (Stream<Map<String, Object>> dbRows = getJdbcHelper().executeSelectAsStream(conn,
                  SQL_GET_ORPHAN_MSGS, threshold)) {
              dbRows.forEach(row -> result.add(UniversalIdIntQueueMessage.newInstance(row)));
          }
          return result;
      }
docs: {@inheritDoc}