You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2013/12/19 20:22:37 UTC
svn commit: r1552400 - in /qpid/trunk/qpid/cpp/src/qpid/amqp: Encoder.cpp
Encoder.h MessageEncoder.cpp
Author: gsim
Date: Thu Dec 19 19:22:37 2013
New Revision: 1552400
URL: http://svn.apache.org/r1552400
Log:
QPID-5434: send timestamps with correct typecode
Modified:
qpid/trunk/qpid/cpp/src/qpid/amqp/Encoder.cpp
qpid/trunk/qpid/cpp/src/qpid/amqp/Encoder.h
qpid/trunk/qpid/cpp/src/qpid/amqp/MessageEncoder.cpp
Modified: qpid/trunk/qpid/cpp/src/qpid/amqp/Encoder.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/amqp/Encoder.cpp?rev=1552400&r1=1552399&r2=1552400&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/amqp/Encoder.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/amqp/Encoder.cpp Thu Dec 19 19:22:37 2013
@@ -246,6 +246,12 @@ void Encoder::writeLong(int64_t i, const
write((uint64_t) i, typecodes::LONG, d);
}
+void Encoder::writeTimestamp(int64_t t, const Descriptor* d)
+{
+ write((uint64_t) t, typecodes::TIMESTAMP, d);
+}
+
+
void Encoder::writeFloat(float f, const Descriptor* d)
{
write(f, typecodes::FLOAT, d);
Modified: qpid/trunk/qpid/cpp/src/qpid/amqp/Encoder.h
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/amqp/Encoder.h?rev=1552400&r1=1552399&r2=1552400&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/amqp/Encoder.h (original)
+++ qpid/trunk/qpid/cpp/src/qpid/amqp/Encoder.h Thu Dec 19 19:22:37 2013
@@ -71,6 +71,7 @@ class Encoder
void writeFloat(float, const Descriptor* d=0);
void writeDouble(double, const Descriptor* d=0);
void writeUuid(const qpid::types::Uuid&, const Descriptor* d=0);
+ void writeTimestamp(int64_t, const Descriptor* d=0);
void writeSymbol(const CharSequence&, const Descriptor* d=0);
void writeSymbol(const std::string&, const Descriptor* d=0);
Modified: qpid/trunk/qpid/cpp/src/qpid/amqp/MessageEncoder.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/amqp/MessageEncoder.cpp?rev=1552400&r1=1552399&r2=1552400&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/amqp/MessageEncoder.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/amqp/MessageEncoder.cpp Thu Dec 19 19:22:37 2013
@@ -116,10 +116,10 @@ void MessageEncoder::writeProperties(con
if (msg.hasContentEncoding()) writeSymbol(msg.getContentEncoding());
else if (fields > 7) writeNull();
- if (msg.hasAbsoluteExpiryTime()) writeLong(msg.getAbsoluteExpiryTime());
+ if (msg.hasAbsoluteExpiryTime()) writeTimestamp(msg.getAbsoluteExpiryTime());
else if (fields > 8) writeNull();
- if (msg.hasCreationTime()) writeLong(msg.getCreationTime());
+ if (msg.hasCreationTime()) writeTimestamp(msg.getCreationTime());
else if (fields > 9) writeNull();
if (msg.hasGroupId()) writeString(msg.getGroupId());
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org