message-queue

WM_DESTROY, WM_CLOSE bypassing IMessageFilter

Below is my message filter: bool MyFilter::PreFilterMessage(Message %m){ switch(m.Msg){ case WM_CLOSE: case WM_DESTROY: case WM_NCDESTROY: case WM_QUIT: Debug::WriteLine(L"Gone!"); break; case WM_MOUSEMOVE: Debug::WriteLine(L"A mouse! Catch! Catch!!! CATCH!!"); break; } return false; }...

MSMQ Thread Safety

I'm working with message queues in c#. I'm sending messages to a queue from code called by a timer (set up in the main thread), and also from a background worker thread. If I have two instances of the message queue, one for the timer and one for the background worker thread, am I going to face any thread issues? I have had problems when ...

ActiveMQ message grouping performance

Has anyone used the Message Grouping feature in ActiveMQ? http://activemq.apache.org/message-groups.html This would be a really useful feature for a project I'm working on, but I'm curious how well this feature scales and performs. In our system, we would need to group messages into groups of about 3-5 messages, so we would be continu...

Help me find the "ugliest" message queues API

I realize this is a weird question, but I am writing a presentation and I want to discuss the difference between intutivie APIs and unintuitive ones. Intuitiveness has to do with function names, complex signature, etc. I am using JMS as my intuitive example (especially since it's object oriented and the sample code is very obvious). I ...

Message Queues in Ruby on Rails

What message queues are people using for their Rails apps and what was the driving force behind the decision to choose it. Does the latest Twitter publicity over their in house queue Starling falling down affect any existing design decisions. I am working on an app that will need a message queue to process some background tasks, I haven...

Rules of thumb regarding Messaging / Message Queueing

Can someone provide some rules of thumb regarding when to use Message Queueing and what practical real-world problems they are supposed to address? Thanks ...

Can someone explain what message brokers are used for?

In my line of work it's hard to go five minutes without someone extolling the virtues of MQ Series or MSMQ or the like, and I always wonder, after the sparkle of buzzwords has passed, what are some actual examples of these wonderful devices out in the real world. What I'm looking for is something that might inspire me to find a use for ...

ActiveMQ or RabbitMQ or ZeroMQ or...

We'd be interested to hear any experiences with the pros and cons of ActiveMQ vs RabbitMQ vs ZeroMQ. Information about any other interesting message queues is also welcome. ...

Message queue that delivers delayed messages and checks for uniqness

I have an online service that receives incoming events (few every second). Service needs to process a job when there were no events for 30 seconds or more. Service is distributed across several PCs and uses Amazon webservices (SQS and SimpleDB) as a backbone. I understand how can I schedule a job when there IS an incoming event (just pu...

Why ActiveMQ, as opposed to a simple Queue/Mutex?

Tomorrow I am presenting my rationale for choosing an in-process message queue implementation, and I'm unable to articulate my reasoning. My co-designers are proposing that we implement a simple asynchronous queue using just a basic list of jobs and a mutex to control access, where I'm suggesting ActiveMQ in embedded mode. I've persona...

How is Win32 event-driven programming implemented under the hood?

In a Win32 C++ application, we start a message loop that fetches messages from a queue, translates them and then dispatches them. Eventually, each message reaches our WndProc where the associated event can be handled. I understand that part. What I don't understand is the in between goings-on. Specifically: Different kinds of OS inter...

More threads, better performance?

When I write a message driven app. much like a standard windows app only that it extensively uses messaging for internal operations, what would be the best approach regarding to threading? As I see it, there are basically three approaches (if you have any other setup in mind, please share): Having a single thread process all of the me...

On Windows - where is a mqji.properties for me to use?

My application is a stand alone Java app, that customers download, install and run. It uses MQ to communicate with a host, which has been working for years. Neither myself nor customers have anything MQ installed on their Windows machines; we include and use com.ibm.mq.jar to do the work. Apparently though, MQ needs a mqji.properties fi...

Processing messages is too slow, resulting in a jerky, unresponsive UI - how can I use multiple threads to alleviate this?

I'm having trouble keeping my app responsive to user actions. Therefore, I'd like to split message processing between multiple threads. Can I simply create several threads, reading from the same message queue in all of them, and letting which ever one is able process each message? If so, how can this be accomplished? If not, can you...

Building a high performance and automatically backupped queue

Please give me some hints on my issue. I'm building a queue data structure that: has a backup on hard disk at realtime and can restore the backup Can respond to massive enqueue/dequeue request Thank you! ...

RE: Posix and System V IPC

Which IPC among message queues, shared memory and semaphores is easiest to convert to network IPC and which is the hardest. Would it be easier to convert System V shared memory to network IPC or Posix shared memory to network IPC ...

Persistent Messaging/Service Bus - Roll my own or risk the learning curve?

We have a client application that needs to send messages to a server for various notifications. In order that the client can run occasionally connected I'm going to go with a message-queue approach. The queue processing will take messages off the queue and call a web service that will put them on another queue to finally be processed. ...

MQJE018: Protocol error - unexpected segment type received

Calling all MQ Gurus, I have a box under my desk which we use to replicate our production environment which is: WebSphere 6.1 Fedora Linux MQ 6.0 Whenever one of our applications tries to send a message to a MQ queue we get the following error: MQJE018: Protocol error - unexpected segment type received Any suggestions on what this mi...

System i (iSeries, AS/400) Message Queuing Options

I'm trying to find options for MQ on the iSeries besides WebSphere MQ. Does anyone have experience with this? Is it possible? Could I run a pure java MQ server like OpenMQ? ...

sql service broker functionality question

Hi, I'm a beginning web developer sitting on an ambitious web application project. So after having done some research, I found out about SQL Service Broker. It seems like something I could use, but I'm not sure. Since learning it requires someone to put in lots of time, I wanted to be sure that it would fit my needs. I need to implemen...