protected Session createSession ( Connection connection ) throws JMSException { if ( connection instanceof QueueConnection ) { return ( ( QueueConnection ) connection ) . createQueueSession ( false , Session . AUTO_ACKNOWLEDGE ) ; } return connection . createSession ( false , Session . AUTO_ACKNOWLEDGE ) ; }
Create queue session .