@Test public void testMaxWorkQueueSize() { assertEquals(testMaxWorkQueueSize, createSchema(0).convert().getMaxWorkQueueSize()); }
@Override public ConnectionSchema convert() { Map<String, Object> map = new HashMap<>(); map.put(NAME_KEY, name); if (StringUtil.isNullOrEmpty(sourceRelationshipName)) { map.put(SOURCE_RELATIONSHIP_NAMES_KEY, new ArrayList<>()); } else { map.put(SOURCE_RELATIONSHIP_NAMES_KEY, new ArrayList<>(Arrays.asList(sourceRelationshipName))); } map.put(MAX_WORK_QUEUE_SIZE_KEY, maxWorkQueueSize); map.put(MAX_WORK_QUEUE_DATA_SIZE_KEY, maxWorkQueueDataSize); map.put(FLOWFILE_EXPIRATION__KEY, flowfileExpiration); map.put(QUEUE_PRIORITIZER_CLASS_KEY, queuePrioritizerClass); return new ConnectionSchema(map); }
ConnectionSchemaV1 extends BaseSchema implements ConvertableSchema<ConnectionSchema> { @Override public ConnectionSchema convert() { Map<String, Object> map = new HashMap<>(); map.put(NAME_KEY, name); if (StringUtil.isNullOrEmpty(sourceRelationshipName)) { map.put(SOURCE_RELATIONSHIP_NAMES_KEY, new ArrayList<>()); } else { map.put(SOURCE_RELATIONSHIP_NAMES_KEY, new ArrayList<>(Arrays.asList(sourceRelationshipName))); } map.put(MAX_WORK_QUEUE_SIZE_KEY, maxWorkQueueSize); map.put(MAX_WORK_QUEUE_DATA_SIZE_KEY, maxWorkQueueDataSize); map.put(FLOWFILE_EXPIRATION__KEY, flowfileExpiration); map.put(QUEUE_PRIORITIZER_CLASS_KEY, queuePrioritizerClass); return new ConnectionSchema(map); } }
ConnectionSchemaV1 extends BaseSchema implements ConvertableSchema<ConnectionSchema> { @Override public ConnectionSchema convert() { Map<String, Object> map = new HashMap<>(); map.put(NAME_KEY, name); if (StringUtil.isNullOrEmpty(sourceRelationshipName)) { map.put(SOURCE_RELATIONSHIP_NAMES_KEY, new ArrayList<>()); } else { map.put(SOURCE_RELATIONSHIP_NAMES_KEY, new ArrayList<>(Arrays.asList(sourceRelationshipName))); } map.put(MAX_WORK_QUEUE_SIZE_KEY, maxWorkQueueSize); map.put(MAX_WORK_QUEUE_DATA_SIZE_KEY, maxWorkQueueDataSize); map.put(FLOWFILE_EXPIRATION__KEY, flowfileExpiration); map.put(QUEUE_PRIORITIZER_CLASS_KEY, queuePrioritizerClass); return new ConnectionSchema(map); } ConnectionSchemaV1(Map map); }
ConnectionSchemaV1 extends BaseSchema implements ConvertableSchema<ConnectionSchema> { @Override public ConnectionSchema convert() { Map<String, Object> map = new HashMap<>(); map.put(NAME_KEY, name); if (StringUtil.isNullOrEmpty(sourceRelationshipName)) { map.put(SOURCE_RELATIONSHIP_NAMES_KEY, new ArrayList<>()); } else { map.put(SOURCE_RELATIONSHIP_NAMES_KEY, new ArrayList<>(Arrays.asList(sourceRelationshipName))); } map.put(MAX_WORK_QUEUE_SIZE_KEY, maxWorkQueueSize); map.put(MAX_WORK_QUEUE_DATA_SIZE_KEY, maxWorkQueueDataSize); map.put(FLOWFILE_EXPIRATION__KEY, flowfileExpiration); map.put(QUEUE_PRIORITIZER_CLASS_KEY, queuePrioritizerClass); return new ConnectionSchema(map); } ConnectionSchemaV1(Map map); @Override ConnectionSchema convert(); String getSourceName(); String getDestinationName(); String getName(); @Override int getVersion(); }
ConnectionSchemaV1 extends BaseSchema implements ConvertableSchema<ConnectionSchema> { @Override public ConnectionSchema convert() { Map<String, Object> map = new HashMap<>(); map.put(NAME_KEY, name); if (StringUtil.isNullOrEmpty(sourceRelationshipName)) { map.put(SOURCE_RELATIONSHIP_NAMES_KEY, new ArrayList<>()); } else { map.put(SOURCE_RELATIONSHIP_NAMES_KEY, new ArrayList<>(Arrays.asList(sourceRelationshipName))); } map.put(MAX_WORK_QUEUE_SIZE_KEY, maxWorkQueueSize); map.put(MAX_WORK_QUEUE_DATA_SIZE_KEY, maxWorkQueueDataSize); map.put(FLOWFILE_EXPIRATION__KEY, flowfileExpiration); map.put(QUEUE_PRIORITIZER_CLASS_KEY, queuePrioritizerClass); return new ConnectionSchema(map); } ConnectionSchemaV1(Map map); @Override ConnectionSchema convert(); String getSourceName(); String getDestinationName(); String getName(); @Override int getVersion(); static final String SOURCE_RELATIONSHIP_NAME_KEY; static final String DESTINATION_NAME_KEY; static final String SOURCE_NAME_KEY; }