Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Edgex 2.3.0 use mqtt messagebus #2197

Closed
edgego opened this issue Aug 18, 2023 · 3 comments
Closed

Edgex 2.3.0 use mqtt messagebus #2197

edgego opened this issue Aug 18, 2023 · 3 comments
Assignees

Comments

@edgego
Copy link

edgego commented Aug 18, 2023

Hi team, I use mqtt messagebus , and setup conf key for ekuiper:
mod1:
messageType: request
optional:
ClientId: kuiper-rules-engine
KeepAlive: 500
Qos: 0
Retained: false
SkipCertVerify: true
port: 1883
protocol: tcp
server: edge-mqtt-broker
topic: edgex/events/device/Test-Device-Modbus-Profile/mod1#
type: mqtt

and create a rule based on datastream mod1, from ekuiper got error:

time="2023-08-18 02:37:59" level=error msg="Failed to subscribe to edgex messagebus with topic edgex/events/device/Test-Device-Modbus-Profile/mod1# has error : An error occured while performing a 'Subscribe' operation: connection lost before Subscribe completed." file="edgex/edgex.go:143"
time="2023-08-18 02:37:59" level=error msg="Failed to subscribe to edgex messagebus topic An error occured while performing a 'Subscribe' operation: connection lost before Subscribe completed.\n" file="edgex/edgex_source.go:94" source_pool=edgex.mod1

please kindly help how to setup conf key ! Thanks a lot!

@Rui-Gan
Copy link
Collaborator

Rui-Gan commented Aug 18, 2023

mod1:
  messageType: request
  port: 1883
  protocol: tcp
  server: edge-mqtt-broker
  topic: edgex/events/device/Test-Device-Modbus-Profile/mod1/#
  type: mqtt
  optional:
    ClientId: kuiper-rules-engine
    KeepAlive: 500
    Qos: 0
    Retained: false
    SkipCertVerify: true

Hi, you can try this configuration!

@edgego
Copy link
Author

edgego commented Aug 18, 2023

Thanks , sound like work

@ngjaying
Copy link
Collaborator

Close as it is solved.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

3 participants