code: @Override
      protected boolean removeFromEphemeralStorage(Connection conn,
              IQueueMessage<String, byte[]> _msg) {
          if (!(_msg instanceof UniversalIdStrQueueMessage)) {
              throw new IllegalArgumentException("This method requires an argument of type ["
                      + UniversalIdStrQueueMessage.class.getName() + "]!");
          }
          UniversalIdStrQueueMessage msg = (UniversalIdStrQueueMessage) _msg;
          int numRows = getJdbcHelper().execute(conn, SQL_REMOVE_FROM_EPHEMERAL, getQueueName(),
                  msg.getId());
          return numRows > 0;
      }
docs: {@inheritDoc}