@ PostConstruct public void acquireConnections ( ) throws JMSException { LOGGER . debug ( "Initializing: {}" , this . getClass ( ) . getCanonicalName ( ) ) ; connection = connectionFactory . createConnection ( ) ; connection . start ( ) ; jmsSession = connection . createSession ( false , Session . AUTO_ACKNOWLEDGE ) ; producer = jmsSession . createProducer ( createDestination ( ) ) ; eventBus . register ( this ) ; }
Connect to JCR Repostory and JMS queue