class MQTTConsumerMeta extends BaseStreamStepMeta implements StepMetaInterface {

  public void setSslConfig( Map<String, String> sslConfig ) {
    sslKeys = conf( sslConfig ).keys();
    sslValues = conf( sslConfig ).vals();
  }

  public  MQTTConsumerMeta();

}