feat(command): command query via internal messaging #4182

chr1shung · 2022-10-05T07:27:43Z

Signed-off-by: Chris Hung [email protected]

If your build fails due to your commit message not passing the build checks, please review the guidelines here: https://github.com/edgexfoundry/edgex-go/blob/main/.github/Contributing.md

PR Checklist

Please check if your PR fulfills the following requirements:

I am not introducing a breaking change (if you are, flag in conventional commit message with BREAKING CHANGE: describing the break)
I am not introducing a new dependency (add notes below if you are)
I have added unit tests for the new feature or bug fix (if not, why?)
I have fully tested (add details below) this the new feature or bug fix (if not, why?)
I have opened a PR for the related docs change (if not, why?)

Testing Instructions

Run core-command from this branch with MESSAGEQUEUE_REQUIRED=true environment variable
Send command query request via internal messaging, for example:

/data # redis-cli
127.0.0.1:6379> PUBLISH .commandquery.request.Random-Boolean-Device '{"CorrelationID": "14a42ea6-c394-41c3-8bcd-a29b9f5e6835", "ApiVersion": "v2", "RequestId": "e6e8a2f4-eb14-4649-9e2b-175247911369", "ContentType": "application/json"}'
(integer) 1

Verify core-command received the request and send the response back correctly:

level=DEBUG ts=2022-10-05T07:26:15.601091825Z app=core-command source=internal.go:196 msg="Command query request received on internal MessageBus. Topic: /commandquery/request/Random-Boolean-Device, Correlation-id: 14a42ea6-c394-41c3-8bcd-a29b9f5e6835 "
level=DEBUG ts=2022-10-05T07:26:15.606759825Z app=core-command source=internal.go:223 msg="Command query response sent to internal MessageBus. Topic: /commandquery/response, Correlation-id: 14a42ea6-c394-41c3-8bcd-a29b9f5e6835"