Closed eswdd closed 10 years ago
Looking into Cougar source code (EventPublisherRunnable class from JMSEventTransportImpl.java, sonic-transport module) I saw that the MessageProducer objects are never closed: public void run() { try { Session session = sessionManager.get(); Destination destination = createDestination(session, destinationName); MessageProducer messageProducer = session.createProducer(destination); TextMessage textMessage = getEventMarshaller().marshallEvent(descriptor, event, session); messageProducer.send(textMessage, textMessage.getJMSDeliveryMode(), textMessage.getJMSPriority(), textMessage.getJMSExpiration()); success = true; } catch (CougarFrameworkException cfe) { // Catch possible exception thrown from session creation success = false; error = cfe; } catch (JMSException ex) { // Catch any other exception thrown during message publication success = false; error = ex; } finally { unlock(); } }
Looking into Cougar source code (EventPublisherRunnable class from JMSEventTransportImpl.java, sonic-transport module) I saw that the MessageProducer objects are never closed: public void run() { try { Session session = sessionManager.get(); Destination destination = createDestination(session, destinationName); MessageProducer messageProducer = session.createProducer(destination); TextMessage textMessage = getEventMarshaller().marshallEvent(descriptor, event, session); messageProducer.send(textMessage, textMessage.getJMSDeliveryMode(), textMessage.getJMSPriority(), textMessage.getJMSExpiration()); success = true; } catch (CougarFrameworkException cfe) { // Catch possible exception thrown from session creation success = false; error = cfe; } catch (JMSException ex) { // Catch any other exception thrown during message publication success = false; error = ex; } finally { unlock(); } }