You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ac...@apache.org on 2011/09/06 23:46:50 UTC
svn commit: r1165883 - in
/qpid/branches/qpid-2920-1/qpid/cpp/src/qpid/cluster/exp: Multicaster.cpp
Multicaster.h
Author: aconway
Date: Tue Sep 6 21:46:50 2011
New Revision: 1165883
URL: http://svn.apache.org/viewvc?rev=1165883&view=rev
Log:
QPID-2920: add conveniece function to multicast AMQBodys directly.
Modified:
qpid/branches/qpid-2920-1/qpid/cpp/src/qpid/cluster/exp/Multicaster.cpp
qpid/branches/qpid-2920-1/qpid/cpp/src/qpid/cluster/exp/Multicaster.h
Modified: qpid/branches/qpid-2920-1/qpid/cpp/src/qpid/cluster/exp/Multicaster.cpp
URL: http://svn.apache.org/viewvc/qpid/branches/qpid-2920-1/qpid/cpp/src/qpid/cluster/exp/Multicaster.cpp?rev=1165883&r1=1165882&r2=1165883&view=diff
==============================================================================
--- qpid/branches/qpid-2920-1/qpid/cpp/src/qpid/cluster/exp/Multicaster.cpp (original)
+++ qpid/branches/qpid-2920-1/qpid/cpp/src/qpid/cluster/exp/Multicaster.cpp Tue Sep 6 21:46:50 2011
@@ -22,6 +22,9 @@
#include "Multicaster.h"
#include "qpid/cluster/Cpg.h"
#include "qpid/log/Statement.h"
+#include "qpid/framing/AMQBody.h"
+#include "qpid/framing/AMQDataBlock.h"
+#include "qpid/framing/AMQFrame.h"
namespace qpid {
namespace cluster {
@@ -55,6 +58,11 @@ void Multicaster::mcast(const framing::A
queue.push(bufRef);
}
+void Multicaster::mcast(const framing::AMQBody& body) {
+ framing::AMQFrame f(body);
+ mcast(f);
+}
+
Multicaster::PollableEventQueue::Batch::const_iterator
Multicaster::sendMcast(const PollableEventQueue::Batch& buffers) {
try {
Modified: qpid/branches/qpid-2920-1/qpid/cpp/src/qpid/cluster/exp/Multicaster.h
URL: http://svn.apache.org/viewvc/qpid/branches/qpid-2920-1/qpid/cpp/src/qpid/cluster/exp/Multicaster.h?rev=1165883&r1=1165882&r2=1165883&view=diff
==============================================================================
--- qpid/branches/qpid-2920-1/qpid/cpp/src/qpid/cluster/exp/Multicaster.h (original)
+++ qpid/branches/qpid-2920-1/qpid/cpp/src/qpid/cluster/exp/Multicaster.h Tue Sep 6 21:46:50 2011
@@ -23,12 +23,16 @@
*/
#include "BufferFactory.h"
-#include "qpid/framing/AMQDataBlock.h"
#include "qpid/sys/PollableQueue.h"
#include <sys/uio.h> // For struct iovec
namespace qpid {
+namespace framing {
+class AMQDataBlock;
+class AMQBody;
+}
+
namespace sys {
class Poller;
}
@@ -50,6 +54,7 @@ class Multicaster
/** Multicast an event */
void mcast(const framing::AMQDataBlock&);
+ void mcast(const framing::AMQBody&);
private:
typedef sys::PollableQueue<BufferRef> PollableEventQueue;
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org