message-queue

Send Message to remote PC in local network

Hello friends. How can I in c# send Message box to remote computer? I have credentials of remote PC and know PC name. Can use for this purpose WMI? ...

[RabbitMQ] Use it for JSON data transfer

I am trying to use RabbitMQ for a distributed system that would work something like: a producer puts in a queue a JSON-formatted list of order ids several consumers pull out of that queue, do the business logic with that order ids and the result (JSON formatted) as well is put back into another queue from the second queue, another cons...

Database connection/update mechanism for continuous data

I am working on system where there are huge (2000-5000 records per minute) amount of incoming events which have to be recorded in the database (SQL server 2000). We are using ODBC connection to connect with the database. Currently we open a single connection during the app startup and push the data using the connection since we won't be...

MessageQueue.Exists returns true for one site, false for another!

I have two websites running on the same IIS instance on the same 2008 R2 server, both sharing a common messaging assembly that attempts to log messages to a messagequeue on the server. They're both calling the same method, which in turn calls System.Messaging.MessageQueue.Exists(QueueName); Where QueueName is the correct (and 100% pai...

MessageQueue + ObjectDisposedException + .Net 4.0

Hi, I have implemented a dispose pattern in a class model which uses MessageQueue. My class A where all objects from class B must register to contains a Dictionary with MessageQueue objects. This works all fine. Objects from class B can be collect by GC and the dispose pattern, which let each object from class B sent a last message duri...

How to retract a message in RabbitMQ?

I've got something like a job queue over RabbitMQ and, upon a request to cancel a job, I'd like to retract the tasks that have not yet started processing (their messages have not been ack'd), which corresponds to retracting these messages from the queues that they've been routed to. I haven't found this functionality in AMQP or in the R...

Windows Messages in Library Code

I am porting a library to Windows. In a function I need to block on the arrival of a WM_DEVICECHANGE message. What options are available for doing this? As my code resides in a library I have little-to-no information on the current set-up (so if it is a Console application, a regular GUI application, if my code is being run in a spawn...

Zend sending email

hi all, i have a project that need to send email. and i use zend as my framework. i use XSL for email templat and save email parameter as array that will turn to XML before send the email. i create my own implementation multithread class utilize CURL for sending email. any better development approach for queue & sending email ? ...

Other than strings what can i pass to message queue?

At very high level i would like to know apart from strings what (information) can i pass to Message Queues in C#.NET. Simply to say that what are all things that can i can pass/send to a message queue by preparing a message. ...

different Target format types of XmlMessageFormatter

What are the different Target formats with respect to System.Messaging.XmlMessageFormatter(....) in C#.NET As i'm well known about receiving data in terms of string formats. I would like to know the format target types other than strings in System.Messaging.XmlMessageFormatter(.......) while receiving the result from message queues. Pl...

Can message-oriented middleware be used instead of MPI to coordinate distributed computation?

By message-oriented middleware I am referring to technologies such as Advanced Message Queuing Protocol. Obviously AMQP is a different beast than MPI, but I would think distributed-memory computations that operate in a master-slave manner could be trivially implemented using AMQP, letting AMQP handle equitable work distribution to sla...

How do I call other Controllers within a Zend Framework Process and retrieve their rendered view?

Hi there, I have the following setup: An endless running PHP process that looks at a job queue which contains module names, controller names, action names and a parameter array. For every job I want to call the given controllers action and retrieve the rendered view for further processing. I was thinking about bootstrapping an instan...

MSMQ messages bound for clustered MSMQ instance get stuck in outgoing queues

We have clustered MSMQ for a set of NServiceBus services, and everything runs great until it doesn't. Outgoing queues on one server start filling up, and pretty soon the whole system is hung. More details: We have a clustered MSMQ between servers N1 and N2. Other clustered resources are only services that operate directly on the clus...

Apache qpid queue url

I'm trying to learn more information on how apache Qpid works and I do so by following examples from official svn : http://svn.apache.org/repos/asf I was looking at : http://svn.apache.org/repos/asf/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/Hello.java Which uses this configuration/property file : htt...

How to pause a Thread's Message Queue in Android?

I am queuing up a bunch of runnables into a thread via a Handler.post(). I would like the ability to send a note to that thread that it should pause. By pause I mean, finish the runnable or message you are currently working on, but don't go to the next message or runnable in your message queue until I tell you to continue. ...

MQ HTTP payload delivery?

I'm planning a new system heavily reliant on MQ (unknown implementation at this time). Most of my MQ experience is IBM MQ Series and OS/400's data queues but in nearly every case we polled the queues, or wrote a broker to poll and deliver. There are lots of MQ systems out there now. Instead of writing a broker to poll and deliver, are...

How do I run system wide operations on a cluster of app-servers?

I am running my application on a group of unclustered tomcat servers. It serves restlet web-services. As per restful paradigm, each call is stateless. In this environment, I want the application to periodically review the database for status changes and take action. Since one of the actions is to fire off an email, I want to ensure t...

Using RabbitMQ with nServiceBus (for C#) vs using Amazon SQS

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 ...

Does WaitForMultipleObjects cause problems in a thread creating STA COM objects?

I have a thread which creates COM objects that use the STA model. This thread's Run function puts it in an infinite WaitForMultipleObjects. Is it possible that the infinite WaitForMultipleObjects could prevent other threads from marshaling calls to the COM objects owned by this thread? Basically, I'm asking if WaitForMultipleObjects ...

MsgWaitForMultipleObjects sometimes returns WAIT_FAILED with no GetLastError value

I have a thread that creates COM objects that require a single threaded apartment. Originally, this thread's main function put it into a WaitForMultipleObjects loop. Evidently this is a problem, because it prevents the COM message pump from doing it's job. I replaced this with MsgWaitForMultipleObjects as a solution, but now I'm runnin...