apiVersion: dapr.io/v1alpha1 kind: Component metadata: name: messagebus namespace: default spec: type: pubsub.rabbitmq metadata: - name: host value: amqp://user:GSlU5LpIa1:32421 # Required. Example: "amqp://rabbitmq.default.svc.cluster.local:5672", "amqp://localhost:5672" - name: consumerID value: rabbitMqConsumer # Required. Any unique ID. Example: "myConsumerID" # - name: durable # value: "true" # Optional. Default: "false" # # - name: deletedWhenUnused # # value: <REPLACE-WITH-DELETE-WHEN-UNUSED> # Optional. Default: "false" - name: autoAck value: true # Optional. Default: "false" # # - name: deliveryMode # # value: "0" # Optional. Default: "0". Values between 0 - 2. # - name: requeueInFailure # value: "true" # Optional. Default: "false".
== APP == 2020/09/02 00:27:58 event - PubsubName: messagebus, Topic: neworder, ID: 5dc38ceb-9a1a-4d71-9c8e-0d44f98f4845, Data: ping == DAPR == time="2020-09-02T00:27:58.172224+08:00" level=error msg="rabbitmq pub/sub: error handling message from topic 'neworder', error returned from app while processing pub/sub event: . status code returned: 500" app_id=faildsub1 instance=ArideMacBook-Air.local scope=dapr.contrib type=log ver=0.10.0
DAPR won’t distribute message from input binding to multiple instances of consumer?
I have the following scenario and issue:
1) External system publish 500 TODO job message to RabbitMQ
2) Consumer Pod use input binding (AMQP protocol) to receive messages from RabbitMQ, and Consumer Pod is running on demand (if no message, then no instances running)
2) KEDA scale the Consumer Pod from 0 to 5 based on custom metrics of RabbitMQ queueLength
3) Kubernetes create 5 instances of Consumer Pod based on scale rule (incoming 500 messages)
4) The daprd sidecar of first instances of Consumer Pod will get all 500 messages and processed them one by one, each message will use 20 seconds to complete, at meantime, the status of all messages in RabbitMQ changed from Ready to Unacked - UnAcknoledged
5) The other 4 instances of consumer Pod did NOT get any un-processed messages from RabbitMQ and free all time
I need all 5 instances of Consumer Pod parallelly process all non-complete messages in RabbitMQ, What configuration I missed or did wrong?
InvokeMethodmethod of the dapr client? Am I right that the DaprClient makes a gRPC request to the sidecar, then the sidecar searches for the service and makes a gRPC request to the sidecar of the API service. And then the sidecar makes an HTTP call to the API? If so, can someone point me to the right code in GitHub?
2020/09/04 00:02:52 http: TLS handshake error from 100.96.2.0:41578: remote error: tls: bad certificate
Hi I'm having trouble getting service invocation from C# sdk to work.
Even tried running the samples at
I have "routing" up and running, and can invoke it successfully via
dapr invokeGet -a routing -m 17 .
However, when running the sample
Client code (with the GET invocation uncommented), i get the following error:
== APP == Unhandled exception. Grpc.Core.RpcException: Status(StatusCode=Unknown, Detail="context deadline exceeded")
I get the same error when I try to invoke my own service code from another of my own services, which is what started me down this road. After getting the excact same error from sample code i figured it's time to ask for help :P Any ideas? Running on OSX if that matters.
We are trying to POC dapr for our company, really like what its trying to achieve.
We have it running in Kubernetes and want to setup dapr running on a VM.
My question is
How do i step these two locations to communicate with each other?
How does service discovery work across hosts?