message-queue

Approaches for Orchestrating Message Queues

Hi folks. I'm looking for some different perspectives for orchestrating messages through a number of message queues. For orchestration steps, would prefer to avoid some of the hard coded xml file solutions that are out there. Not BPEL; as the workers are not soap services. I was thinking of something a bit more dynamic such as defin...

How to provide a cross platform, asynchronous service interface

What is the best way to provide an asynchronous service interface to multi-platform (primarily java and .net) clients? The backend service is implemented in java. We are looking at asynchronous web service and message queues, but apparently cross platform asynchronous web service* is not supported yet in java (as far as I know) and fo...

How do I inject a message into Postfix's queue?

I am working on an application that quarantines and routes email. Let's say in this application that I have an email message in a directory of my choosing and it has been scanned by our software and is considered "clean". How do I inject this message back into Postfix? ...

Distributed data structures in Java

I'm going to develop my own message queue implementation in Java and I need to distribute the queue content across multiple servers so that it would provide reliability and redundancy. In addition to that I need to persist the queue content into the file system. Can somebody tell me what is the most suitable distributed data structure...

Reading DLQ from WCF Service with MSMQ 4.0

Hi folks, i want to write the web service that will be read messages from DLQ. As i understand if the message can not be delivered(there are other cases such as timeout, authentication etc.) from Client to Service, then message will be placed to DLQ(in this case i use custom DLQ), and DLQ Service will be called automatically. I wrote t...

Filtering messages in WPF application

Windows Forms have the IMessageFilter interface to capture messages. How is this done in WPF? Specifically, I want to create a clipboard format listener. ...

How can you read the count of an MSMQ on another machine?

My program is successfully using .NET's MessageQueue class to read from an MSMQ. The queue is user configurable, and is sometimes on the local machine, and sometimes on a remote machine. The user can specify the remote machine either by name or IP address, and the queue name (and I'm only using "Private" queues). I want to display to ...

What mechanism do PIPES use to "wake up" the recipient?

I have two questions is one here. On Windows, I am familiar with pipes and how they work. However, I am curious as to what mechanism the OS uses to notify the recipient thread of a message arrival. Does the thread "poll & sleep" continuously for data? Does the OS check to see if the thread is sleeping and wake it up? Or is there some o...

Looking for an optimum multithread message queue

I want to run several threads inside a process. I'm looking for the most efficient way of being able to pass messages between the threads. Each thread would have a shared memory input message buffer. Other threads would write the appropriate buffer. Messages would have priority. I want to manage this process myself. Without getting in...

Authentication client-server using message queues in c language

Hi all ... I'm working on this project about how to develop authentication server that serves multiple clients at a time the client gives the name and password as request and the server authenticates the request and returns the result ... ALL communications between client and server should use message queues techniques ...and i want it ...

beanstalkd c client library

We are going to implement a fairly complex new service in an asynchronous way, introducing asynchronous processing as well. For this, we have selected beanstalkd message queue service, as it fits best for our needs. The problem is that beanstalk seems to miss client API in C, at least I have failed to find it. I do not want to invent t...

What is the Message Id (IEF...? maybe) for a circular wrap file

Is there a Standard Message ID that is sent to the Syslog when a circular file 'wraps' and new records start overwriting the oldest records at the beginning of this circular file? jimpa ...

How to pass complex objects ( std::string ) through boost::interprocess::message queue

Does anybody have some example code showing the pipeline of serializing a std::string sending it through a boost::interprocess::message_queue and getting it back out again? ...

What is best practice technique for scalable, routine processing of a large user base?

Suppose you have a database of users, which is constantly moving, and getting big. You want to do something to each user, every 24 hours, without fail. It doesn't matter what that something is, maybe send them each an email, or maybe something more complex that takes an unpredictable length of time. For a small site, I can imagine a sim...

How to selectively delete messages from an AMQP (RabbitMQ) queue?

I'd like to selectively delete messages from an AMQP queue without even reading them. The scenario is as follows: Sending side wants to expire messages of type X based on a fact that new information of type X arrived. Because it's very probable that the subscriber didn't consume latest message of type X yet, publisher should just delet...

I need a message/queuing solution for my web-based system

Hi, I am looking for a message/queuing solution for my web based system running on Ubuntu. The system was built on the following technologies: Javascript (Extjs framework) - Frontend PHP Python (Daemon service which interacts with the encryption device) Python pyserial - (Serial port interactions) MySQL Linux - Ccu...

JMS message re-delivery delay

I have a JMS client that can ssh to remote systems upon receiving a message (and do various things there - not relevant to the question). It is possible that hundreds of such messages will arrive in a short period of time which need to be processed ASAP. However, it is also possible that certain remote systems are not available when the...

Error occured while trying to use Nservice bus

Hi guys, I am new to NServcie bus and Im was trying to implement Publication and subscription of messages .This is the error I'm getting Exception when starting endpoint, error has been logged. Reason: The destination queue 'mygateway' could not be found. You may have misconfigured the destination for this kind of message (NServiceBu...

MantaRay opens 3 TCP connections on the same port.

Another problem with mantaray: We have "a lot" of PCs in a network, our p2p messaging software uses MantaRay (which we plan to replace with something else). On some PCs the task manager shows CPU at 100% when this application runs. We tried to investigate that with TCPView, and found that these PCs open more than one TCP connection from...

RabbitMQ Message Queue Exists or Not

How Can i check whether a message Queue already exists or not.. Reason for this is i have 2 different applications one creating a queue and other reading from that queue..So if i run the Client which reads from the queue first than it crashes. So to avoid that i would like to check first whether the queue exists or not ...