@Test public void testCheckDefaults() { List<CheckResultInterface> remarks = new ArrayList<>(); meta.check( remarks, null, null, null, null, null, null, new Variables(), null, null ); assertEquals( 0, remarks.size() ); }
@Override public void check( List<CheckResultInterface> remarks, TransMeta transMeta, StepMeta stepMeta, RowMetaInterface prev, String[] input, String[] output, RowMetaInterface info, VariableSpace space, Repository repository, IMetaStore metaStore ) { super.check( remarks, transMeta, stepMeta, prev, input, output, info, space, repository, metaStore ); StepOption.checkInteger( remarks, stepMeta, space, getString( PKG, "MQTTDialog.Options.KEEP_ALIVE_INTERVAL" ), keepAliveInterval ); StepOption .checkInteger( remarks, stepMeta, space, getString( PKG, "MQTTDialog.Options.MAX_INFLIGHT" ), maxInflight ); StepOption.checkInteger( remarks, stepMeta, space, getString( PKG, "MQTTDialog.Options.CONNECTION_TIMEOUT" ), connectionTimeout ); StepOption .checkBoolean( remarks, stepMeta, space, getString( PKG, "MQTTDialog.Options.CLEAN_SESSION" ), cleanSession ); checkVersion( remarks, stepMeta, space, mqttVersion ); StepOption.checkBoolean( remarks, stepMeta, space, getString( PKG, "MQTTDialog.Options.AUTOMATIC_RECONNECT" ), automaticReconnect ); }
MQTTConsumerMeta extends BaseStreamStepMeta implements StepMetaInterface { @Override public void check( List<CheckResultInterface> remarks, TransMeta transMeta, StepMeta stepMeta, RowMetaInterface prev, String[] input, String[] output, RowMetaInterface info, VariableSpace space, Repository repository, IMetaStore metaStore ) { super.check( remarks, transMeta, stepMeta, prev, input, output, info, space, repository, metaStore ); StepOption.checkInteger( remarks, stepMeta, space, getString( PKG, "MQTTDialog.Options.KEEP_ALIVE_INTERVAL" ), keepAliveInterval ); StepOption .checkInteger( remarks, stepMeta, space, getString( PKG, "MQTTDialog.Options.MAX_INFLIGHT" ), maxInflight ); StepOption.checkInteger( remarks, stepMeta, space, getString( PKG, "MQTTDialog.Options.CONNECTION_TIMEOUT" ), connectionTimeout ); StepOption .checkBoolean( remarks, stepMeta, space, getString( PKG, "MQTTDialog.Options.CLEAN_SESSION" ), cleanSession ); checkVersion( remarks, stepMeta, space, mqttVersion ); StepOption.checkBoolean( remarks, stepMeta, space, getString( PKG, "MQTTDialog.Options.AUTOMATIC_RECONNECT" ), automaticReconnect ); } }
MQTTConsumerMeta extends BaseStreamStepMeta implements StepMetaInterface { @Override public void check( List<CheckResultInterface> remarks, TransMeta transMeta, StepMeta stepMeta, RowMetaInterface prev, String[] input, String[] output, RowMetaInterface info, VariableSpace space, Repository repository, IMetaStore metaStore ) { super.check( remarks, transMeta, stepMeta, prev, input, output, info, space, repository, metaStore ); StepOption.checkInteger( remarks, stepMeta, space, getString( PKG, "MQTTDialog.Options.KEEP_ALIVE_INTERVAL" ), keepAliveInterval ); StepOption .checkInteger( remarks, stepMeta, space, getString( PKG, "MQTTDialog.Options.MAX_INFLIGHT" ), maxInflight ); StepOption.checkInteger( remarks, stepMeta, space, getString( PKG, "MQTTDialog.Options.CONNECTION_TIMEOUT" ), connectionTimeout ); StepOption .checkBoolean( remarks, stepMeta, space, getString( PKG, "MQTTDialog.Options.CLEAN_SESSION" ), cleanSession ); checkVersion( remarks, stepMeta, space, mqttVersion ); StepOption.checkBoolean( remarks, stepMeta, space, getString( PKG, "MQTTDialog.Options.AUTOMATIC_RECONNECT" ), automaticReconnect ); } MQTTConsumerMeta(); }
MQTTConsumerMeta extends BaseStreamStepMeta implements StepMetaInterface { @Override public void check( List<CheckResultInterface> remarks, TransMeta transMeta, StepMeta stepMeta, RowMetaInterface prev, String[] input, String[] output, RowMetaInterface info, VariableSpace space, Repository repository, IMetaStore metaStore ) { super.check( remarks, transMeta, stepMeta, prev, input, output, info, space, repository, metaStore ); StepOption.checkInteger( remarks, stepMeta, space, getString( PKG, "MQTTDialog.Options.KEEP_ALIVE_INTERVAL" ), keepAliveInterval ); StepOption .checkInteger( remarks, stepMeta, space, getString( PKG, "MQTTDialog.Options.MAX_INFLIGHT" ), maxInflight ); StepOption.checkInteger( remarks, stepMeta, space, getString( PKG, "MQTTDialog.Options.CONNECTION_TIMEOUT" ), connectionTimeout ); StepOption .checkBoolean( remarks, stepMeta, space, getString( PKG, "MQTTDialog.Options.CLEAN_SESSION" ), cleanSession ); checkVersion( remarks, stepMeta, space, mqttVersion ); StepOption.checkBoolean( remarks, stepMeta, space, getString( PKG, "MQTTDialog.Options.AUTOMATIC_RECONNECT" ), automaticReconnect ); } MQTTConsumerMeta(); void setDefault(); @Override String getFileName(); @Override RowMeta getRowMeta( String origin, VariableSpace space ); StepInterface getStep( StepMeta stepMeta, StepDataInterface stepDataInterface, int cnr, TransMeta tr,
                                Trans trans ); StepDataInterface getStepData(); @SuppressWarnings ( { "deprecation" } ) // can be removed once the new @PluginDialog annotation supports OSGi String getDialogClassName(); String getMqttServer(); void setMqttServer( String mqttServer ); List<String> getTopics(); void setTopics( List<String> topics ); String getMsgOutputName(); void setMsgOutputName( String msgOutputName ); String getTopicOutputName(); void setTopicOutputName( String topicOutputName ); String getQos(); void setQos( String qos ); String getUsername(); void setUsername( String username ); String getPassword(); void setPassword( String password ); Map<String, String> getSslConfig(); void setSslConfig( Map<String, String> sslConfig ); boolean isUseSsl(); void setUseSsl( boolean useSsl ); String getKeepAliveInterval(); void setKeepAliveInterval( String keepAliveInterval ); String getMaxInflight(); void setMaxInflight( String maxInflight ); String getConnectionTimeout(); void setConnectionTimeout( String connectionTimeout ); String getCleanSession(); void setCleanSession( String cleanSession ); String getStorageLevel(); void setStorageLevel( String storageLevel ); String getServerUris(); void setServerUris( String serverUris ); String getMqttVersion(); void setMqttVersion( String mqttVersion ); String getAutomaticReconnect(); void setAutomaticReconnect( String automaticReconnect ); List<StepOption> retrieveOptions(); @Override void check( List<CheckResultInterface> remarks, TransMeta transMeta,
                     StepMeta stepMeta, RowMetaInterface prev, String[] input, String[] output,
                     RowMetaInterface info, VariableSpace space, Repository repository,
                     IMetaStore metaStore ); @Override boolean equals( Object o ); @Override int hashCode(); }
MQTTConsumerMeta extends BaseStreamStepMeta implements StepMetaInterface { @Override public void check( List<CheckResultInterface> remarks, TransMeta transMeta, StepMeta stepMeta, RowMetaInterface prev, String[] input, String[] output, RowMetaInterface info, VariableSpace space, Repository repository, IMetaStore metaStore ) { super.check( remarks, transMeta, stepMeta, prev, input, output, info, space, repository, metaStore ); StepOption.checkInteger( remarks, stepMeta, space, getString( PKG, "MQTTDialog.Options.KEEP_ALIVE_INTERVAL" ), keepAliveInterval ); StepOption .checkInteger( remarks, stepMeta, space, getString( PKG, "MQTTDialog.Options.MAX_INFLIGHT" ), maxInflight ); StepOption.checkInteger( remarks, stepMeta, space, getString( PKG, "MQTTDialog.Options.CONNECTION_TIMEOUT" ), connectionTimeout ); StepOption .checkBoolean( remarks, stepMeta, space, getString( PKG, "MQTTDialog.Options.CLEAN_SESSION" ), cleanSession ); checkVersion( remarks, stepMeta, space, mqttVersion ); StepOption.checkBoolean( remarks, stepMeta, space, getString( PKG, "MQTTDialog.Options.AUTOMATIC_RECONNECT" ), automaticReconnect ); } MQTTConsumerMeta(); void setDefault(); @Override String getFileName(); @Override RowMeta getRowMeta( String origin, VariableSpace space ); StepInterface getStep( StepMeta stepMeta, StepDataInterface stepDataInterface, int cnr, TransMeta tr,
                                Trans trans ); StepDataInterface getStepData(); @SuppressWarnings ( { "deprecation" } ) // can be removed once the new @PluginDialog annotation supports OSGi String getDialogClassName(); String getMqttServer(); void setMqttServer( String mqttServer ); List<String> getTopics(); void setTopics( List<String> topics ); String getMsgOutputName(); void setMsgOutputName( String msgOutputName ); String getTopicOutputName(); void setTopicOutputName( String topicOutputName ); String getQos(); void setQos( String qos ); String getUsername(); void setUsername( String username ); String getPassword(); void setPassword( String password ); Map<String, String> getSslConfig(); void setSslConfig( Map<String, String> sslConfig ); boolean isUseSsl(); void setUseSsl( boolean useSsl ); String getKeepAliveInterval(); void setKeepAliveInterval( String keepAliveInterval ); String getMaxInflight(); void setMaxInflight( String maxInflight ); String getConnectionTimeout(); void setConnectionTimeout( String connectionTimeout ); String getCleanSession(); void setCleanSession( String cleanSession ); String getStorageLevel(); void setStorageLevel( String storageLevel ); String getServerUris(); void setServerUris( String serverUris ); String getMqttVersion(); void setMqttVersion( String mqttVersion ); String getAutomaticReconnect(); void setAutomaticReconnect( String automaticReconnect ); List<StepOption> retrieveOptions(); @Override void check( List<CheckResultInterface> remarks, TransMeta transMeta,
                     StepMeta stepMeta, RowMetaInterface prev, String[] input, String[] output,
                     RowMetaInterface info, VariableSpace space, Repository repository,
                     IMetaStore metaStore ); @Override boolean equals( Object o ); @Override int hashCode(); @Injection ( name = SSL_KEYS, group = SSL_GROUP )
  public List<String> sslKeys; @Sensitive
  @Injection ( name = SSL_VALUES, group = SSL_GROUP )
  public List<String> sslValues; }