c# - multi-threading based RabbitMQ consumer -


We have a window service that listens to the same rabbit MQ queue and processes the message.

We would like to extend the same window services so that it can listen to many quotes of RabbitMQ and process the message.

Using multi-threading, it can not be ensured that each thread has to be queued (blocking).

As I am very new to multi-threading, I need high level guidelines at the bottom point, which will help me start building prototype.

  1. Is it possible to hear many queues in a single application using threading?
  2. How to handle such a situation where a single thread was sown (due to exception etc.), how to get the entire window back without restart services.
  3. Any such design pattern or open source implementation which can help me handle such a situation.

    4. I like how you wrote your question - it started very broad and special I have successfully implemented something very equally, and currently working on an open-source project so that my lessons can be learned and able to return to the community. Unfortunately, though- I have not prepared my code neatly to package, which does not help you much! However, to answer your questions:

    1 Is it possible to use threading for many queues?

    A: Yes, but it can be full of loss, namely, the rabbit MQ. The NET Library is not the best written piece of the code, and I found it to be a relatively lenient implementation of the AMQP protocol, one of the most deadly warnings is how to handle "receiving" or "consumer" behavior, which is careful If not, the deadlock can cause a lot easier. Fortunately, this is well illustrated in the API documentation. Advice - If you can, then use a single connection object then, in each thread, use a new IModel and connection to create a related user Please.

    2. How to handle exceptions in threads - I believe this is another topic and I will not tell it here because you can use it in many ways.

    3 Any open source projects? - I like the rear thinking, although I have finished my own rolling. I hope that when my open source project has been completed it will have to come back, because I think it is better than EasyNetQ.


Comments

Post a Comment

Popular posts from this blog

ios - How do I use CFArrayRef in Swift? -

I am using Objective-class in my Swift Project through a bridging header. The method signature looks like this: - Some cement (some type) some parameters; I started by getting an example of class, calling method, and storing the value: var myInstance = MyClassWithThatMethod (); Var cfArr = myInstance.someMethod (some value); Then try to get the value in the array: var valueInArrayThatIWant = CFArrayGetValueAtIndex (cfArr, 0); However, I get the error unmanaged & lt; Cfarray & gt; Not like 'CFArray' . Unmanaged & lt; Cfarray & gt; also means? I looked, but I do not need to change the array in a fast array (though it would be good). I need to be able to get value from the array. I also tried CFArray method to pass in a function: func doSomeStuffOnArray (myArray: NSArray) {} Although I get the same error when using: doSomeStuffOnArray (cfArr); // unmanaged & lt; CFArray & gt; I am using CFArray because I want to sto...
Read more

eclipse plugin - Run java code error: Workspace is closed -

To create an automated project, I created a plug-in project with the following dependencies: Org.eclipse.core.resources org.eclipse.equinox.registry org.eclipse.core.runtime and the following The Java class is located in the src folder: Package Examiner; Import org.eclipse.core.resources.IProject; Import org.eclipse.core.resources.IWorkspaceRoot; Import org.eclipse.core.resources.ResourcesPlugin; Import org.eclipse.core.runtime.CoreException; Import org.eclipse.core.runtime.IProgressMonitor; Import org.eclipse.core.runtime.NullProgressMonitor; Public class tes {public static zero main (string [] args) {// TODO auto generated method stub IProgressMonitor progress monitor = new NullProgressMonitor (); IWorkspaceRoot root = ResourcesPlugin.getWorkspace (). GetRoot (); Ipoject project = root.jetproject ("desired projectname"); Try {Project.create (progress monitor); Project.open (progressMonitor); } Grip (CoreException E) {// TODO Auto generated blocking block e....
Read more

c - Error on building source code in VC 6 -

When I create my project in VC6, the BScMKE reports the following error Linking .. Creating Library ... .. / ... / PB / Bean / Debub / ICEERP.Lib and Object ........ P.B. / Bean / DBube / ICREPlay.APP Browse information file ... BSMMK: ​​error can not be read from BK 1505: file '../../PB/bin/TmpOut/ICReplay/Debug/ICReplay_PB.bsc' Error executing bscmake.exe Can someone help me? 2 Reason for reference from: "ICReplay_PB .bsc "file will be corrupted The trunk of the file will be happening with the compiler running out of disk space or is being interrupted when creating .sbr file I think this answer will help you!
Read more