messaging

Message bus design - support implicit ordering of messages?

One important design decision that needs to be made when designing a corporate message bus is whether (and how) the message bus should support implicit ordering of messages. By implicit ordering, I mean the ability to deliver messages in exactly the same order as they were sent. There are several options: Don't support implicit messag...

WSMQ Queue Limit

Hi, is there a limit on how many queues I can have open within a single connection and single session? I can currently open up 128 queues and send messages to them. If I try to open up 129 I get the following error... Thanks Error: com.ibm.msg.client.jms.DetailedResourceAllocationException: JMSWMQ2008: Failed to open MQ queue 'TestQ...

.net service bus recommendations?

We are in need of a distributed architecture messaging system/service bus with the capability of Publish/Subscribe. Does anyone have any reccomendations for a framework that we can use for .net applications? ...

Blackboard messaging using queues

I have an application, where I need to add role-based messaging. The messages are generated ny the application itself, and every message have an starttime (where is show on the client message-window) and an expire-time. Depending on your role, you will see a subset of the messages. Some messages are VERY important, and should be pushed t...

JMS equivalent in .Net

Hi All, I am trying to make an common abstract interface over the messaging infrastructure in our company. The design goal is to 2 fold. 1 is to hide the complexity of programming from the developers (i know its not very complex but still simplify it further) and 2 is to make the developers independent of the vendor specific messaging i...

How to get the number of JMS messages in a Topic

How do I get the number of JMS messages waiting to be consumed by a specific JMS message subscriber? I use the Topic model (publish/subscribe) and not the Queue model. I want my MDB (message driven bean) to be able to figure out this information about the topic it listens to. To be clear; I want my MDB to get the number of messages wait...

How to send messages from PHP application to Java application without creating webservices?

One possible solution could be simple HTTP get or post request, but that wouldn't be secure. ...

Recommended to use Lingo with Spring?

I'm going through some examples for how to configure asynchronous JMS messaging with Spring, and the book I'm going through, Spring In Action, 2nd Edition (I know there's a 3rd edition out there), mentions using Lingo (http://lingo.codehaus.org/ for messaged-based RPC asynchronous messaging. The latest version of Lingo is a couple yea...

JavaDocs for Tibco datagrams (TibrvMsg)?

Does anyone know of available Javadoc for Tibco rvd datagrams (specifically, class "com.tibco.tibrv.TibrvMsg")? It is not hard to decompile classes to get signatures, but that does not tell a lot about expected optimal usage and such. All I need is simple read/write functionality for interoperability purposes, but ideally using recommen...

Message passing interface (MPI)on Windows

Hello, I an new to MPI and i want to use it under windows. Please could any one give me a link in which i can download this library (if exist). If there are many versions of MPI i hope to be referred to the most linux like because i have an MPI C linux code and i want with minimal change to make it work on windows. Thanks very much Hani...

message driven vs. event driven approaches to application integration

Hello, I was wondering if there is a clear distinction between message driven and event driven environments when we refer to SOA or middleware and generally in cases of application and enterprise integration. I understand that a user interface resembles an event driven model where our system intercepts action by the user. Also it is cl...

How to ensure message idempotency with multiple competing consumers?

I have multiple distributed competing consumers each pulling messages off the same (transactional) queue. I want to implement each consumer as an Idempotent Receiver so I never process the same message more than once (across all consumers) even if a duplicate arrives. How can I accomplish this with multiple consumers? My first thought i...

JMS Acknowledge Asynchronous Message

Hi, How do I acknowledge a message when I am using a message listener? I get the following error when I try to do an acknowledge in my message listener. A synchronous method call is not permitted when a session is being used asynchronously: 'acknowledge' ...

My buffer contains elements, but aren't being printed...

Sorry scratch my last post, it's way to late =S But basically I'm having problems sending out the buffer I created. Just need to know where I'm going wrong =( or if theres a better way. ------ Client Sending Username ------- int bufferSize = 32; char messageBuffer[bufferSize]; char* message; if (userName.size() > 8) { cout << "I...

ActiveMQ store-and-forward broker hangs after failover of master-slave pair

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

is there a servicebus solution where consumers don't consume events? (multiple consumers receive same event)

Hi, I was reading up on ActiveMQ which seems like a great implementation of a servicebus where producers can post messages and other processes can receive them. However when reading the documentation, it looks like the producer has to give the 'endpoint' when sending a message. I would rather have it the other way around: My producer ...

Best solution for Java HTTP push (messaging)

We want to push data from a server to clients but can only use HTTP (port 80). What is the best solution for messaging? One idea is Comet. Are there other ideas or frameworks which offer lets say JMS over HTTP. (Yes, ActiveMQ supports it too, but waggly IMHO. And JXTA supports it too but the configuration is complicated. Something simple...

Python message oriented middleware (i.e. JMS for Python)

What message oriented middle ware with a Python API are out there? What ones did you use and recommend (or not)? ...

Persistable and Repeatable Commands

Imagine that we have stuff we want done in the system and sometimes exceptions are raised while doing it. We want to give the end users a report of those errors so they have an opportunity to fix the root of the problem and then re-invoke the thing that caused the error. This obviously means we need to capture the "thing" in a way that ...

MassTransit Queue Maintenance

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