I'm queuing messages to a WebSphere MQ queue (NB: A point-to-point queue -- not a topic) using a stored procedure in my Oracle database. Is there a way to publish each message to multiple queues with a single call? What I would like is to find a solution that would incur zero additional latency on my database compared to sending the mess...
I have 2 Message driven beans. 2 Activation Specs for these beans. I have one Message bus and both the activation specs are configured to this one bus. I have 2 different queues and one queue connection factory configured for that one Message bus. Now, I would write my code to send a message to one of the queues at runtime after determ...
I was just reading abit about JMS and Apache ActiveMQ. And was wondering what real world use have people here used JMS or similar message queue technologies for ? ...
Does anyone know if there's a way to check the number of messages in a queue from a client application? Thanks. BTW, I'm using .NET client libraty. ...
I'm writing a .NET Windows Forms application that will post a message to a Websphere MQ queue and then poll a different queue for a response. If a response is returned, the application will partially process the response in real time. But the response needs to stay in the queue so that a daily batch job, which also reads from the respons...
I am attempting to write a time management tool with wxPython that is ideally non-obtrusive and very much out of the way. The app so far can be used normally and minimized to the system tray for the duration of its use. However, I notice that once the frame is not in focus, as it is when its 'Iconized', the mouse and keyboard trappin...
I'm using message queues for inter-thread communication in a server. The server was functioning as expected on Thursday evening. When I picked the project back up on Monday, it was unable to create two of the six queues in use, citing that they were already open (O_EXCL is set). This should not have been the case, but nevertheless I a...
I'm a little confused as to which one I should use. I think either will work, but is one better or more appropriate than the other? http://github.com/ask/carrot/tree/master http://github.com/ask/celery/tree/master ...
I'm using Carrot for a message queue in a Django project and followed the tutorial, and it works fine. But the example runs in the console, and I'm wondering how I apply this in Django. The publisher class I'm calling from one of my models in models.py, so that's OK. But I have no idea where to put the consumer class. Since it just sit...
I have been trying to figure out a solution but nothing has really presented itself to work. I am building a system that sends out emails (among other things), and I have been trying to figure out a way to have the queuing of messages work. I would like to provide the user a (somewhat) accurate count of the messages sent so far. I was th...
Here's the situation. Multi-million user website. Each user's page has a message section. Anyone can visit a user's page, where they can leave a message or view the last 100 messages. Messages are short pieces of txt with some extra meta-data. Every message has to be stored permanently, the only thing that must be real-time quick is th...
I have a background thread that handles communication with an external service. Each time the background thread receives a message I'd like to pass it to the UI thread for further processing (displaying to user). Currently I've made a thread safe message queue that is pooled periodically in Timer.Tick and filled in background thread. Bu...
Is there a robust OSS alternative to enterprise products like MSMQ? I had a little research and found: Apache ActiveMQ (wiki) RabbitMQ (homepage) However, I can't tell if they are robust enough for implementation. Please share your thoughts about these products, or add some to the list. ...
I'm looking for an implementation of this Enterprise Integration Pattern http://msdn.microsoft.com/en-us/library/ms978583.aspx explained in a more general way on http://www.eaipatterns.com/Messaging.html Does an Open Source implementation of "Message Bus" (or message queue) pattern exist for Delphi? ...
For message-oriented middleware that does not consistently support priority messages (such as AMQP) what is the best way to implement priority consumption when queues have only FIFO semantics? The general use case would be a system in which consumers receive messages of a higher priority before messages of a lower priority when a large ...
I have a system that will generate messages sporadically, and I would like to only submit either zero or one message every 5 minutes. If no message is generated, nothing would be processed by the queue consumer. If a hundred identical messages are generated within 5 minutes I only want one of those to be consumed from the queue. I am ...
What happens if two pthreads are calling the msgsnd() function at the "same" time, posting message to the same message queue ? What if two processes do the same ? Does it matter if they are threads or processes ? Specifically interested for Linux 2.6.15-2.5 #1 SMP PREEMPT Tue Sep 19 10:56:25 CDT 2006 x86_64 x86_64 x86_64 GNU/Linux ...
I have a queue " AIS.CICSUD1.BROKER.DATA " with different process Id as BO01, BO02, BO03. Can I create same Queue for diferrent process Id's. I tried it on MQ Explorer but it's giving me duplicate Queue Error. My MQ Sever is on my local Machine only and I need to access the Queuesfrom my local machine. Please let me know ...
I'm writing a (C++) application that utilizes a single dialog box. After setting up a message pump and handler I started wondering how I would go about propagating C++ exceptions to my original code (i.e., the code that calls CreateDialogParam, for instance). Here's a skeleton example of what I mean: BOOL CALLBACK DialogProc(HWND, UINT...
I have to send and receive dynamic data using a SysV message queue for a university project. The length of the data is transmitted in a separate message, size is therefor already known. And this is how I try to receive the data. I have to admit that I'm not a C++ specialist, especially when it comes to memory allocation. struct { ...