Background: We have a bunch of Windows apps that need to be integrated. We think a publish-subscribe IPC mechanism/library would do the trick. Inter app Events don't need to be persisted; Not all apps are written on .NET but those that aren't have a plug-in architecture that allows for extending in .NET The apps are run by users on a T...
Are handlers reused to proceed another message? public abstract class SomeHandler : IHandleMessages<MyEvent> { public IBus Bus { get; set; } public String Message { get; set; } public void Handle(T message) { Message = "Test"; SomeInstanceMethod(); } public void SomeInstanceMethod() { ...
I have a solution that uses NServicebus which contains at least 3 projects that are of interest for this scenario; a publisher, a sweep, and a webservice. Basically the sweep(s) gather data for the publisher to store in a database and then publish to subscribers. The webservice gives access to the data stored in the publishers database. ...
Is there any way to intercept messages in NServiceBus? From now i can do it manually via introducing base message handler like this: public abstract class MessageHandler<T> : IHandleMessages<T> where T : IMessage { public IBus Bus { get; set; } protected abstract void HandleCommand(T command); public void Handle(T com...
I have this code in my app .NET application using NServiceBus: Bus.Send<IServiceStarted>(e => { e.ServiceInfo = ReadServiceInfo(); e.EventTime = DateProvider.Now; }); How would you go about unit-testing such a...
If I understand correctly, I can use nServiceBus as a "framework" and / or a wrapper around RabbitMQ My preference of RabbitMQ is being able to use it on linux machines Background I have an application that enables people to upload images. These images will require thumbnails. Our application is predominantly asp.net (c#) My idea is ...
Used Version of NServiceBus: 2.0.0.1145 Question: Is it possible to configure a NServiceBus in such way that, it consumes (subcribes to) his own published messages? Answer: It seems possible, but in the following Configuration it gives me a Transaction deadlocked Exception while trying to insert Subscriptions into the SubscriptionSto...
In the NServiceBus interface, why are some things configured like this: NServiceBus.Configure.Instance.Configurer.ConfigureComponent(ComponentCallModelEnum.Singleton); And some things are configured like this: NServiceBus.Configure.With().DoNotAutoSubscribe(); What is the significance of "Instance" here? ...
Hi , I am using request reply model of NServiceBUs for one of my project.There is a self hosted service bus listening for a request message and reply back with a request message. So in WCF message code i have coded like // sent the message to bus. var synchronousMessageSent = this._bus.Send(destinationQueueName, requestMessage) ...
I have two subscribers listening to a publisher.All th queues are on the same machine.To make subscriber power off i deleted the input queue of one of the subsriber. I am getting one exception in the generic host command output and no meesages are there in the Outgoing Queues. Is this behaviour is coz all things are in the same machine ?...
I have recently read some articles about service buses and would like to to give it a go. Googled to find a good beginner tutorial on NserviceBus, bug could not find a one so far. Anyone aware of a good beginner tutorial on NServiceBus? (to start from very basic level) seen some literature on internet, but they do not seem to be begi...
Does NServiceBus automatically attempt to redeliver messages if handling fails? And if it does, is there a limit in the number of times delivery can be attempted? ...
When I try to run the NUnit unit test for the FullDuplex sample I get the following exception. I am using the NServiceBus version for .NET Framework 4. I have not changed anything in the sample (other than to convert to VS2010 and change the .NET Framework version to 4.0 so it can use the .NET 4 binaries), and I am new to probably all of...
Hi, I am starting a nsb saga using IAmStartedByMessages. On the handle of this particualr message i am doing some kind of business logic if some cases fail i don't want the Saga to be persisted. How can i achieve this? Thanks, Ajai ...
Hello, Another question on "Using NServiceBus with Asp.Net MVC 2" (http://stackoverflow.com/questions/3668648/using-nservicebus-with-asp-net-mvc-2) thread. Udi has replied saying following method can be used if we really want to do it. var sync = Bus.Send<SomeMessage>(/*data*/) .Register((AsyncCallback)delegate(IAsyncResult...
Hi, I am using the pub sub model of nservicebus. I have the following situation My publisher is hosted a wcf web service and publishes the message.Thw wcf web config look like <!--NSB configurations--> <MsmqTransportConfig InputQueue="Pubque1" ErrorQueue="error" NumberOfWorkerThreads="1"+ MaxRetries="5" /> And i am having one...
Scenario: I'm using NServiceBus with MSMQ Transport. I have messages from an app dropped into QUEUE-A. I have a NServiceBus Gateway grab messages from QUEUE-A and send them to another Gateway I the Destination Gateway receives the messages and places them into the respective queue. Source Gateway throws a Null Reference Exception and...
Hi, I am trying to use synchronous send/reply from the handler function of the generic host windows service as below. But I think NServiceBus will send the message only after completing the handle function(during the current transaction complete). So below code will hang in ‘synchronousHandle.AsyncWaitHandle.WaitOne()’. What should be ...