I need to create asynchronous message queues dynamically in Java. My use case is sending email via multiple SMTP servers: I need to enforce that emails to the same SMTP server are processes sequentially, but emails to different SMTP servers may be processed concurrently. I've used JMS in the past, but as far as I can see it only allows f...
I am currently using a shared hosting web server, and am trying to set up a queue system which my main web site will post messages to. Then I will use something else (probably a cronjob) to process items in the queue. I need something that is secure, so that other users on the machine cannot use my queue. The memory footprint should be ...
I am looking for a message broker (like Apache ActiveMQ for Java) that works with PHP, preferably open-source. Any ideas? ...
Is there any example of using JMS Queues in BlazeDS as point-to-point communication to a Flex client. I'm curious in writing a custom MessageAdapter for BlazeDS that is adapting a point-to-point message queue system and I want to understand how it works for JMS Queues which are point-to-point. The BlazeDS documentation describes JMS Qu...
Hi, I have a message queue from which I am getting messages in a loop. The problem is that I don't know how to exit the loop. msgrcv returns type size_t so it keeps going. What value should I compare the return value so I can exit the loop? while(msgrcv(msqid, &msgreceived, sizeof(msgreceived), BUFFER_CHANGED, 0) != -1){ printf("%d %d ...
I need a simple table that acts as a Queue. My MySQL server restriction is I can't use InnoDB tables, only MyISAM. Clients/workers will work at the same time and they will need to receive differents jobs each time. My idea is to do the following (pseudo-code): $job <- SELECT * FROM queue ORDER BY last_pop ASC LIMIT 1; UPDATE queue SET...
I've written a multi-threaded WTL util to stress test an in-house service. Comms threads signal to the main thread that they've quit, so the main thread can delete their corresponding object. They make the signal as so: PostThreadMessage(m_dwParentThreadId, WM_THREADQUIT, 1, m_dwNetThreadId); My problem is how to deal with the custo...
I am wondering what are the limitation of System-V message queue i.e. Maximum queue size, maximum size per item etc. As I am working on integration of C++ with my PHP scripts and have very large amount of data which will be pushed into queue from php and C++ process will read that data on the other end. I have devised an strategy in whi...
Hi all, I'm encountering some problem with ActiveMQ 5.3. We have the following setup: - A master-slave pair ('master' and 'slave') - A broker ('broker') that forwards messages to either 'master' or 'slave', depending on who is active The symptom I see: When I start 'master', 'slave' and 'broker' messaging works as expected: When I publ...
What message oriented middle ware with a Python API are out there? What ones did you use and recommend (or not)? ...
How do I setup a message queue that automatically sends all it's messages to another server? I'm working on a proof of concept for a system that needs to run on multiple servers, writing to local message queues, then have a central service on another server running that reads its local queue to pick up all the messages from the other se...
Is there anything built into MassTransit that can help manage the queues? I'm specifically thinking of the error queues. I saw the thread similar to this, but I'm not looking to manage it with a utility, but rather in code. Scenario: Web client - commands are published as messages with MT to a remote queue on an application server. ...
Is there any way to find out from threadId , if a thread has message queue or not? Basically there are some windows api which only work if a thread has message queue.window ...
Im currently writing a application where i need to let my other server queue base on request and after that, the application from my server send back a small data of whether it's finished, still queueing, how many percent, item id, etc... Is there any way i can accomplish this? since i dont want my other server to run another Http insta...
I'm using py-amqplib to access RabbitMQ in Python. The application receives requests to listen on certain MQ topics from time to time. The first time it receives such a request it creates an AMQP connection and a channel and starts a new thread to listen for messages: connection = amqp.Connection(host = host, userid = "guest", pass...
At work, we're building a distributed application (possibly across several machines on a LAN, possibly later across several continents on a WAN+VPN). We don't want log files local to each machine (filling up its disk and impossible to view in aggregate) so we need to centralize logging over the network. Most logs won't be important, so U...
A number of years ago I implemented an asynchronous peer-to-peer Message-Oriented-Middle-ware that was very friendly to use in Excel VBA, and I find myself again needing to do lots of calculations which could be trivially distributed, if I had the mechanism. I could re-implement the MOM layer, but I'd prefer to use a third party product...
I'm trying to implement a binary protocol between a flash application and a Custom Java Server using TCP/IP sockets, the protocol's messages are of variable length, so my idea is to add a field indicating the number of bytes I have to read before parsing a complete message, something like this: bytesToRead = socket.readInteger(); var bf...
I have a situation where a basic message, such as wm_paint, inside it's treatment will trigger a call WCF Webservices when, for example, it needs remote formatting information. However, while WCF is waiting for that call to return, messages keep being pumped, which can end up in another message triggering the same call. -Thread safety ...
We have a large project coming up soon with quite a lot of media processing (Images, Video) as well email output etc, the sort of stuff normally we'd put into a table called "email_queue" and we use a cron to run a script process the queue in the table. I have been reading a lot on Message Queue systems like beanstalkd, and have even se...