the sample composite events and others have __ instead of _ for the amqp events. for example
{"wf_user": "rynge",
"root__xwf__id": "d8939648-74cd-4809-a6ee-f640b69ba155",
"job__id": "create_dir_synthetic_0_staging_site",
"submit__dir": "/lfs1/scratch/rynge/workflows/rynge/pegasus/synthetic/20180829T094516-0700",
"site": "local",
"pegasus__version": "4.9.0dev",
"event": "stampede.job_inst.composite",
"xwf__id": "d8939648-74cd-4809-a6ee-f640b69ba155",
"work_dir": "/lfs1/scratch/rynge/workflows/rynge/pegasus/synthetic/20180829T094516-0700",
"wf__ts": 1535561116,
"ts": 1535561214,
"local__dur": 4,
"sched__id": "4147075.0",
"multiplier_factor": "1",
"submit__hostname": "bamboo.isi.edu",
"stderr__file": "00/01/create_dir_synthetic_0_staging_site.err.000",
"int_error_count": 0,
"status": 0,
"dag": "synthetic-0.dag",
"js__id": 4,
"job_inst__id": 1,
"user": "rynge",
"stdout__text": "#@ 1 stdout%0A2018-08-29 09:46:50,736 INFO: Reading URL pairs from stdin%0A2018-08-29 09:46:50,737 INFO: 1 transfers loaded%0A2018-08-29 09:46:50,737 INFO: PATH=/usr/bin:/bin%0A2018-08-29 09:46:50,737 INFO: LD_LIBRARY_PATH=%0A2018-08-29 09:46:50,764 INFO: --------------------------------------------------------------------------------%0A2018-08-29 09:46:50,765 INFO: Starting transfers - attempt 1%0A2018-08-29 09:46:52,831 INFO: Tool found: gfal-mkdir Version: 2.15.4 Path: /usr/bin/gfal-mkdir%0A2018-08-29 09:46:52,831 INFO: gfal-mkdir -p %27gsiftp://bamboo.isi.edu/nfs/ccg4/scratch-purge-no-backups/rynge/intermediate/rynge/pegasus/synthetic/20180829T094516-0700%27%0A2018-08-29 09:46:54,348 INFO: --------------------------------------------------------------------------------%0A2018-08-29 09:46:54,348 INFO: Stats: no local files in the transfer set%0A2018-08-29 09:46:54,348 INFO: All transfers completed successfully.%0A", "dax": "/nfs/asd2/rynge/pegasus/synthetic-integrity-test/dax.xml",
"stdout__file": "00/01/create_dir_synthetic_0_staging_site.out.000",
"stderr__text": "",
"jobtype": "6",
"exitcode": "0"}
{"wf_user": "rynge",
"root__xwf__id": "d8939648-74cd-4809-a6ee-f640b69ba155",
"job__id": "create_dir_synthetic_0_staging_site",
"submit__dir": "/lfs1/scratch/rynge/workflows/rynge/pegasus/synthetic/20180829T094516-0700",
"site": "local",
"pegasus__version": "4.9.0dev",
"event": "stampede.job_inst.composite",
"xwf__id": "d8939648-74cd-4809-a6ee-f640b69ba155",
"work_dir": "/lfs1/scratch/rynge/workflows/rynge/pegasus/synthetic/20180829T094516-0700",
"wf__ts": 1535561116,
"ts": 1535561214,
"local__dur": 4,
"sched__id": "4147075.0",
"multiplier_factor": "1",
"submit__hostname": "bamboo.isi.edu",
"stderr__file": "00/01/create_dir_synthetic_0_staging_site.err.000",
"int_error_count": 0,
"status": 0,
"dag": "synthetic-0.dag",
"js__id": 4,
"job_inst__id": 1,
"user": "rynge",
"stdout__text": "#@ 1 stdout%0A2018-08-29 09:46:50,736 INFO: Reading URL pairs from stdin%0A2018-08-29 09:46:50,737 INFO: 1 transfers loaded%0A2018-08-29 09:46:50,737 INFO: PATH=/usr/bin:/bin%0A2018-08-29 09:46:50,737 INFO: LD_LIBRARY_PATH=%0A2018-08-29 09:46:50,764 INFO: --------------------------------------------------------------------------------%0A2018-08-29 09:46:50,765 INFO: Starting transfers - attempt 1%0A2018-08-29 09:46:52,831 INFO: Tool found: gfal-mkdir Version: 2.15.4 Path: /usr/bin/gfal-mkdir%0A2018-08-29 09:46:52,831 INFO: gfal-mkdir -p %27gsiftp://bamboo.isi.edu/nfs/ccg4/scratch-purge-no-backups/rynge/intermediate/rynge/pegasus/synthetic/20180829T094516-0700%27%0A2018-08-29 09:46:54,348 INFO: --------------------------------------------------------------------------------%0A2018-08-29 09:46:54,348 INFO: Stats: no local files in the transfer set%0A2018-08-29 09:46:54,348 INFO: All transfers completed successfully.%0A", "dax": "/nfs/asd2/rynge/pegasus/synthetic-integrity-test/dax.xml",
"stdout__file": "00/01/create_dir_synthetic_0_staging_site.out.000",
"stderr__text": "",
"jobtype": "6",
"exitcode": "0"}