summaryrefslogtreecommitdiff
path: root/java
diff options
context:
space:
mode:
Diffstat (limited to 'java')
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/logging/actors/CurrentActor.java57
1 files changed, 30 insertions, 27 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/logging/actors/CurrentActor.java b/java/broker/src/main/java/org/apache/qpid/server/logging/actors/CurrentActor.java
index 374550a72b..df4da2a79e 100644
--- a/java/broker/src/main/java/org/apache/qpid/server/logging/actors/CurrentActor.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/logging/actors/CurrentActor.java
@@ -22,8 +22,8 @@ package org.apache.qpid.server.logging.actors;
import org.apache.qpid.server.logging.LogActor;
-import java.util.LinkedList;
-import java.util.Deque;
+import java.util.EmptyStackException;
+import java.util.Stack;
/**
* The CurrentActor is a ThreadLocal wrapper that allows threads in the broker
@@ -31,78 +31,81 @@ import java.util.Deque;
* reasons:
* 1) We do not have to pass a logging actor around the system
* 2) We can set new actors at the point we have enough information. i.e.
- * - Set a low level ConnectionActor when processing bytes from the wire.
- * - Set a ChannelActor when we are processing the frame
- * - Set a SubscriptionActor when we are handling the subscription.
- *
+ * - Set a low level ConnectionActor when processing bytes from the wire.
+ * - Set a ChannelActor when we are processing the frame
+ * - Set a SubscriptionActor when we are handling the subscription.
+ * <p/>
* The code performing the logging need not worry about what type of actor is
* currently set so can perform its logging. The resulting log entry though will
* contain customised details from the the currently set Actor.
- *
+ * <p/>
* The Actor model also allows the pre-creation of fixed messages so the
* performance impact of the additional logging data is minimised.
- *
+ * <p/>
* This class does not perform any checks to ensure that there is an Actor set
* when calling remove or get. As a result the application developer must ensure
* that they have called set before they attempt to use the actor via get or
* remove the set actor.
- *
+ * <p/>
* The checking of the return via get should not be done as the logging is
* desired. It is preferable to cause the NullPointerException to highlight the
* programming error rather than miss a log message.
- *
+ * <p/>
* The same is true for the remove. A NPE will occur if no set has been called
* highlighting the programming error.
- *
*/
public class CurrentActor
{
- /**
- * The ThreadLocal variable with initialiser
- */
- private static final ThreadLocal<Deque<LogActor>> _currentActor = new ThreadLocal<Deque<LogActor>>()
+ /** The ThreadLocal variable with initialiser */
+ private static final ThreadLocal<Stack<LogActor>> _currentActor = new ThreadLocal<Stack<LogActor>>()
{
// Initialise the CurrentActor to be an empty List
- protected Deque<LogActor> initialValue()
+ protected Stack<LogActor> initialValue()
{
- return new LinkedList<LogActor>();
+ return new Stack<LogActor>();
}
};
/**
* Set a new LogActor to be the Current Actor
- *
+ * <p/>
* This pushes the Actor in to the LIFO Queue
*
* @param actor The new LogActor
*/
public static void set(LogActor actor)
{
- Deque<LogActor> stack = _currentActor.get();
- stack.addFirst(actor);
+ Stack<LogActor> stack = _currentActor.get();
+ stack.push(actor);
}
/**
* Remove the current LogActor.
- *
- * Calling remove without calling set will result in a NoSuchElementException.
- *
+ * <p/>
+ * Calling remove without calling set will result in an EmptyStackException.
*/
public static void remove()
{
- Deque<LogActor> stack = _currentActor.get();
- stack.removeFirst();
+ Stack<LogActor> stack = _currentActor.get();
+ stack.pop();
}
/**
* Return the current head of the list of LogActors.
- *
+ * <p/>
* If there has been no set call then this will return Null.
*
* @return Current LogActor
*/
public static LogActor get()
{
- return _currentActor.get().peek();
+ try
+ {
+ return _currentActor.get().peek();
+ }
+ catch (EmptyStackException ese)
+ {
+ return null;
+ }
}
}