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
When i split this code between two or more applications, lets say one app is just publishing messages and others are consuming them it then doesnt work, it requires me to setup bindings between exachanges and queues manually.
[Routing(RoutingKey = "event", NoAck = true, PrefetchCount = 50)]
[Exchange(Name = "def_q", Type = ExchangeType.Topic)]
internal class Event
{
public DateTime CreatedAt { get; set; }
public string Message { get; set; }
}
it still doesnt work with topic exchange, and from my understanding, exchange is the place where i should publish my messages to, then given the routing key it(exchange) should be bound to any queues that accept mentioned routing key, im having trouble understanding why SubscribeAsync creates an exchange for a consumer, shouldnt it create a queue?
am i missing something there?
The text was updated successfully, but these errors were encountered:
charconstpointer
changed the title
Consumer creating
Confused about binding between exchange and queues
Aug 19, 2019
If I'm not mistaken you have the same idiom, Event, placed in separate assemblies as effectively different types. Have you tried with Event put into a common classlib? I see this as something that may affect you.
and this does not
What is the configuration you use? The default has Durable set to true and AutoDelete to false for the exchange.
When i split this code between two or more applications, lets say one app is just publishing messages and others are consuming them it then doesnt work, it requires me to setup bindings between exachanges and queues manually.
For example
Using attrbitues
My consumer
And producer
it still doesnt work with topic exchange, and from my understanding, exchange is the place where i should publish my messages to, then given the routing key it(exchange) should be bound to any queues that accept mentioned routing key, im having trouble understanding why SubscribeAsync creates an exchange for a consumer, shouldnt it create a queue?
am i missing something there?
The text was updated successfully, but these errors were encountered: