RemoteProcessGroupSchema extends BaseSchemaWithIdAndName { @Override public Map<String, Object> toMap() { Map<String, Object> result = super.toMap(); result.put(URL_KEY, urls); result.put(COMMENT_KEY, comment); result.put(TIMEOUT_KEY, timeout); result.put(YIELD_PERIOD_KEY, yieldPeriod); result.put(TRANSPORT_PROTOCOL_KEY, transportProtocol); result.put(PROXY_HOST_KEY, proxyHost); result.put(PROXY_PORT_KEY, proxyPort == null ? "" : proxyPort); result.put(PROXY_USER_KEY, proxyUser); result.put(PROXY_PASSWORD_KEY, proxyPassword); result.put(LOCAL_NETWORK_INTERFACE_KEY, localNetworkInterface); putListIfNotNull(result, INPUT_PORTS_KEY, inputPorts); putListIfNotNull(result, OUTPUT_PORTS_KEY, outputPorts); return result; } RemoteProcessGroupSchema(Map map); @Override Map<String, Object> toMap(); String getComment(); String getUrls(); String getTimeout(); String getYieldPeriod(); List<RemotePortSchema> getInputPorts(); List<RemotePortSchema> getOutputPorts(); String getTransportProtocol(); void setProxyHost(String proxyHost); void setProxyPort(Integer proxyPort); void setProxyUser(String proxyUser); void setProxyPassword(String proxyPassword); void setTransportProtocol(String transportProtocol); String getProxyHost(); Integer getProxyPort(); String getProxyUser(); String getProxyPassword(); void setLocalNetworkInterface(String LocalNetworkInterface); String getLocalNetworkInterface(); static final String URL_KEY; static final String TIMEOUT_KEY; static final String TRANSPORT_PROTOCOL_KEY; static final String S2S_PROXY_REQUIRES_HTTP; static final String PROXY_HOST_KEY; static final String PROXY_PORT_KEY; static final String PROXY_USER_KEY; static final String PROXY_PASSWORD_KEY; static final String LOCAL_NETWORK_INTERFACE_KEY; static final String EXPECTED_PROXY_HOST_IF_PROXY_PORT; static final String EXPECTED_PROXY_HOST_IF_PROXY_USER; static final String EXPECTED_PROXY_USER_IF_PROXY_PASSWORD; static final String EXPECTED_PROXY_PASSWORD_IF_PROXY_USER; static final String DEFAULT_COMMENT; static final String DEFAULT_TIMEOUT; static final String DEFAULT_YIELD_PERIOD; static final String DEFAULT_TRANSPORT_PROTOCOL; static final String DEFAULT_PROXY_HOST; static final Integer DEFAULT_PROXY_PORT; static final String DEFAULT_PROXY_USER; static final String DEFAULT_PROXY_PASSWORD; static final String DEFAULT_NETWORK_INTERFACE; }
@Test public void testInputPortsRootGroup() { Map<String, Object> map = new HashMap<>(); map.put(CommonPropertyKeys.INPUT_PORTS_KEY, Arrays.asList(createPortSchema("f94d2469-39f8-4f07-a0d8-acd9396f639e", "testName", ConfigSchema.TOP_LEVEL_NAME).toMap())); map.put(RemoteProcessGroupSchema.URL_KEY, "http: map.put(CommonPropertyKeys.ID_KEY, "a58d2fab-7efe-4cb7-8224-12a60bd8003d"); validateIssuesNumMatches(0, new RemoteProcessGroupSchema(map)); }