diff options
| author | Keith Wall <kwall@apache.org> | 2012-03-27 11:04:02 +0000 |
|---|---|---|
| committer | Keith Wall <kwall@apache.org> | 2012-03-27 11:04:02 +0000 |
| commit | 95049a0fc8d159736a770f47c17b35bbac35ab4d (patch) | |
| tree | 8c1ddb6a6a4c82bfc7eb984ebe91639bbaf71166 /java/broker | |
| parent | 1284af874a028a88cc99b9c6f255fde9b05d4ee2 (diff) | |
| download | qpid-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.java | 16 |
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); + } } |
