Author: gatfora
Date: Tue Apr 29 23:13:53 2008
New Revision: 652282
URL: http://svn.apache.org/viewvc?rev=652282&view=rev
Log:
Only call wakeThread in the cases where we need to wake the Sender as there is
work to do
Modified:
webservices/sandesha/branches/sandesha2/java/1_4/modules/core/src/main/java/org/apache/sandesha2/storage/inmemory/InMemoryStorageManager.java
webservices/sandesha/branches/sandesha2/java/1_4/modules/core/src/main/java/org/apache/sandesha2/storage/inmemory/InMemoryTransaction.java
Modified:
webservices/sandesha/branches/sandesha2/java/1_4/modules/core/src/main/java/org/apache/sandesha2/storage/inmemory/InMemoryStorageManager.java
URL:
http://svn.apache.org/viewvc/webservices/sandesha/branches/sandesha2/java/1_4/modules/core/src/main/java/org/apache/sandesha2/storage/inmemory/InMemoryStorageManager.java?rev=652282&r1=652281&r2=652282&view=diff
==============================================================================
---
webservices/sandesha/branches/sandesha2/java/1_4/modules/core/src/main/java/org/apache/sandesha2/storage/inmemory/InMemoryStorageManager.java
(original)
+++
webservices/sandesha/branches/sandesha2/java/1_4/modules/core/src/main/java/org/apache/sandesha2/storage/inmemory/InMemoryStorageManager.java
Tue Apr 29 23:13:53 2008
@@ -91,7 +91,7 @@
// do some work that requires a tran without there being a
transaction in scope
// then the enlist method will throw an exception.
Thread thread = Thread.currentThread();
- InMemoryTransaction result = new InMemoryTransaction(this,
thread);
+ InMemoryTransaction result = new InMemoryTransaction(this,
thread, useSerialization);
Transaction oldTran = (Transaction)
transactions.putIfAbsent(thread, result);
if(oldTran!=null){
// We don't want to overwrite or return an existing
transaction, as someone
@@ -339,4 +339,4 @@
MessageContext msgContext;
SOAPEnvelope envelope;
}
-}
\ No newline at end of file
+}
Modified:
webservices/sandesha/branches/sandesha2/java/1_4/modules/core/src/main/java/org/apache/sandesha2/storage/inmemory/InMemoryTransaction.java
URL:
http://svn.apache.org/viewvc/webservices/sandesha/branches/sandesha2/java/1_4/modules/core/src/main/java/org/apache/sandesha2/storage/inmemory/InMemoryTransaction.java?rev=652282&r1=652281&r2=652282&view=diff
==============================================================================
---
webservices/sandesha/branches/sandesha2/java/1_4/modules/core/src/main/java/org/apache/sandesha2/storage/inmemory/InMemoryTransaction.java
(original)
+++
webservices/sandesha/branches/sandesha2/java/1_4/modules/core/src/main/java/org/apache/sandesha2/storage/inmemory/InMemoryTransaction.java
Tue Apr 29 23:13:53 2008
@@ -47,18 +47,20 @@
private boolean sentMessages = false;
private boolean active = true;
private Thread thread;
+ private boolean useSerialization;
- InMemoryTransaction(InMemoryStorageManager manager, Thread thread) {
+ InMemoryTransaction(InMemoryStorageManager manager, Thread thread,
boolean useSerialization) {
if(log.isDebugEnabled()) log.debug("Entry:
InMemoryTransaction::<init>");
this.manager = manager;
this.thread = thread;
this.threadName = thread.getName();
+ this.useSerialization = useSerialization;
if(log.isDebugEnabled()) log.debug("Exit:
InMemoryTransaction::<init>, " + this);
}
public void commit() {
releaseLocks();
- if(sentMessages) manager.getSender().wakeThread();
+ if(sentMessages && useSerialization)
manager.getSender().wakeThread();
active = false;
}
@@ -176,3 +178,4 @@
+
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
