message-queue

Multiple consumers & producers connected to a message queue, Is that possible in AMQP?

I'd like to create a farm of processes that are able to OCR text. I've thought about using a single queue of messages which is read by multiple OCR processes. I would like to ensure that: each message in queue is eventually processed the work is more or less equally distributed an image will be parsed only by one OCR process An OCR pr...

Using Message Queue on Windows Mobile 2003

Does anyone know where I can find the cab file that will allow me to use Microsoft Message Queues on a Windows Mobile 2003 device? I am writing application that needs to use Microsoft Message Queue on a Windows Mobile 2003 device. Apparently message queue was never installed on the device. I have scoured the web and can find no cab fi...

Potential pitfalls in using a JMS queue?

I've been asked to design and implement a system for receiving a high volume of automated sensor data from a large number of devices. This data will be produced at regular intervals and sent to the server as xml in an http post. The devices will keep resending the same data if they don't receive a specific acknowledgment from the server....

JBoss 5.1.0 Adding Queues

How do I add custom queues to JBoss 5.1.0? I found a way to do it via the Admin Console however for some reason it keeps failing, also I need to be able to quickly and easily move my queues from one JBoss Server to another. So basically I was wondering if there is a way to create custom queues in an xml file and add that file to the d...

Messaging System in .net

Hello, We have a Message broker application in Java which accepts messages(XML). It validates the XML against XSD and calls a .net Webservice and passes the validated XML. We have a requirement to do the same in .net. Do we have any API's to do this one. I am looking for a system that takes care of logging in case of errors or some kind...

C: Is there something better than a FIFO Queue implementation for this requirement?

In one of my programs, there are multiple clients and each client has its own buffer. In an infinite loop, I check if any of the client has any data to be written to disk. If it does, then I do the same and continue. Now, because the client writes data that is not really in my control (result of some computations), I need a dynamic buf...

zeromq/AMQP plugable?

[1] I was reading through the AMQP standard, and it seems that there is a clear separation between the exchange, queue and binding component. However, looking at the zeromq docs, it doesn't seem as if zeromq allows you to plug in your own exchange/queue/bindings implementation. [2] Also, is there any AMQP framework available where I don...

Retrieve messages from RabbitMQ queue(s)

Hey guys, I'm looking to implement RabbitMQ into my PHP application, and am using the php-amqp extension. My only question is this, how do I easily query to return the contents of the queue in PHP? php-amqp seems to not enable me to do this. If I am going wrong, please help me out here :) ...

Can txAMQP unbind in RabbitMQ?

I want to remove bindings in RabbitMQ without deleting the bound queue. I am using txAMQP with the 0.8 AMQP spec; it seems to be the only version that RabbitMQ supports but it has no unbind method. Oddly enough, a perusal through the source code suggests that RabbitMQ supports unbind, which leaves me rather confused. Can I unbind with ...

Options for Non-Locking Messaging from within a SQL Server Transaction

I maintain a SQL Server-based application that requires us to send notifications of certain database changes to connected clients. These clients are fat-client C++ apps with high-bandwidth connectivity to the server. Up until this point, we've been using a dedicated messaging table in SQL Server which is updated via triggers on the rel...

Help me understand how message queuing works

Been using PHP for quite some time now and I was wondering what this whole "message queue" is all about. Let's take facebook for example. I can update my status but then I have to show that status updates to all my friends (let's say I have 3000 followers). Even more work if there are comments and they have to be notified to all friends ...

Writing to SQL Server using MessageQueue from web application

Hi Folks, I have to write some information to SQL Server from a web application. But to minimize the delay I want it to be asynchronous operation using Message Queue. I can create a Queue and post a Message (xml serialized object to be stored) to the queue. What do I need to do to write that message from Queue to database? ...

Stats/Monitor/Inspector for beanstalkd

Does anyone know of an app that can monitor a beanstalkd queue? I'm looking for something that shows stats on tubes and jobs, and allows you to inspect the details. I'm not really picky about language/platform, just want to know if there's something out there before I write my own. ...

Rabbitmq or Gearman - choosing a jobs queue

At work, we need to build a jobs server for things like sending emails, building PDFs, crunching some data, etc. Obviously, we'd like to build on some sort of generic queueing system. I'm familiar with Gearman, and that this is exact problem that it tries to solve: putting jobs on a queue where workers come to pick them up. However, I'...

Message Queue Task in SSIS is stuck.

I'm using message queue task in SSIS to receive message from a private queue, I set MessageType To "String message to variable" and Compare to "None" When I debug on this package, it's stuck at message queue task, I've checked the private msmq, there are some messages in it. Any ideas/Help? Thanks ...

Message queue system

Hi, I am in the process of writing a message queue system. My question is... Is it better to do this queue with files or in a database? If I were to choose the database, it needs to check for new jobs every second and that just seems a bit of an overhead to me? If it's files I guess you just constantly monitor the folder and execute ...

jboss-esb fs-listener jbm message queue overflow

Hi, We have a jboss esb server which is reading files from the file system in a scheduled way (schedule frequency of 20sec) and convert them into the esb message then we parse the message. There are some other providers/listeners (jms) and services configured on the esb servers. When there is an error in one of the services it effects t...

Strategy for Reporting on JMS Activity

The answer to this question may be obvious to someone with more experience in data-warehousing and BI, but I am looking for some guidance. I'm building a system that uses multiple JMS queues to process millions of messages per day. I need visibility into the activity of these queues, so that I can create reports like..."Yesterday at 11...

Blocking WM_QUIT

Quick question. I have an app that use a native DLL through PInvoke, this DLL may call a PostQuitMessage(). How can I avoid it? (as my app should not close) I tried AddMessageFilter, but it doesn't trigger the WM_QUIT. ...

Windows Game Loop 50% CPU on Dual Core

The game loop alone is using 50% of CPU Usage, I haven't done any rendering work yet. What i'm doing here? while(true) { if(PeekMessage(&msg,NULL,0,0,PM_REMOVE)) { if(msg.message == WM_QUIT || msg.message == WM_CLOSE || ms...