Author: supun
Date: Wed May 12 09:39:37 2010
New Revision: 943418
URL: http://svn.apache.org/viewvc?rev=943418&view=rev
Log:
improving code
Modified:
synapse/trunk/java/modules/commons/src/main/java/org/apache/synapse/commons/executors/MultiPriorityBlockingQueue.java
Modified:
synapse/trunk/java/modules/commons/src/main/java/org/apache/synapse/commons/executors/MultiPriorityBlockingQueue.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/commons/src/main/java/org/apache/synapse/commons/executors/MultiPriorityBlockingQueue.java?rev=943418&r1=943417&r2=943418&view=diff
==============================================================================
---
synapse/trunk/java/modules/commons/src/main/java/org/apache/synapse/commons/executors/MultiPriorityBlockingQueue.java
(original)
+++
synapse/trunk/java/modules/commons/src/main/java/org/apache/synapse/commons/executors/MultiPriorityBlockingQueue.java
Wed May 12 09:39:37 2010
@@ -398,8 +398,8 @@ public class MultiPriorityBlockingQueue<
public String toString() {
final ReentrantLock lock = this.lock;
lock.lock();
- String s = "";
try {
+ String s = "";
for (InternalQueue<E> internalQueue : queues) {
s += internalQueue.toString();
}
@@ -426,8 +426,8 @@ public class MultiPriorityBlockingQueue<
public <T> T[] toArray(T[] a) {
final ReentrantLock lock = this.lock;
lock.lock();
- List<E> list = new ArrayList<E>();
try {
+ List<E> list = new ArrayList<E>();
for (InternalQueue<E> internalQueue : queues) {
list.addAll(internalQueue);
}
@@ -440,8 +440,8 @@ public class MultiPriorityBlockingQueue<
public Object[] toArray() {
final ReentrantLock lock = this.lock;
lock.lock();
- List<E> list = new ArrayList<E>();
try {
+ List<E> list = new ArrayList<E>();
for (InternalQueue<E> internalQueue : queues) {
list.addAll(internalQueue);
}