code: @Override
      public UniversalKafkaQueue init() throws Exception {
          super.init();
  
          if (getMessageFactory() == null) {
              setMessageFactory(UniversalIdIntQueueMessageFactory.INSTANCE);
          }
  
          return this;
      }
docs: {@inheritDoc}
  
  @since 0.7.0