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
Hi,
I am trying to use SubscribeClientImpl with a fanout exchange without much success. Here is some of my code:
var connection:Connection = new Connection(buildConnectionParams());
var serializer:JSONSerializer = new JSONSerializer()
var subClient:SubscribeClientImpl = new SubscribeClientImpl(connection);
subClient.serializer = serializer;
subClient.exchange = "multicast";
subClient.exchangeType = "fanout";
subClient.subscribe("routing_key", onConsume);
Now the subClient.subscribe method takes the routing key and the method to be called as inputs. The routing key is immaterial for exchanges of type fanout. More here.
Digging deeper into the code, I found that onDeliver method of SubscribeClientImpl is being called. I can see that there is a trace method in that method on line 123 which is being printed in debug mode. But this line (line 126) is not working properly:
var topic:String = matchTopic(properties.correlationid || method.routingkey);
Any help would be appreciated. I apologize if I overlooked anything. I am pretty new to AMQP.
cheers,
ducky
The text was updated successfully, but these errors were encountered:
Hi,
I am trying to use SubscribeClientImpl with a fanout exchange without much success. Here is some of my code:
Now the subClient.subscribe method takes the routing key and the method to be called as inputs. The routing key is immaterial for exchanges of type fanout. More here.
Digging deeper into the code, I found that onDeliver method of SubscribeClientImpl is being called. I can see that there is a trace method in that method on line 123 which is being printed in debug mode. But this line (line 126) is not working properly:
Any help would be appreciated. I apologize if I overlooked anything. I am pretty new to AMQP.
cheers,
ducky
The text was updated successfully, but these errors were encountered: