Re: [go-nuts] Re: Golang Rabbit MQ Fanout Exchange Multiple Consumers

[Ross Salas]

This may help:
http://activemq.apache.org/how-does-a-queue-compare-to-a-topic.html


On Mon, Jul 4, 2016 at 8:22 AM, Giang Tran  wrote:

> it's because you use single queue for both of consumer, in fanout
> exchange, message is copy to all the queue bind to this exchange.
> Inorder to has 2 copy, you must have to use 2 queue(use different queue
> name).
>
>
> On Monday, July 4, 2016 at 10:09:03 PM UTC+7, Rakesh Goyal wrote:
>>
>>
>>
>> down votefavorite
>> 
>>
>> I am publishing messages in fanout exchange from Java application. I am
>> able to receive message in multiple consumer in Java. I have 2 consumers in
>> golang app but only one of the consumer (alternatively ) is receiving the
>> message (Not both of them for a published message).
>>
>> func HandleMessageFanout1(){
>>
>> conn := system.EltropyAppContext.RabbitMQConn
>>
>> channel, err := conn.Channel()
>>
>> if(err!=nil){
>> log.Println(err)
>> }
>> //forever := make(chan bool)
>>
>>
>>
>> deliveries,err := channel.Consume(
>> "example.queue", //queue
>> "qw",
>> true,
>> false,
>> false,
>> false,
>> nil)
>>
>> if(err!=nil){
>> log.Println(err)
>> }
>>
>> go func() {
>>
>> for d := range deliveries {
>> log.Printf("Message recived in fanout 1")
>> log.Printf("Received a message: %s", d.Body)
>> }
>> }()
>>
>> //<-forever
>>
>> }
>>
>> //2nd Consumer
>>
>> package consumer
>>
>> import (
>> "github.com/eltropy/shehnai/backend/golang/common-packages/system"
>> log "github.com/Sirupsen/logrus"
>> )
>>
>> func HandleMessageFanout2() {
>>
>> conn := system.EltropyAppContext.RabbitMQConn
>>
>> channel, err := conn.Channel()
>>
>> if (err!=nil) {
>> log.Println(err)
>> }
>>
>> //forever := make(chan bool)
>>
>> deliveries, err := channel.Consume(
>> "example.queue", //queue
>> "q2",
>> true,
>> false,
>> false,
>> false,
>> nil)
>>
>> if (err!=nil) {
>> log.Println(err)
>> }
>>
>> go func() {
>> for d := range deliveries {
>> log.Printf("Message recived in fanout 2")
>> log.Printf("Received a message: %s", d.Body)
>> }
>> }()
>>
>> //<-forever
>>
>> }
>>
>> I am using https://github.com/streadway/amqp library for rabbit mq.
>>
> --
> You received this message because you are subscribed to the Google Groups
> "golang-nuts" group.
> To unsubscribe from this group and stop receiving emails from it, send an
> email to golang-nuts+unsubscr...@googlegroups.com.
> For more options, visit https://groups.google.com/d/optout.
>

-- 
You received this message because you are subscribed to the Google Groups 
"golang-nuts" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to golang-nuts+unsubscr...@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

[go-nuts] Re: Golang Rabbit MQ Fanout Exchange Multiple Consumers

[Giang Tran]

it's because you use single queue for both of consumer, in fanout exchange, 
message is copy to all the queue bind to this exchange.
Inorder to has 2 copy, you must have to use 2 queue(use different queue 
name).

On Monday, July 4, 2016 at 10:09:03 PM UTC+7, Rakesh Goyal wrote:
>
>
>
> down votefavorite 
> 
>
> I am publishing messages in fanout exchange from Java application. I am 
> able to receive message in multiple consumer in Java. I have 2 consumers in 
> golang app but only one of the consumer (alternatively ) is receiving the 
> message (Not both of them for a published message).
>
> func HandleMessageFanout1(){
>
> conn := system.EltropyAppContext.RabbitMQConn
>
> channel, err := conn.Channel()
>
> if(err!=nil){
> log.Println(err)
> }
> //forever := make(chan bool)
>
>
>
> deliveries,err := channel.Consume(
> "example.queue", //queue
> "qw",
> true,
> false,
> false,
> false,
> nil)
>
> if(err!=nil){
> log.Println(err)
> }
>
> go func() {
>
> for d := range deliveries {
> log.Printf("Message recived in fanout 1")
> log.Printf("Received a message: %s", d.Body)
> }
> }()
>
> //<-forever
>
> }
>
> //2nd Consumer
>
> package consumer
>
> import (
> "github.com/eltropy/shehnai/backend/golang/common-packages/system"
> log "github.com/Sirupsen/logrus"
> )
>
> func HandleMessageFanout2() {
>
> conn := system.EltropyAppContext.RabbitMQConn
>
> channel, err := conn.Channel()
>
> if (err!=nil) {
> log.Println(err)
> }
>
> //forever := make(chan bool)
>
> deliveries, err := channel.Consume(
> "example.queue", //queue
> "q2",
> true,
> false,
> false,
> false,
> nil)
>
> if (err!=nil) {
> log.Println(err)
> }
>
> go func() {
> for d := range deliveries {
> log.Printf("Message recived in fanout 2")
> log.Printf("Received a message: %s", d.Body)
> }
> }()
>
> //<-forever
>
> }
>
> I am using https://github.com/streadway/amqp library for rabbit mq.
>

-- 
You received this message because you are subscribed to the Google Groups 
"golang-nuts" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to golang-nuts+unsubscr...@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.