Ayende, thanks for reply. I have tried using a separate queue per
subscriber. For example, (with just 1 publisher and 1 subscriber) I
have a publisher queue called "my.queue" and a subscriber queue called
"my.subscriber1". Configured as below. However, with this
configuration I do not receive any messages. I have tried with both
OnewayRhinoServiceBusFacility and the regular RhinoServiceBusFacility.
Subscriber config:
-----------------
<facility id="rhino.esb.receiver" >
<bus threadCount="1" numberOfRetries="5" endpoint="msmq://
localhost/my.subscriber1" DisableAutoQueueCreation="false" />
<messages>
<add name="My.Messages.Namespace" endpoint="msmq://
localhost/my.queue" />
</messages>
</facility>
Publisher config:
-----------------
<facility id="rhino.esb.sender" >
<messages>
<add name="My.Messages.Namespace" endpoint="msmq://localhost/
my.queue"/>
</messages>
</facility>
Log from the receiver:
----------------------
DEBUG Rhino.ServiceBus.Impl.DefaultServiceBus [(null)] Starting the
bus for Uri: msmq://computername/my.subscriber1
DEBUG Rhino.ServiceBus.Impl.DefaultServiceBus [(null)] Initating
subscription storage as message module:
Rhino.ServiceBus.Msmq.MsmqSubscriptionStorage
DEBUG Rhino.ServiceBus.Msmq.AbstractMsmqListener [(null)] Starting
msmq transport on: Uri: msmq://computername/my.subscriber1
DEBUG Rhino.ServiceBus.Msmq.MsmqSubscriptionStorage [(null)]
Initializing msmq subscription storage on:
msmq://localhost/my.subscriber1;subscriptions
INFO Rhino.ServiceBus.Impl.DefaultServiceBus [(null)] Subscribing
My.Messages.Namespace.MyMessage on msmq://localhost/my.queue
DEBUG Rhino.ServiceBus.Msmq.OpenedQueue [(null)] Sending message
Rhino.ServiceBus.Messages.AddSubscription to COMPUTERNAME\private$
\my.queue, reply: COMPUTERNAME\private$\my.subscriber1
DEBUG Rhino.ServiceBus.Msmq.MsmqTransport [(null)] Send message
Rhino.ServiceBus.Messages.AddSubscription to Uri: msmq://computername/my.queue
Thanks for your help,
Andrew
On Nov 24, 11:30 am, Ayende Rahien <[email protected]> wrote:
> Every subscriber needs to have its own queue
>
> On Mon, Nov 23, 2009 at 1:26 PM, Andrew <[email protected]> wrote:
> > I am trying to set up pub-sub between 1 publisher and multiple
> > subscribers using Rhino Service Bus. However, all I ever seem to get
> > is competing consumers (where messges are distributed between 1
> > consumer or the other, but not sent to both).
>
> > My current publisher configuration looks like this (Note: I'm using
> > the new OnewayRhinoServiceBusFacility so I don't need to define a bus
> > element in the sender)
>
> > <facility id="rhino.esb.sender" >
> > <messages>
> > <add name="My.Messages.Namespace"
> > endpoint="msmq://localhost/my.queue"/>
> > </messages>
> > </facility>
>
> > My subscriber configuration looks like this:
>
> > <facility id="rhino.esb.receiver" >
> > <bus threadCount="1" numberOfRetries="5" endpoint="msmq://
> > localhost/my.queue" DisableAutoQueueCreation="false" />
> > <messages>
> > <add name="My.Messages.Namespace" endpoint="msmq://
> > localhost/my.queue" />
> > </messages>
> > </facility>
>
> > This works fine and dandy for 1 publisher and 1 subscriber. However,
> > what I want to acheive is 2 subscribers listening to the same message
> > and each receiving their own copy of the message. So, I just copied
> > and pasted the subscriber exe and config file file to create my second
> > subscriber. I've tried various config settings but no matter what I
> > do, I only end up with competing consumers.
>
> > I would've assumed that I could define a different endpoint for each
> > receiver bus (and leave the messages element above still pointing to
> > "msmq://localhost/my.queue"). In this way, each receiver can have
> > their own queue. I.e. the configuration for the subscriber looks like:
>
> > <facility id="rhino.esb.receiver" >
> > <bus threadCount="1" numberOfRetries="5" endpoint="msmq://
> > localhost/my.subscriber1" DisableAutoQueueCreation="false" />
> > <messages>
> > <add name="My.Messages.Namespace" endpoint="msmq://
> > localhost/my.queue" />
> > </messages>
> > </facility>
>
> > But, if I try to do this, I don't receive any messages at all (even
> > though from the log files, it looks like it's doing the right thing).
>
> > This must be possible so I'm sure I've missed something obvious here.
> > Any help much appreciated.
>
> > Cheers
>
> > --
>
> > You received this message because you are subscribed to the Google Groups
> > "Rhino Tools Dev" group.
> > To post to this group, send email to [email protected].
> > To unsubscribe from this group, send email to
> > [email protected]<rhino-tools-dev%[email protected]>
> > .
> > For more options, visit this group at
> >http://groups.google.com/group/rhino-tools-dev?hl=.
>
>
--
You received this message because you are subscribed to the Google Groups
"Rhino Tools Dev" group.
To post to this group, send email to [email protected].
To unsubscribe from this group, send email to
[email protected].
For more options, visit this group at
http://groups.google.com/group/rhino-tools-dev?hl=en.
