You are viewing a plain text version of this content. The canonical link for it is here.
Posted to fx-dev@ws.apache.org by ga...@apache.org on 2007/02/16 09:47:57 UTC

svn commit: r508348 - in /webservices/sandesha/trunk/java/src/org/apache/sandesha2: storage/inmemory/InMemorySenderBeanMgr.java workers/SandeshaThread.java workers/SenderWorker.java

Author: gatfora
Date: Fri Feb 16 00:47:56 2007
New Revision: 508348

URL: http://svn.apache.org/viewvc?view=rev&rev=508348
Log:
Protect against Null to address in SenderWorker, add extra trace information in SandeshaThread and InMemorySenderBeanMgr

Modified:
    webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/inmemory/InMemorySenderBeanMgr.java
    webservices/sandesha/trunk/java/src/org/apache/sandesha2/workers/SandeshaThread.java
    webservices/sandesha/trunk/java/src/org/apache/sandesha2/workers/SenderWorker.java

Modified: webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/inmemory/InMemorySenderBeanMgr.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/inmemory/InMemorySenderBeanMgr.java?view=diff&rev=508348&r1=508347&r2=508348
==============================================================================
--- webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/inmemory/InMemorySenderBeanMgr.java (original)
+++ webservices/sandesha/trunk/java/src/org/apache/sandesha2/storage/inmemory/InMemorySenderBeanMgr.java Fri Feb 16 00:47:56 2007
@@ -96,7 +96,7 @@
 			}
 		}
 		
-		if(log.isDebugEnabled()) log.debug("Exit: InMemorySenderBeanManager::getNextMessageToSend");
+		if(log.isDebugEnabled()) log.debug("Exit: InMemorySenderBeanManager::getNextMessageToSend " + result);
 		return result;
 	}
 	

Modified: webservices/sandesha/trunk/java/src/org/apache/sandesha2/workers/SandeshaThread.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/workers/SandeshaThread.java?view=diff&rev=508348&r1=508347&r2=508348
==============================================================================
--- webservices/sandesha/trunk/java/src/org/apache/sandesha2/workers/SandeshaThread.java (original)
+++ webservices/sandesha/trunk/java/src/org/apache/sandesha2/workers/SandeshaThread.java Fri Feb 16 00:47:56 2007
@@ -148,7 +148,8 @@
 	 * must pass in the internal sequence id when rmSource is true.
 	 */
 	public synchronized void runThreadForSequence(ConfigurationContext context, String sequenceID, boolean rmSource){
-		if(log.isDebugEnabled()) log.debug("Entry: SandeshaThread::runThreadForSequence, " + this);
+		if(log.isDebugEnabled()) 
+			log.debug("Entry: SandeshaThread::runThreadForSequence, " + this + ", " + sequenceID + ", " + rmSource);
 
 		SequenceEntry entry = new SequenceEntry(sequenceID, rmSource);
 		if (!workingSequences.contains(entry)) workingSequences.add(entry);
@@ -258,7 +259,7 @@
 						setRanMainLoop();
 					}
 				} catch (InterruptedException e1) {
-					log.debug("Sender was interupted...");
+					log.debug("SandeshaThread was interupted...");
 					log.debug(e1.getMessage());
 					log.debug("End printing Interrupt...");
 				}

Modified: webservices/sandesha/trunk/java/src/org/apache/sandesha2/workers/SenderWorker.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/workers/SenderWorker.java?view=diff&rev=508348&r1=508347&r2=508348
==============================================================================
--- webservices/sandesha/trunk/java/src/org/apache/sandesha2/workers/SenderWorker.java (original)
+++ webservices/sandesha/trunk/java/src/org/apache/sandesha2/workers/SenderWorker.java Fri Feb 16 00:47:56 2007
@@ -134,7 +134,7 @@
 			RequestResponseTransport t = null;
 			Boolean makeConnection = (Boolean) msgCtx.getProperty(Sandesha2Constants.MAKE_CONNECTION_RESPONSE);
 			EndpointReference toEPR = msgCtx.getTo();
-			if(toEPR.hasAnonymousAddress() &&
+			if((toEPR!=null && toEPR.hasAnonymousAddress()) &&
 				(makeConnection == null || !makeConnection.booleanValue())) {
 
 				MessageContext inMsg = null;



---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org