How are you setting up the container?
I _think_ that you need set the facility id to be rhino.esb alone.

On Tue, Nov 24, 2009 at 5:41 PM, Andrew <[email protected]> wrote:

> 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]>
> <rhino-tools-dev%[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]<rhino-tools-dev%[email protected]>
> .
> For more options, visit this group at
> http://groups.google.com/group/rhino-tools-dev?hl=en.
>
>
>

--

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.


Reply via email to