How to use Rabbitmq binder in spring cloud dataflow stream -
i have stream launches task based on given time interval. want use rabbit binder missing syntax of providing rabbitmq broker properties. please me.
here steps , configuration have. 1. imported apps using: app import --uri http//bitly/stream-applications-rabbit-maven 2. registered task: app register --name task-sink --type sink --uri file://tasksink.jar 3. created stream: stream create foo --definition "triggertask --triggertask.uri=file://task-file.jar --trigger.cron-expression=10 | task-sink" 4. stream deploy foo --properties "spring.rabbitmq.host=myhost, spring.rabbitmq.username=user,spring.rabbitmq.password=pass, spring.rabbitmq.port=5672,spring.rabbitmq.virtual-host=xxx" when both stream , runtime apps deployed see error on logs saying connection not established. changed properties syntax "spring.cloud.stream.bindings.rabbitmq.host" same error. not sure not using correct syntax here below different behaviour when run on vpn , without vpn. **note**: case 1: both machines (where scdf running , rabbitmq broker) in core network (vpn). if run scdf , rabbitmq on local machine not work , says unable resolve host. case 2: when run rabbitmq , scdf on local machine (not connected vpn) works fine "spring.rabbitmq.username=user" properties syntax. there setting need change connect different host system? in advance , suggestion.
spring.rabbitmq.host=myhost
correct since passing applications in spring cloud data flow dsl, need prefix applicaton name, i.e. app.triggertask.spring.rabbitmq.host
etc. same other aplications. have few shortcuts available, see:
and
for details.
Comments
Post a Comment