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

can we publish message to queue in rabbit mq instead of a topic? #3402

Open
isaacnikon93 opened this issue Apr 25, 2024 · 2 comments
Open

can we publish message to queue in rabbit mq instead of a topic? #3402

isaacnikon93 opened this issue Apr 25, 2024 · 2 comments

Comments

@isaacnikon93
Copy link

i am trying to use rabbit mq pubsub component and try to send a message to queue directly instead of using a topic
i have a few queues already created, i tried using bindings but it was causing some overflow when i was trying to define ttlInSeconds of "2592000" (30 days), according to RabbitMQ documentation if we pass a empty string as exchange and pass a routingKey
https://www.rabbitmq.com/tutorials/amqp-concepts#exchange-default

i am trying to send it like below
d.client.PublishEvent(ctx, "rabbit-mq-pubsub", "", data.Message, client.PublishEventWithMetadata( map[string]string{ "priority": fmt.Sprint(data.Priority), "routingKey": queueName, }, ))

any pointers will be helpful

@berndverst
Copy link
Member

berndverst commented May 1, 2024

I am not sure. I don't believe we currently have any active contributor with deep RabbitMQ knowledge (through I could be wrong). If you'd like to look through the code we have it's here. PRs welcome to improve things.

The SDK we use: https://github.com/rabbitmq/amqp091-go (currently on v1.8.1)

Dapr PubSub code:
https://github.com/dapr/components-contrib/tree/main/pubsub/rabbitmq/

and

Dapr Binding code
https://github.com/dapr/components-contrib/blob/main/bindings/rabbitmq/

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