Sonic MQ Spring Integeration

[sanjava]

Hi,

I was able to integrate sonic MQ with spring core JMS API. I am looking forward to integrate spring with sonic MQ 8.5

we are building a Middleware service which subscribes to non durable topics ( > 1000 ) on the fly and get XML Messages.

These topics are created and destroyed on the fly by publisher. its like online shopping cart. whenever
you login your topic is created and when add an item to cart, we should send message to topic item added
when you delete we should send a message to topic item deleted and there is a Middleware service which we need to build to get active item for that agent login whenever a http request or web service request is sent.

I had explored using comet framework which does constant polling to get messages but we cannot use polling as our services are hosted in a shared JVM which might affect performance.

Is there any way to convert the JMS messages to HTTP and store in HTTP session so that I can respond to client request for messages.

I have another question if we connect to sonic MQ using Load Balancer URL, is it possible to get real server name?
we are having more than 3 Sonic MQ servers tied to single M3 load balancer.

[sanjava]

Let me rephrase my question into 2 parts

Part A)

I'd like multiple message listeners to handle successive messages from the topic concurrently and add remove new listeners
dynamically

Do I need to instantiate multiple DefaultMessageListenerContainers?

If time flows down the vertical axis:


ListenerA reads msg 1 ListenerB reads msg 2 ListenerC reads msg 3
ListenerA reads msg 4 ListenerB reads msg 5 ListenerC reads msg 6
ListenerA reads msg 7 ListenerB reads msg 8 ListenerC reads msg 9
ListenerA reads msg 10 ListenerB reads msg 11 ListenerC reads msg 12


Part B) Store these messages temporarily and respond to incoming external HTTP request.

Note: As a Client we have read only access to MQ server and we get at least 15 messages per second for various listeners from sonic MQ. Max can be 50 messages per second.