TLiferayOutputDefinition extends LiferayDefinition { @Override public RuntimeInfo getRuntimeInfo( ExecutionEngine executionEngine, ComponentProperties componentProperties, ConnectorTopology connectorTopology) { assertEngineCompatibility(executionEngine); return getCommonRuntimeInfo(SINK_CLASS_NAME); } TLiferayOutputDefinition(); @Override Class<? extends ComponentProperties>[] getNestedCompatibleComponentPropertiesClass(); @Override Class<? extends ComponentProperties> getPropertyClass(); @Override Property[] getReturnProperties(); @Override RuntimeInfo getRuntimeInfo(
		ExecutionEngine executionEngine,
		ComponentProperties componentProperties,
		ConnectorTopology connectorTopology); @Override Set<ConnectorTopology> getSupportedConnectorTopologies(); @Override boolean isConditionalInputs(); static final String COMPONENT_NAME; }
@Test public void testGetRuntimeInfoForIncomingTopology() { RuntimeInfo runtimeInfo = _tLiferayOutputDefinition.getRuntimeInfo( ExecutionEngine.DI, null, ConnectorTopology.INCOMING); assertThat( runtimeInfo.getRuntimeClassName(), equalTo("com.liferay.talend.runtime.LiferaySink")); }
@Test public void testGetRuntimeInfoWrongEngine() { expectedException.expect(TalendRuntimeException.class); expectedException.expectMessage( "WRONG_EXECUTION_ENGINE:{component=tLiferayOutput, " + "requested=DI_SPARK_STREAMING, available=[DI]}"); _tLiferayOutputDefinition.getRuntimeInfo( ExecutionEngine.DI_SPARK_STREAMING, null, ConnectorTopology.INCOMING); }
@Ignore @Test public void testGetRuntimeInfoWrongTopology() { expectedException.expect(TalendRuntimeException.class); expectedException.expectMessage( "WRONG_CONNECTOR:{component=tLiferayOutput}"); _tLiferayOutputDefinition.getRuntimeInfo( ExecutionEngine.DI, null, ConnectorTopology.OUTGOING); }