summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorKenneth Anthony Giusti <kgiusti@apache.org>2011-11-02 15:37:03 +0000
committerKenneth Anthony Giusti <kgiusti@apache.org>2011-11-02 15:37:03 +0000
commitdf2027a432879efc5e9708e2d381b066fae84a49 (patch)
tree479a5b76e6aa891694c3c46f709cacb25de25c7f
parent5e6d14c5486772c9ec4edcb8b952395e11c5973c (diff)
downloadqpid-python-df2027a432879efc5e9708e2d381b066fae84a49.tar.gz
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
-rw-r--r--qpid/cpp/docs/man/qpidd.125
-rw-r--r--qpid/cpp/src/qpid/broker/MessageGroupManager.cpp5
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<std::string>()) {
- group = id->get<std::string>();
+ std::string tmp = id->get<std::string>();
+ if (!tmp.empty()) // empty group is reserved
+ group = tmp;
}
}
if (cachedGroup && group == lastGroup) {
hits++;
+ lastMsg = thisMsg;
return *cachedGroup;
}