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: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
