You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
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
The text was updated successfully, but these errors were encountered:
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.
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
The text was updated successfully, but these errors were encountered: