code: @Override
      protected boolean putToQueueStorage(Connection conn, IQueueMessage<Long, byte[]> _msg) {
          if (!(_msg instanceof UniversalIdIntQueueMessage)) {
              throw new IllegalArgumentException("This method requires an argument of type ["
                      + UniversalIdIntQueueMessage.class.getName() + "]!");
          }
          UniversalIdIntQueueMessage msg = (UniversalIdIntQueueMessage) _msg;
          Long qid = msg.getId();
          if (qid == null || qid.longValue() == 0) {
              int numRows = getJdbcHelper().execute(conn, SQL_PUT_NEW_TO_QUEUE, getQueueName(),
                      msg.getTimestamp(), msg.getQueueTimestamp(), msg.getNumRequeues(),
                      msg.getContent());
              return numRows > 0;
          } else {
              int numRows = getJdbcHelper().execute(conn, SQL_REPUT_TO_QUEUE, getQueueName(), qid,
                      msg.getTimestamp(), msg.getQueueTimestamp(), msg.getNumRequeues(),
                      msg.getContent());
              return numRows > 0;
          }
      }
docs: {@inheritDoc}