summaryrefslogtreecommitdiff
path: root/java/broker
diff options
context:
space:
mode:
authorKeith Wall <kwall@apache.org>2012-03-27 11:04:02 +0000
committerKeith Wall <kwall@apache.org>2012-03-27 11:04:02 +0000
commit95049a0fc8d159736a770f47c17b35bbac35ab4d (patch)
tree8c1ddb6a6a4c82bfc7eb984ebe91639bbaf71166 /java/broker
parent1284af874a028a88cc99b9c6f255fde9b05d4ee2 (diff)
downloadqpid-python-95049a0fc8d159736a770f47c17b35bbac35ab4d.tar.gz
QPID-3913: Add functionality to upgrade bdbstore automatically on broker start-up. Store message content using single chunk. Change store version to 6. Remove implementations of tuple bindings for previous versions.
Applied patch from Phil Harvey<phil@philharveyonline.com> Oleksandr Rudyy<orudyy@gmail.com> git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1305809 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/broker')
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/logging/actors/CurrentActor.java16
1 files changed, 14 insertions, 2 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 feacf35d41..97134515a0 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
@@ -20,11 +20,13 @@
*/
package org.apache.qpid.server.logging.actors;
-import org.apache.qpid.server.logging.LogActor;
-
import java.util.EmptyStackException;
import java.util.Stack;
+import org.apache.qpid.server.logging.LogActor;
+import org.apache.qpid.server.logging.LogMessage;
+import org.apache.qpid.server.logging.LogSubject;
+
/**
* The CurrentActor is a ThreadLocal wrapper that allows threads in the broker
* to retrieve an actor to perform logging. This approach is used so for two
@@ -126,4 +128,14 @@ public class CurrentActor
{
_defaultActor = defaultActor;
}
+
+ public static void message(LogSubject subject, LogMessage message)
+ {
+ get().message(subject, message);
+ }
+
+ public static void message(LogMessage message)
+ {
+ get().message(message);
+ }
}