Author: veithen
Date: Sat Jul 3 11:18:39 2010
New Revision: 960202
URL: http://svn.apache.org/viewvc?rev=960202&view=rev
Log:
Replaced tabs by spaces.
Modified:
axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms/ServiceTaskManager.java
Modified:
axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms/ServiceTaskManager.java
URL:
http://svn.apache.org/viewvc/axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms/ServiceTaskManager.java?rev=960202&r1=960201&r2=960202&view=diff
==============================================================================
---
axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms/ServiceTaskManager.java
(original)
+++
axis/axis2/java/transports/trunk/modules/jms/src/main/java/org/apache/axis2/transport/jms/ServiceTaskManager.java
Sat Jul 3 11:18:39 2010
@@ -163,7 +163,7 @@ public class ServiceTaskManager {
}
if (cacheLevel == JMSConstants.CACHE_AUTO) {
- cacheLevel =
+ cacheLevel =
transactionality == BaseConstants.TRANSACTION_NONE ?
JMSConstants.CACHE_CONSUMER : JMSConstants.CACHE_NONE;
}
@@ -397,10 +397,10 @@ public class ServiceTaskManager {
try {
if (transactionality == BaseConstants.TRANSACTION_JTA)
{
ut = getUserTransaction();
- // We will only create a new tx if there is no tx
alive
- if (ut.getStatus() == Status.STATUS_NO_TRANSACTION)
{
- ut.begin();
- }
+ // We will only create a new tx if there is no tx
alive
+ if (ut.getStatus() ==
Status.STATUS_NO_TRANSACTION) {
+ ut.begin();
+ }
}
} catch (NotSupportedException e) {
handleException("Listener Task is already associated
with a transaction", e);
@@ -439,7 +439,7 @@ public class ServiceTaskManager {
}
} finally {
-
+
if (log.isTraceEnabled()) {
log.trace("Listener task with Thread ID : " +
Thread.currentThread().getId() +
" is stopping after processing : " + messageCount + "
messages :: " +
@@ -451,7 +451,7 @@ public class ServiceTaskManager {
log.debug("Listener task with Thread ID : " +
Thread.currentThread().getId() +
" is stopping after processing : " + messageCount + "
messages");
}
-
+
// Close the consumer and session before decrementing
activeTaskCount.
// (If we have a shared connection, Qpid deadlocks if the
shared connection
// is closed on another thread while closing the session)
