### Question:
MQTTProducerMeta extends BaseSerializingMeta implements StepMetaInterface { public void setTopic( String topic ) { this.topic = topic; } MQTTProducerMeta(); @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 ); List<StepOption> retrieveOptions(); @SuppressWarnings ( { "deprecation" } ) // can be removed once the new @PluginDialog annotation supports OSGi @Override String getDialogClassName(); String getMqttServer(); void setMqttServer( String mqttServer ); String getClientId(); void setClientId( String clientId ); String getTopic(); void setTopic( String topic ); String getQOS(); void setQOS( String qos ); String getMessageField(); void setMessageField( String messageField ); 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(); @Override boolean equals( Object o ); @Override int hashCode(); @Override String toString(); void setAutomaticReconnect( String automaticReconnect );  }### Answer:
@Test public void testSavingToRepository() throws Exception { StringObjectId stepId = new StringObjectId( "step1" ); StringObjectId transId = new StringObjectId( "trans1" ); MQTTProducerMeta localMeta = testMeta(); localMeta.setTopic( "weather" ); localMeta.saveRep( rep, metaStore, transId, stepId ); verify( rep ).saveStepAttribute( transId, stepId, "step-xml", localMeta.getXML() ); verifyNoMoreInteractions( rep ); }