@Override
  public RowMeta getRowMeta( String origin, VariableSpace space ) {
    RowMeta rowMeta = new RowMeta();
    rowMeta.addValueMeta( new ValueMetaBase( msgOutputName, getMessageDataType() ) );
    rowMeta.addValueMeta( new ValueMetaString( topicOutputName ) );
    return rowMeta;
  }
@Test
  public void rowMetaUsesMessageDataType() {
    MQTTConsumerMeta meta = new MQTTConsumerMeta();
    meta.messageDataType = ValueMetaInterface.getTypeDescription( ValueMetaInterface.TYPE_BINARY );
    assertEquals( ValueMetaInterface.TYPE_BINARY, meta.getRowMeta( "", new Variables() ).getValueMeta( 0 ).getType() );
    meta.messageDataType = ValueMetaInterface.getTypeDescription( ValueMetaInterface.TYPE_STRING );
    assertEquals( ValueMetaInterface.TYPE_STRING, meta.getRowMeta( "", new Variables() ).getValueMeta( 0 ).getType() );
  }