From df2027a432879efc5e9708e2d381b066fae84a49 Mon Sep 17 00:00:00 2001 From: Kenneth Anthony Giusti Date: Wed, 2 Nov 2011 15:37:03 +0000 Subject: QPID-3577: assign null group names to the default group git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1196635 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/cpp/docs/man/qpidd.1 | 25 ++++++++++++++++++------ qpid/cpp/src/qpid/broker/MessageGroupManager.cpp | 5 ++++- 2 files changed, 23 insertions(+), 7 deletions(-) diff --git a/qpid/cpp/docs/man/qpidd.1 b/qpid/cpp/docs/man/qpidd.1 index d2cff454cf..7ffb153248 100644 --- a/qpid/cpp/docs/man/qpidd.1 +++ b/qpid/cpp/docs/man/qpidd.1 @@ -1,5 +1,5 @@ -.\" DO NOT MODIFY THIS FILE! It was generated by help2man 1.38.2. -.TH QPIDD "1" "March 2011" "qpidd (qpidc) version 0.11" "User Commands" +.\" DO NOT MODIFY THIS FILE! It was generated by help2man 1.40.2. +.TH QPIDD "1" "November 2011" "qpidd (qpidc) version 0.13" "User Commands" .SH NAME qpidd \- the Qpid AMQP Message Broker Daemon @@ -24,11 +24,11 @@ Displays the help message \fB\-v\fR [ \fB\-\-version\fR ] Displays version information .TP -\fB\-\-config\fR FILE +\fB\-\-config\fR FILE (/usr/local/etc/qpidd.conf) Reads configuration from FILE .SS "Module options:" .TP -\fB\-\-module\-dir\fR DIR +\fB\-\-module\-dir\fR DIR (/usr/local/lib/qpid/daemon) Load all shareable modules in this directory .TP @@ -41,7 +41,7 @@ Don't load modules from module directory .SS "Broker Options:" .TP -\fB\-\-data\-dir\fR DIR +\fB\-\-data\-dir\fR DIR (/home/kgiusti/.qpidd) Directory to contain persistent data generated by the broker .TP @@ -127,6 +127,15 @@ which flow control is de\-activated. \fB\-\-default\-event\-threshold\-ratio\fR %age of limit (80) The ratio of any specified queue limit at which an event will be raised +.TP +\fB\-\-default\-message\-group\fR GROUP\-IDENTIFER (qpid.no\-group) +Group identifier to assign to messages +delivered to a message group queue that +do not contain an identifier. +.TP +\fB\-\-enable\-timestamp\fR yes|no (0) +Add current time to each received +message. .SS "Logging options:" .TP \fB\-t\fR [ \fB\-\-trace\fR ] @@ -164,6 +173,10 @@ Include thread ID in log messages Include function signature in log messages .TP +\fB\-\-log\-hires\-timestamp\fR yes|no (0) +Use unformatted hi\-res timestamp in log +messages +.TP \fB\-\-log\-prefix\fR STRING Prefix to append to all log messages .SS "Logging sink options:" @@ -197,7 +210,7 @@ default in this mode. The transport for which to return the port .TP -\fB\-\-pid\-dir\fR DIR +\fB\-\-pid\-dir\fR DIR (/home/kgiusti/.qpidd) Directory where port\-specific PID file is stored .TP diff --git a/qpid/cpp/src/qpid/broker/MessageGroupManager.cpp b/qpid/cpp/src/qpid/broker/MessageGroupManager.cpp index 77108c10d5..00d1a58bef 100644 --- a/qpid/cpp/src/qpid/broker/MessageGroupManager.cpp +++ b/qpid/cpp/src/qpid/broker/MessageGroupManager.cpp @@ -77,12 +77,15 @@ MessageGroupManager::GroupState& MessageGroupManager::findGroup( const QueuedMes if (headers) { qpid::framing::FieldTable::ValuePtr id = headers->get( groupIdHeader ); if (id && id->convertsTo()) { - group = id->get(); + std::string tmp = id->get(); + if (!tmp.empty()) // empty group is reserved + group = tmp; } } if (cachedGroup && group == lastGroup) { hits++; + lastMsg = thisMsg; return *cachedGroup; } -- cgit v1.2.1