@Test
public void testCsvInitialSchema() {

    outgoing.put("passCsvOutFrom", "csv");
    String[] schema = {"name","id#"}; 
    outgoing.put("useCsvSchema", Arrays.asList(schema));
    
    pHandler = new UDPPublishHandler(outgoing, fakeSocket, sourceName);
    
    Map<String,Object> testMap = new LinkedHashMap<>();
    Map<String,Object> obj1 = new LinkedHashMap<>();
    obj1.put("name","bob newhart");
    obj1.put("id#","12345");
    Map<String,Object> obj2 = new LinkedHashMap<>();
    obj2.put("name","raynor, jim");
    obj2.put("id#","67892");
    obj2.put("notInSchema","ignored");
    Map[] objects = {obj1, obj2};
    
    testMap.put("csv", Arrays.asList(objects));
    
    String expectedData = "name,id#\nbob newhart,12345\n\"raynor, jim\",67892\n";
    
    // Test UUT
    createMessage(testMap);
    pHandler.handleMessage(extMsg);
    
    assert fakeSocket.compareData(expectedData);
}