messaging

Lightweight persistent message queue for Linux?

Is there a (preferably no cost) message queuing solution for Linux that has disk-based persistence (e.g. can survive a reboot)? I'm looking for something equivalent to MSMQ on Windows, fairly basic and lightweight and not, say, MQSeries. This will be used from C++ components. ...

Repeat windows messages in Winforms

I want repeat sent windows messages to my winforms application. Now, I have class implementing "IMessageFilter" which saves the selected messages (WM _KEYDOWN, WM _LBUTTONDOWN, etc...) to the list. On key "Pause/Break" I copy the list of messages, clear original list, and resend the messages. In my test project is only one form with on...

Trade-offs implementing versioning of services accessed by reliable async messaging?

Clients of HTTP services can specify the version (and format) they understand by requesting or posting data with a specific content type. The HTTP protocol defines error codes for reporting that the content type is not understood. Messaging systems (e.g. JMS, MQ Series and the like) do not have a standard way of describing message proto...

C# Client to Client Messaging

I will try and explain exactly what I want to achieve first. Imagine two users are using a windows forms application, when User A opens a particular form a lock is applied to the data record underlying the form so that only that user can make changes at that time. User B has a list of all records (in a grid) which among others contains...

Embeddable messaging component for Java web application

In order to satisfy customer requirements, we will need to let users exchange information among each other. The 'messaging system' does not have sophisticated back-end requirements and could be easily implemented with a few tables to store messages and message types. The problem is that I believe that the requirements on the front-end a...

Mule vs ActiveMQ for Python

I need to manged several servers, network services, appalication server (Apache, Tomcat) and manage them (start stop, install software). I would like to use Python, since C++ seems to complex and less productive for thing task. In am not sure which middleware to use. ActiveMQ and Mule seem to be a good choice, although written in Java. ...

Pipeline pattern for message processing

I have a set of services (non-WCF) that sit on queues. When message arrives, typical service does some calculations and spits out zero or more result messages to its output queue. Besides its primary function, each service has some housekeeping logic like auth / audit / logging / status tracking with exact steps and sequencing varying so...

Mule Aggregator - Streaming Aggregation

The collection aggregator used in the Mule 2.0 framework works a bit like this: An inbound router takes a collection of messages and splits it up into a number of smaller messages - each smaller message get stamped with a correlation id corresponding to the parent message These messages flow through various services Finally these messa...

Design Question – Polymorphic Event Handling

Design Question – Polymorphic Event Handling I’m currently trying to reduce the number of Event Handles in my current project. We have multiple systems that send data over USB. I currently have a routine to read in the messages and parse the initial header details to determine which system the message came from. The headers are a lit...

How would I create an asynchronous notification system using RESTful web services?

I have a Java application which I make available via RESTful web services. I want to create a mechanism so clients can register for notifications of events. The rub is that there is no guarantee that the client programs will be Java programs and hence I won't be able to use JMS for this (i.e. if every client was a Java app then we coul...

Avoiding split-brain, votes and quorum

Suppose you have n processes, n > 2. You want to have agreement amongst them that one is to be active. So they need to vote amonst each other to determine which one is active. All processes may fail at any time, we want to have one process active if possible, but ... We must never have two active at the same time, so if they can't be s...

Message Queues: Are messages lost on network failure?

I am wondering about the reliabilty of message delivery in messaging systems such as WebsphereMQ or ActiveMQ (used via JMS). As far as I know messages can be buffered if the recepient is unavailable and will be delivered later. Now I am wondering what happens if the sender temporarily cannot reach the network. Is there some kind of loca...

How do you assess/evaluate a messaging architecture?

I'm working on a project that relies on integrating with SMS/MMS messaging aggregator companies for deploying applications to cellphones as well as performing mobile payments through SMS. Many concepts in such architectures are closely related to messaging pattersn in enterprise integration and SOA worlds. I'm currently in the process of...

In a FIFO Qeueing system, what's the best way the to implement priority messaging.

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 ...

Messaging Middleware - how to avoid reentrance with wildcard subscription?

Messaging middleware solutions (JSM, Tibco, etc.) allow publish/subscribe with "topic" filtering using wildcards to subscribe to all messages of a certain "topic", e.g. SUBSCRIBE("ACCOUNT.*") topic allows you to subscribe to both "ACCOUNT.WITHDRAW" message and "ACCOUNT.CHECKBALANCE" message. The problem is that such subscription also re...

Idempotency Barrier for messaging

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...

How to see windows messages of a dialog shown with a second thread?

I've registered a message filter using Application.AddMessageFilter(m_messageFilter); using this I can log all of the mouse clicks a user makes in the application's user interface. However, one dialog is run on a separate thread, with code something like: void Run() { using( MyDialog dialog = new MyDialog() ) { dialo...

How should I go about guaranteeing that a "message" is sent and stored once and only once?

I'm working on designing an EDI system for two companies: Company A and Company B. Company A already exists as a small manufacturing business, and Company B is a new company formed around a specific product with the involvement of the owner of Company A. Company A will have exclusive rights to produce the product for Company B. I'm res...

How to pause JMS topic subscriber from receiving messages

My setup: JBoss Messaging 1.4 running on JBoss 4.2.3 I have a couple of MDB's that subscribes on one topic, and the MDB's onMessage() tries to deliver the received message to one web service each. My problem is that I can't figure out how to pause the subscriptions in the case when the web service is offline. My plan is to do the foll...

JBoss Messaging per EAR configuration

I'm using JBoss Messaging 1.4.3.GA (inside JBoss AS 5.1.0.GA). I'm packaging the definitions of my queues inside my EAR using an mbean. This means applications can define and use queues without having to change our company's stock JBoss installation. Is it possible to configure message persistence on a per application basis (inside the ...