@Test public void testCheck() { List<CheckResultInterface> remarks = new ArrayList<>(); JmsProducerMeta jmsProducerMeta = new JmsProducerMeta(); jmsProducerMeta.setDisableMessageId( "asdf" ); jmsProducerMeta.setDisableMessageTimestamp( "asdf" ); jmsProducerMeta.setDeliveryMode( "asdf" ); jmsProducerMeta.setPriority( "asdf" ); jmsProducerMeta.setTimeToLive( "asdf" ); jmsProducerMeta.setDeliveryDelay( "asdf" ); jmsProducerMeta.check( remarks, null, null, null, null, null, null, new Variables(), null, null ); assertEquals( 6, remarks.size() ); assertTrue( remarks.get( 0 ).getText() .contains( BaseMessages.getString( JmsProducerMeta.class, "JmsDialog.Options.DISABLE_MESSAGE_ID" ) ) ); assertTrue( remarks.get( 1 ).getText() .contains( BaseMessages.getString( JmsProducerMeta.class, "JmsDialog.Options.DISABLE_MESSAGE_TIMESTAMP" ) ) ); assertTrue( remarks.get( 2 ).getText() .contains( BaseMessages.getString( JmsProducerMeta.class, "JmsDialog.Options.DELIVERY_MODE" ) ) ); assertTrue( remarks.get( 3 ).getText() .contains( BaseMessages.getString( JmsProducerMeta.class, "JmsDialog.Options.PRIORITY" ) ) ); assertTrue( remarks.get( 4 ).getText() .contains( BaseMessages.getString( JmsProducerMeta.class, "JmsDialog.Options.TIME_TO_LIVE" ) ) ); assertTrue( remarks.get( 5 ).getText() .contains( BaseMessages.getString( JmsProducerMeta.class, "JmsDialog.Options.DELIVERY_DELAY" ) ) ); remarks = new ArrayList<>(); jmsProducerMeta.setDisableMessageId( "true" ); jmsProducerMeta.setDisableMessageTimestamp( "false" ); jmsProducerMeta.setDeliveryMode( "1" ); jmsProducerMeta.setPriority( "2" ); jmsProducerMeta.setTimeToLive( "3" ); jmsProducerMeta.setDeliveryDelay( "4" ); jmsProducerMeta.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.checkBoolean( remarks, stepMeta, space, getString( PKG, "JmsDialog.Options.DISABLE_MESSAGE_ID" ), disableMessageId ); StepOption.checkBoolean( remarks, stepMeta, space, getString( PKG, "JmsDialog.Options.DISABLE_MESSAGE_TIMESTAMP" ), disableMessageTimestamp ); StepOption.checkInteger( remarks, stepMeta, space, getString( PKG, "JmsDialog.Options.DELIVERY_MODE" ), deliveryMode ); StepOption.checkInteger( remarks, stepMeta, space, getString( PKG, "JmsDialog.Options.PRIORITY" ), priority ); StepOption.checkLong( remarks, stepMeta, space, getString( PKG, "JmsDialog.Options.TIME_TO_LIVE" ), timeToLive ); StepOption.checkLong( remarks, stepMeta, space, getString( PKG, "JmsDialog.Options.DELIVERY_DELAY" ), deliveryDelay ); }
JmsProducerMeta extends BaseSerializingMeta implements StepMetaInterface, Cloneable { @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.checkBoolean( remarks, stepMeta, space, getString( PKG, "JmsDialog.Options.DISABLE_MESSAGE_ID" ), disableMessageId ); StepOption.checkBoolean( remarks, stepMeta, space, getString( PKG, "JmsDialog.Options.DISABLE_MESSAGE_TIMESTAMP" ), disableMessageTimestamp ); StepOption.checkInteger( remarks, stepMeta, space, getString( PKG, "JmsDialog.Options.DELIVERY_MODE" ), deliveryMode ); StepOption.checkInteger( remarks, stepMeta, space, getString( PKG, "JmsDialog.Options.PRIORITY" ), priority ); StepOption.checkLong( remarks, stepMeta, space, getString( PKG, "JmsDialog.Options.TIME_TO_LIVE" ), timeToLive ); StepOption.checkLong( remarks, stepMeta, space, getString( PKG, "JmsDialog.Options.DELIVERY_DELAY" ), deliveryDelay ); } }
JmsProducerMeta extends BaseSerializingMeta implements StepMetaInterface, Cloneable { @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.checkBoolean( remarks, stepMeta, space, getString( PKG, "JmsDialog.Options.DISABLE_MESSAGE_ID" ), disableMessageId ); StepOption.checkBoolean( remarks, stepMeta, space, getString( PKG, "JmsDialog.Options.DISABLE_MESSAGE_TIMESTAMP" ), disableMessageTimestamp ); StepOption.checkInteger( remarks, stepMeta, space, getString( PKG, "JmsDialog.Options.DELIVERY_MODE" ), deliveryMode ); StepOption.checkInteger( remarks, stepMeta, space, getString( PKG, "JmsDialog.Options.PRIORITY" ), priority ); StepOption.checkLong( remarks, stepMeta, space, getString( PKG, "JmsDialog.Options.TIME_TO_LIVE" ), timeToLive ); StepOption.checkLong( remarks, stepMeta, space, getString( PKG, "JmsDialog.Options.DELIVERY_DELAY" ), deliveryDelay ); } @VisibleForTesting  JmsProducerMeta();  JmsProducerMeta( JmsDelegate jmsDelegate ); }
JmsProducerMeta extends BaseSerializingMeta implements StepMetaInterface, Cloneable { @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.checkBoolean( remarks, stepMeta, space, getString( PKG, "JmsDialog.Options.DISABLE_MESSAGE_ID" ), disableMessageId ); StepOption.checkBoolean( remarks, stepMeta, space, getString( PKG, "JmsDialog.Options.DISABLE_MESSAGE_TIMESTAMP" ), disableMessageTimestamp ); StepOption.checkInteger( remarks, stepMeta, space, getString( PKG, "JmsDialog.Options.DELIVERY_MODE" ), deliveryMode ); StepOption.checkInteger( remarks, stepMeta, space, getString( PKG, "JmsDialog.Options.PRIORITY" ), priority ); StepOption.checkLong( remarks, stepMeta, space, getString( PKG, "JmsDialog.Options.TIME_TO_LIVE" ), timeToLive ); StepOption.checkLong( remarks, stepMeta, space, getString( PKG, "JmsDialog.Options.DELIVERY_DELAY" ), deliveryDelay ); } @VisibleForTesting  JmsProducerMeta();  JmsProducerMeta( JmsDelegate jmsDelegate ); @SuppressWarnings( "deprecated" ) String getDialogClassName(); @Override void setDefault(); @Override StepInterface getStep( StepMeta stepMeta, StepDataInterface stepDataInterface, int copyNr, TransMeta transMeta,
                                Trans trans ); @Override StepDataInterface getStepData(); @Override void check( List<CheckResultInterface> remarks, TransMeta transMeta,
                     StepMeta stepMeta, RowMetaInterface prev, String[] input, String[] output,
                     RowMetaInterface info, VariableSpace space, Repository repository,
                     IMetaStore metaStore ); String getFieldToSend(); void setFieldToSend( String fieldToSend ); void setPropertyValuesByName( Map<String, String> propertyValuesByName ); Map<String, String> getPropertyValuesByName(); String getDisableMessageId(); void setDisableMessageId( String disableMessageId ); String getDisableMessageTimestamp(); void setDisableMessageTimestamp( String disableMessageTimestamp ); String getDeliveryMode(); void setDeliveryMode( String deliveryMode ); String getPriority(); void setPriority( String priority ); String getTimeToLive(); void setTimeToLive( String timeToLive ); String getDeliveryDelay(); void setDeliveryDelay( String deliveryDelay ); String getJmsCorrelationId(); void setJmsCorrelationId( String jmsCorrelationId ); String getJmsType(); void setJmsType( String jmsType ); List<StepOption> retriveOptions(); }
JmsProducerMeta extends BaseSerializingMeta implements StepMetaInterface, Cloneable { @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.checkBoolean( remarks, stepMeta, space, getString( PKG, "JmsDialog.Options.DISABLE_MESSAGE_ID" ), disableMessageId ); StepOption.checkBoolean( remarks, stepMeta, space, getString( PKG, "JmsDialog.Options.DISABLE_MESSAGE_TIMESTAMP" ), disableMessageTimestamp ); StepOption.checkInteger( remarks, stepMeta, space, getString( PKG, "JmsDialog.Options.DELIVERY_MODE" ), deliveryMode ); StepOption.checkInteger( remarks, stepMeta, space, getString( PKG, "JmsDialog.Options.PRIORITY" ), priority ); StepOption.checkLong( remarks, stepMeta, space, getString( PKG, "JmsDialog.Options.TIME_TO_LIVE" ), timeToLive ); StepOption.checkLong( remarks, stepMeta, space, getString( PKG, "JmsDialog.Options.DELIVERY_DELAY" ), deliveryDelay ); } @VisibleForTesting  JmsProducerMeta();  JmsProducerMeta( JmsDelegate jmsDelegate ); @SuppressWarnings( "deprecated" ) String getDialogClassName(); @Override void setDefault(); @Override StepInterface getStep( StepMeta stepMeta, StepDataInterface stepDataInterface, int copyNr, TransMeta transMeta,
                                Trans trans ); @Override StepDataInterface getStepData(); @Override void check( List<CheckResultInterface> remarks, TransMeta transMeta,
                     StepMeta stepMeta, RowMetaInterface prev, String[] input, String[] output,
                     RowMetaInterface info, VariableSpace space, Repository repository,
                     IMetaStore metaStore ); String getFieldToSend(); void setFieldToSend( String fieldToSend ); void setPropertyValuesByName( Map<String, String> propertyValuesByName ); Map<String, String> getPropertyValuesByName(); String getDisableMessageId(); void setDisableMessageId( String disableMessageId ); String getDisableMessageTimestamp(); void setDisableMessageTimestamp( String disableMessageTimestamp ); String getDeliveryMode(); void setDeliveryMode( String deliveryMode ); String getPriority(); void setPriority( String priority ); String getTimeToLive(); void setTimeToLive( String timeToLive ); String getDeliveryDelay(); void setDeliveryDelay( String deliveryDelay ); String getJmsCorrelationId(); void setJmsCorrelationId( String jmsCorrelationId ); String getJmsType(); void setJmsType( String jmsType ); List<StepOption> retriveOptions(); static final String DISABLE_MESSAGE_ID; static final String DISABLE_MESSAGE_TIMESTAMP; static final String DELIVERY_MODE; static final String PRIORITY; static final String TIME_TO_LIVE; static final String DELIVERY_DELAY; static final String JMS_CORRELATION_ID; static final String JMS_TYPE; @InjectionDeep
  final JmsDelegate jmsDelegate; }