A recent presentation I saw regarding RabbitMQ mentioned the use of something called an "idempotency barrier" for message de-duplication. Is this just a fancy name for a message conflator or is it something more specific. If so, what exactly is it? A google search yielded results which are mostly related to RabbitMQ, with little explanat...
I am trying to extend a 3rd party application so that it can be invoked via command line in addition to using the windows form GUI (mixed mode is desired). It's a fairly simple program which basically loads a file and then you click a button it starts sending UDP network packets. I need to invoke the application from another and would...
I am looking for a .NET middleware system that covers message queueing, distributed caches, failover/redundancy. I'd prefer to look at a standards based commercial solution of some kind. What would you recommend? Anything available which from a company point of view has stood the test of time, which is highly likely to stay in business?...
I need to rejig some VERY old Windows code that uses Perl to talk to MQ. Specifically, I need to be able to install Perl's MQClient::MQSeries, MQSeries::QueueManager, MQSeries::Queue and MQSeries::Message modules. When I fire up Strawberry Perl, go into CPAN and try to install them, I can see that there's several MQ client DLLs that ar...
Hi guys, So my Java process communicates with a remote queue. What happens is at the end of every day, the sender channel on the receiving end is in a stopped state. Is there a way to start up that channel in Java, before accessing the remote queue? ...
I'm using an IPC queue to do process synchronization. I always get the EIDRM eror when sending an receiving messages from an IPC queue, but i can see that the queue is there with ipcs. I've been for 2 hours searching but i can't see the error. the following code is a stripped down version that gives me the same error. #define CLAVE ...
I'm familiar with MQJexplorer, but it's no longer under development and a bit clunky by today's standards. Is there anything better in this area, or would I have to roll my own? ...
I'm writing an embedded control system in C that consists of multiple tasks that send messages to each other (a fairly common idiom, I believe!), but I'm having a hard time designing a mechanism which: is neat is generic is relatively efficient most importantly: is platform independent (specifically, doesn't violate strict-aliasing or ...
Has anyone got a working code example of how to connect to the windows message queue(post/sendMessage) and log all messages there? Preferably in Python. I'm interrested in this to easier be able to create test-scripts that emulates user input. ...
I'm trying to replace a small homegrown messaging system, and are playing around a bit with zmq . I'll be needing to detect slow readers, and boot/disconnect them - slow readers pretty much meaning a particular consumer whos queue size is above a certain threshold. So far it seems zmq blocks every consumer if one of them is a bit slow (...
I am doing Comet chat with Erlang. I only use one connection (long-polling) for the message transportation. But, as you know, the long-polling connection can not be stay connected all the time. Every time a new message comes or reaches the timeout, it will break and then connect to the server again. If a message is sent before the connec...
Hi all, I have AMQ + Activemessaging running in a Rails App. I'm facing a problem with activemessaging not acting on messages when they are received. This is solved once i restart the client. Apparently, it works for a while but not sure when it stops acting weirdly. This is resulting in loss of messages as they are being read, the St...
Given: I load a queue of messages at page load. With jGrowl, how can I display each message, one message at a time, in a drip-like fashion? ...
Hi there, I'm currently designing an application which I will ultimately want to move to Windows Azure. In the short term, however, it will be running on a server which I will host myself. The application involves a number of separate web applications - some of these are essentially WCF services which receive data, and some are sites f...
I am trying out RabbitMQ with this python binding. One thing I noticed is that if I kill a consumer uncleanly (emulating a crashed program), the server will think that this consumer is still there for a long time. The result of this is that every other message will be ignored. For example if you kill a consumer 1 time and reconnect, th...
I have a simple JMS application deployed on OC4J under AIX server, in my application I'm listening to some queues and sending to other queues on a Websphere MQ deployed under AS400 server. The problem is that my connections to these queues are terminated/closed when it stays idle for some time with the error MQJMS1016 (this is not the p...
Whats is diffrence between classes org.jboss.jms.server.destination.QueueService and org.jboss.mq.server.jmx.Queue? ...
I have an Application layout that is based on a treeView at the left, and a panel on the right. The panel hosts a differnt TForm class depending on the tree node selected (a kind of 'form explorer'). There is only one form displayed at a time which exposes underlying data stored elsewhere and the form instance is created and destroyed on...
I send a message using the following code: var transaction = new MessageQueueTransaction()) transaction.Begin( ); var message = new Message { Body = myContent, Recoverable = true }; m_oMessageQueue.Send( message , myTransaction ); transaction.Commit( ); And receive it using a BeginRecieve and a ReceiveCompleted event hand...
I have the spring-flex-testdrive example (JMS chat application which uses a Topic to pub/sub messages) to work on Tomcat with ActiveMQ now I want to run this example on Glassfish with OpenMQ. This is a related sample config I found online but it doesn't quite work for the Flex/Glassfish/OpenMQ/BlazeDs/Spring-Integration technology com...