From 95049a0fc8d159736a770f47c17b35bbac35ab4d Mon Sep 17 00:00:00 2001 From: Keith Wall Date: Tue, 27 Mar 2012 11:04:02 +0000 Subject: 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 Oleksandr Rudyy git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1305809 13f79535-47bb-0310-9956-ffa450edef68 --- .../apache/qpid/server/logging/actors/CurrentActor.java | 16 ++++++++++++++-- 1 file changed, 14 insertions(+), 2 deletions(-) (limited to 'java/broker') 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); + } } -- cgit v1.2.1