New connection is created on each JMS message

[benxiong]

I use hornetq client with spring jmstemplate, and watched the log, with each message there is one line:

* [Old I/O server boss ([id: 0x38f28789, /192.168.149.220:5445])] 5-Jul 3:49:25,773 FINEST [RemotingServiceImpl]  Connection created org.hornetq.core.remoting.impl.netty.NettyConnection@1f655d7e[local= /192.168.149.220:5445, remote=/192.168.149.220:35365]

I think the client does not created connection pool? How can I enable connection pool on client side? Thanks.

[gaohoward]

I think you need configure your spring.

[benxiong]

org.springframework.jms.core.JmsTemplate's property connectionFactory is pointing to org.hornetq.jms.client.HornetQJMSConnectionFactory, whose connectorConfig is a org.hornetq.api.core.TransportConfiguration with org.hornetq.core.remoting.impl.netty.NettyConnectorFactory.

I have checked the options for NettyConnectorFactory and do not see any options for connection pool.

[gaohoward]

You are right HornetQ's factory doesn't provide pooling. You need Spring's pool configuration IMO.

[benxiong]

Yah, in Spring, one can use JEE managed connection pool or use CachingConnectionFactory as described in the following article:

http://singztechmusings.wordpress.com/2011/04/24/problem-with-creating-jms-messageproducer-using-spring-jmstemplate-how-to-solve/

[jbertram]

Also see this article about using the Spring JMSTemplate with JBoss Messaging.  It applies to HornetQ (or any message broker) as well.

[benxiong]

Seems only ONE connection is established for all sessions and messages. Although it's already much faster, but still one connection can send around 30 messages/second (LAN).

Tomcat + Spring seems no solution for multi connections? I have to drop tomcat? If so, I have to say ActiveMQ is attractive in this case because HornetQ is fast but who cares if I cannot even connect to it with so popular Tomcat?

[jbertram]

I'm not a Spring expert, but I don't believe this is an issue with HornetQ.  Spring is managing the connections to HornetQ so if there is only 1 connection available then I believe that would be a Spring code/configuration issue.  My guess is that this same problem would exist if you tried to integrate with ActiveMQ or any other JMS provider for that matter.

[benxiong]

I'm not trying to argue but actually ActiveMQ does offer

org.apache.activemq.pool.PooledConnection

That's why I was trying to find it in HornetQ. Spring seems failed to deliver a replacement for JEE JMS connection pool.