code: @Override
      protected void initQueue(T queue, QueueSpec spec) throws Exception {
          queue.setMongoClient(defaultMongoClient).setConnectionString(defaultConnectionString)
                  .setCollectionName(defaultCollectionName);
  
          String connectionString = spec.getField(SPEC_FIELD_CONNECTION_STRING);
          if (!StringUtils.isBlank(connectionString)) {
              queue.setConnectionString(connectionString);
          }
  
          String collectionName = spec.getField(SPEC_FIELD_COLLECTION_NAME);
          if (!StringUtils.isBlank(collectionName)) {
              queue.setCollectionName(collectionName);
          }
  
          super.initQueue(queue, spec);
      }
docs: {@inheritDoc}
  
  @throws Exception