code: @Override
      protected boolean putToQueueStorage(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;
          String qid = msg.getId();
          if (StringUtils.isEmpty(qid)) {
              qid = QueueUtils.IDGEN.generateId128Hex();
          }
          int numRows = getJdbcHelper().execute(conn, SQL_REPUT_TO_QUEUE, getQueueName(), qid,
                  msg.getTimestamp(), msg.getQueueTimestamp(), msg.getNumRequeues(),
                  msg.getContent());
          return numRows > 0;
      }
docs: {@inheritDoc}