qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kgiu...@apache.org
Subject svn commit: r1196635 - in /qpid/trunk/qpid/cpp: docs/man/qpidd.1 src/qpid/broker/MessageGroupManager.cpp
Date Wed, 02 Nov 2011 15:37:03 GMT
Author: kgiusti
Date: Wed Nov  2 15:37:03 2011
New Revision: 1196635

URL: http://svn.apache.org/viewvc?rev=1196635&view=rev
Log:
QPID-3577: assign null group names to the default group

Modified:
    qpid/trunk/qpid/cpp/docs/man/qpidd.1
    qpid/trunk/qpid/cpp/src/qpid/broker/MessageGroupManager.cpp

Modified: qpid/trunk/qpid/cpp/docs/man/qpidd.1
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/docs/man/qpidd.1?rev=1196635&r1=1196634&r2=1196635&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/docs/man/qpidd.1 (original)
+++ qpid/trunk/qpid/cpp/docs/man/qpidd.1 Wed Nov  2 15:37:03 2011
@@ -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

Modified: qpid/trunk/qpid/cpp/src/qpid/broker/MessageGroupManager.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/MessageGroupManager.cpp?rev=1196635&r1=1196634&r2=1196635&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/MessageGroupManager.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/MessageGroupManager.cpp Wed Nov  2 15:37:03 2011
@@ -77,12 +77,15 @@ MessageGroupManager::GroupState& Message
     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;
     }
 



---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org


Mime
View raw message