qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acon...@apache.org
Subject svn commit: r1150687 - in /qpid/branches/qpid-2920/qpid/cpp/src/qpid/cluster/exp: Multicaster.cpp Multicaster.h
Date Mon, 25 Jul 2011 13:12:52 GMT
Author: aconway
Date: Mon Jul 25 13:12:52 2011
New Revision: 1150687

URL: http://svn.apache.org/viewvc?rev=1150687&view=rev
Log:
QPID-2920: add conveniece function to multicast AMQBodys directly.

Modified:
    qpid/branches/qpid-2920/qpid/cpp/src/qpid/cluster/exp/Multicaster.cpp
    qpid/branches/qpid-2920/qpid/cpp/src/qpid/cluster/exp/Multicaster.h

Modified: qpid/branches/qpid-2920/qpid/cpp/src/qpid/cluster/exp/Multicaster.cpp
URL: http://svn.apache.org/viewvc/qpid/branches/qpid-2920/qpid/cpp/src/qpid/cluster/exp/Multicaster.cpp?rev=1150687&r1=1150686&r2=1150687&view=diff
==============================================================================
--- qpid/branches/qpid-2920/qpid/cpp/src/qpid/cluster/exp/Multicaster.cpp (original)
+++ qpid/branches/qpid-2920/qpid/cpp/src/qpid/cluster/exp/Multicaster.cpp Mon Jul 25 13:12:52
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/qpid/cpp/src/qpid/cluster/exp/Multicaster.h
URL: http://svn.apache.org/viewvc/qpid/branches/qpid-2920/qpid/cpp/src/qpid/cluster/exp/Multicaster.h?rev=1150687&r1=1150686&r2=1150687&view=diff
==============================================================================
--- qpid/branches/qpid-2920/qpid/cpp/src/qpid/cluster/exp/Multicaster.h (original)
+++ qpid/branches/qpid-2920/qpid/cpp/src/qpid/cluster/exp/Multicaster.h Mon Jul 25 13:12:52
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


Mime
View raw message