Fixed bug sending event

[aneeshkp]

Signed-off-by: Aneesh Puttur [email protected]
fixing a bug that prevented event getting posted

[nmathew]

@aneeshkp

linuxptp-daemon side:

time="2022-11-10T20:39:45Z" level=info msg="setting return address to /cluster/node/cp-baremetal-ptpstack-1/mock/RRyIz"
time="2022-11-10T20:39:45Z" level=info msg="got status check call,fire events returning to /cluster/node/cp-baremetal-ptpstack-1/mock/RRyIz"
time="2022-11-10T20:39:45Z" level=info msg="created new sender for /cluster/node/cp-baremetal-ptpstack-1/mock/RRyIz"
time="2022-11-10T20:39:47Z" level=error msg="failed to send(TO): /cluster/node/cp-baremetal-ptpstack-1/mock/RRyIz result context deadline exceeded "
time="2022-11-10T20:39:47Z" level=error msg="postprocessfn:not finding publisher for address /cluster/node/cp-baremetal-ptpstack-1/mock/status"

consumer side:

time="2022-11-10T20:39:45Z" level=info msg="sending status requerst to status address /cluster/node/cp-baremetal-ptpstack-1/mock/status with return /cluster/node/cp-baremetal-ptpstack-1/mock/RRyIz"
time="2022-11-10T20:39:45Z" level=info msg="waiting to receive message at /cluster/node/cp-baremetal-ptpstack-1/mock/RRyIz"
time="2022-11-10T20:39:45Z" level=info msg="got the status msg Context Attributes,\n  specversion: 0.3\n  type: /cluster/node/cp-baremetal-ptpstack-1/mock\n  source: /cluster/node/cp-baremetal-ptpstack-1/mock\n  subject: mock\n  id: 3eb49d48-f07b-4406-b8f0-d445472fe629\n  time: 2022-11-10T20:39:45.485Z\n  datacontenttype: application/json\nData,\n  {\n    \"version\": \"v1\",\n    \"values\": [\n      {\n        \"resource\": \"/mock\",\n        \"dataType\": \"notification\",\n        \"valueType\": \"enumeration\",\n        \"value\": \"ACQUIRING-SYNC\"\n      },\n      {\n        \"resource\": \"/mock\",\n        \"dataType\": \"metric\",\n        \"valueType\": \"decimal64.3\",\n        \"value\": \"99.6\"\n      }\n    ]\n  }\n"
time="2022-11-10T20:39:47Z" level=error msg="failed to send(TO): /cluster/node/cp-baremetal-ptpstack-1/mock/status result context deadline exceeded "
time="2022-11-10T20:39:47Z" level=error msg="failed to receive status request to address /cluster/node/cp-baremetal-ptpstack-1/mock/status"

Is this change fix this send(TO) error? I am running with MOCK_PLUGIN.

[nmathew]

Here data is actually getting send, but send says it failed.

[aneeshkp]

The fix should have taken care of that error. Are you running consumer and producer as two different container ?

[nmathew]

@aneeshkp yes two different containers, any problems with this configurations.

[aneeshkp]

@nmathew please create an issue under clouen-event-proxy project and we can discuss it there. I am able to recreate same message with mock_plugin and look into fixing that. Like you said its false error and events are actually getting delivered.

[nmathew]

Actual issue is here Azure/go-amqp#193.
I will also raise an issue with cloud-event-proxy .

[nmathew]

redhat-cne/cloud-event-proxy#150