In my message publisher configuration I have <MsmqTransportConfig InputQueue="EnformMessages" ErrorQueue="error" NumberOfWorkerThreads="1" MaxRetries="5" /> <UnicastBusConfig ForwardReceivedMessagesTo="testqueue@cgy1-web01"> <MessageEndpointMappings> <!-- publishers don't need to set this for their ...
We've just newly decided to use NServiceBus on our project and we're experiencing some problems. Rather than "ask for a fish" every time we hit an issue, we'd prefer to "teach ourselves to fish". This means setting things up so we can step into the NServiceBus source code and understand NServiceBus more deeply. We need some help figurin...
Hi All, I have created my own custom subscription store for NServiceBus via my own ISubscriptionStorage class but I cannot find how to implement it and cannot see any documentation on how to do so. Is there anyone out there who can give me a hand? Cheers ...
I have been trying to get nServiceBus to work with Ninject 2.0 as the underlying IoC container unsuccessfully. While I can achieve basic integration, I've had issues with "ghost" messages getting sent to the various subscribers. I used the Autofac implementation as a template of sorts, replacing the necessary pieces with Ninject-specif...
Is the communication bi-directional in NServiceBus? a subscriber can also publish/send message? ...
We are planning to use NServiceBus in our application for dispatching messages. In our case each message has timeToLive property, defining period of time, in which this message should be processed. For the case if message handling was unsuccessful in first attempt, our plan is to move it to specific retry storage (retry queue) and than ...
Is it possible to use NServiceBus to publish and consume messages in the same application, specifically a web application? In the future we will almost certainly need to maintain a separate long running service to process messages generated by this application, and this is why we are hoping to use NServiceBus from the start, but right ...
I am not sure where the distributor/s should run when there is a number of clients and a number of servers. If I have a single distributor which all clients send to and all servers get work from then surely it is a single point of failure. Is there a way to remove this weak point? ...
Hi. I'm getting started with NServiceBus and have a question about the Pubsub sample. My intention was to have multiple instances of Publisher1 running and receiving the message sent from the publisher. I also hacked the Publisher to only send messages of the eventMessage type. But if I start the publisher and three instances of Subscr...
In a test project based of the nServiceBus pub/sub sample, I've replace the bus.publish with bus.send in the server. The server sends 50 messages with a 1sec wait after each 5 (ie 10 burst of 5 messages). The client does not get all the messages. The soln has 3 projects - Server, Client, and common messages. The server and client are ho...
Update: Ok, after getting past the fact that I did not have MSDTC set up as a cluster resource (doh!), I was able to run my program and all appeared well, but I was not able to successfully send messages to it. After digging I found that while the private queues were created on one node of the cluster, they were not on the other node (I...
When I subscribe as the recipient of a certain type of message using NServiceBus Bus.Subscribe<MyMessage>() What am I actually doing? Am I specifying that a particular method on the recipient type will be invoked upon message receipt? If so, within what context does the method run - in a static context, or within the context of a new'...
I have a MessageHandler with a dependency declared as: public IRepository<Person> PersonRepository {get;set;} I set up my Unity container with: IUnityContainer container = new UnityContainer(); container.AddNewExtension<Interception>(); container.RegisterType(typeof(IRepository<Person>), typeof(Example.Data.InMemory.Repository<Perso...
I am looking at various options for a WCF based publish subscribe framework. Say I have one WCF web service that will be the publisher and 1000 clients registered as subscriber. For some published messages all clients will be interested but at the same time I wish the ability to notify a single client with a specific message. On receivin...
I'm trying to use StructureMap with nServiceBus. The Project: Uses a GenericHost Endpoint to send command messages Configures nServiceBus using the StructMapBuilder. Uses a simple StructureMap registry config Uses a start up class TestServer supporting IWantToRunAtStartup The TestServer class has ctor dependency on a TestManager clas...
I have WCF Per-Call service wich provides data for clients and at the same time is integrated with NServiceBus. All statefull objects are stored in UnityContainer wich is integrated into custom service host. NServiceBus is configured in service host and uses same container as service instances. Every client has its own instance context(d...
I use the following: public interface IRepository<T> { void Add(T entity); } public class Repository<T> { private readonly ISession session; public Repository(ISession session) { this.session = session; } public void Add(T entity) { session.Save(entity); } } public class SomeHandler : IHandleMessages<SomeMe...
I am trying to set up NServiceBus to use a remote error queue to ease the management of checking for errors. When I do this, I get the following error when NServiceBus.Host.exe starts up: 2010-03-25 07:59:50,103 [1] ERROR NServiceBus.Utils.MsmqUtilities [(null)] <(null)> - Could not create queue error@C0NSERVICEBUS or check its exis...
I want to achieve something similar to the webservice bridge sample but i don't want to wait for a response from the webservice. I want the call to be asynchronous. What is the best way to do this? Should I just use the webservice bridge and call ProcessAsync as opposed to Process? or Should I not use the webservice bridge and just crea...
So it's easy to load balance an ASP.NET web application. You set up a load balancer between two servers, and if the web server isn't responding on Port 80, it won't receive requests. Are there any proven techniques for doing this for a C# console application or Windows service that takes actions of its own volition? Are there any fram...