[Sblim-commit] jsr48-client/src/org/sblim/cimclient WBEMListenerSBLIM.java, 1.17, 1.18

[Dave B. <bla...@us...>]

Update of /cvsroot/sblim/jsr48-client/src/org/sblim/cimclient
In directory vz-cvs-3.sog:/tmp/cvs-serv24222/src/org/sblim/cimclient

Modified Files:
	WBEMListenerSBLIM.java 
Log Message:
3513228 - Reliable Indications support can create lots of threads

Index: WBEMListenerSBLIM.java
===================================================================
RCS file: /cvsroot/sblim/jsr48-client/src/org/sblim/cimclient/WBEMListenerSBLIM.java,v
retrieving revision 1.17
retrieving revision 1.18
diff -u -d -r1.17 -r1.18
--- WBEMListenerSBLIM.java	14 Mar 2012 11:21:36 -0000	1.17
+++ WBEMListenerSBLIM.java	8 May 2012 17:22:08 -0000	1.18
@@ -24,6 +24,7 @@
  * 3469018    2012-01-03  blaschke-oss Properties not passed to CIMIndicationHandler
  * 3477087    2012-01-23  blaschke-oss Need Access to an Indication Sender's IP Address
  * 3496385    2012-03-02  blaschke-oss JSR48 1.0.0: add WBEMListener get/setProperty
+ * 3513228    2012-04-23  blaschke-oss Reliable Indications support can create lots of threads
  */
 
 package org.sblim.cimclient;
@@ -63,6 +64,8 @@
 
 		private HttpServerConnection iConnection;
 
+		private CIMIndicationHandler iIndicationHandler;
+
 		/**
 		 * Ctor.
 		 * 
@@ -92,17 +95,18 @@
 					"Listener must be instance of IndicationListener or IndicationListenerSBLIM");
 			this.iIndicationListener = pIndicationListener;
 			CIMEventDispatcher eventDispatcher = new CIMEventDispatcher(this.iIndicationListener);
-			CIMIndicationHandler indicationHandler = new CIMIndicationHandler(eventDispatcher,
-					config);
-			this.iConnection = new HttpServerConnection(
-					new HttpConnectionHandler(indicationHandler), pLocalAddress, pPort, pSSL,
-					config);
+			this.iIndicationHandler = new CIMIndicationHandler(eventDispatcher, config);
+			this.iConnection = new HttpServerConnection(new HttpConnectionHandler(
+					this.iIndicationHandler), pLocalAddress, pPort, pSSL, config);
 		}
 
 		@Override
 		protected void finalize() throws Throwable {
-			stop();
-			super.finalize();
+			try {
+				stop();
+			} finally {
+				super.finalize();
+			}
 		}
 
 		/**
@@ -113,10 +117,12 @@
 		}
 
 		/**
-		 * Stops the HTTP server connection receiving the indications.
+		 * Stops the HTTP server connection receiving the indications and the
+		 * indication handler.
 		 */
 		public void stop() {
 			this.iConnection.close();
+			this.iIndicationHandler.close();
 		}
 
 		/**