Ayende,
No joy with renaming them, I'm afraid.
Producer code:
--------------
var container = new WindsorContainer(new XmlInterpreter
("RhinoEsbSettings.xml"));
OnewayRhinoServiceBusFacility facility = new
OnewayRhinoServiceBusFacility();
container.Kernel.AddFacility("rhino.esb", facility);
var bus = container.Resolve<IOnewayBus>();
while (true)
{
MyMessage msg = new ....
bus.Send(msg);
Console.ReadLine();
}
Consumer code:
--------------
static void Main(string[] args)
{
var container = new WindsorContainer(new XmlInterpreter
("RhinoEsbSettings.xml"));
container.Register(Component.For<ConsumerOf<MyMessage>>
().ImplementedBy<MyConsumer>().LifeStyle.Transient.Named
("SomeConsumer"));
RhinoServiceBusFacility facility = new RhinoServiceBusFacility();
container.Kernel.AddFacility("rhino.esb", facility);
var bus = container.Resolve<IStartableServiceBus>();
bus.Start();
Console.WriteLine("Ready to receive messages");
Console.ReadLine();
}
....
public class MyConsumer : ConsumerOf<MyMessage>
{
public void Consume(MyMessage message)
{
Console.WriteLine("Received message");
}
}
Thanks again,
Andrew
On Nov 24, 3:48 pm, Ayende Rahien <[email protected]> wrote:
> 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.
