[jboss-svn-commits] JBL Code SVN: r7460 - in labs/jbossesb/trunk/product/core/rosetta/src/org/jboss: internal/soa/esb/couriers soa/esb/couriers

[jboss-svn-commits at lists.jboss.org]

Author: estebanschifman
Date: 2006-11-08 06:22:09 -0500 (Wed, 08 Nov 2006)
New Revision: 7460

Modified:
   labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/internal/soa/esb/couriers/JmsCourier.java
   labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/couriers/Courier.java
Log:
new cleanup() method in Courier interface and implementations

Modified: labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/internal/soa/esb/couriers/JmsCourier.java
===================================================================
--- labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/internal/soa/esb/couriers/JmsCourier.java	2006-11-08 01:03:38 UTC (rev 7459)
+++ labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/internal/soa/esb/couriers/JmsCourier.java	2006-11-08 11:22:09 UTC (rev 7460)
@@ -72,6 +72,19 @@
 		
     } //________________________________
 
+	public void cleanup() 
+	{
+		if (null != _messageProducer)
+			try { _messageProducer.close(); }
+			catch (JMSException e) {/*  OK do nothing  */ }
+		if (null != _jmsSession)
+			try { _jmsSession.close(); }
+			catch (JMSException e) {/*  OK do nothing  */ }
+		if (null != _jmsConnection)
+			try { _jmsConnection.close(); }
+			catch (JMSException e) {/*  OK do nothing  */ }
+    } //________________________________
+
 	/**
 	 * package the ESB message in a javax.jms.ObjectMessage, and send it
 	 * @param message Message - the message to deliver 

Modified: labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/couriers/Courier.java
===================================================================
--- labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/couriers/Courier.java	2006-11-08 01:03:38 UTC (rev 7459)
+++ labs/jbossesb/trunk/product/core/rosetta/src/org/jboss/soa/esb/couriers/Courier.java	2006-11-08 11:22:09 UTC (rev 7460)
@@ -33,4 +33,8 @@
  * @throws CourierException - if problems were encountered
  */
 	public abstract boolean deliver(Message message) throws CourierException;
+/**
+ * To be called when courier instance is going to be dropped
+ */	
+	public abstract void 	cleanup();
 }