diff --git a/src/cpp/ripple/ripple_Peer.cpp b/src/cpp/ripple/ripple_Peer.cpp
index b80c437ba6..d346dbb9ae 100644
--- a/src/cpp/ripple/ripple_Peer.cpp
+++ b/src/cpp/ripple/ripple_Peer.cpp
@@ -160,6 +160,7 @@ private:
     void sendHello ();
 
     void recvHello (protocol::TMHello & packet);
+    void recvCluster (protocol::TMCluster & packet);
     void recvTransaction (protocol::TMTransaction & packet, ScopedLock & MasterLockHolder);
     void recvValidation (const boost::shared_ptr<protocol::TMValidation>& packet, ScopedLock & MasterLockHolder);
     void recvGetValidation (protocol::TMGetValidations & packet);
@@ -670,6 +671,17 @@ void PeerImp::processReadBuffer ()
         }
         break;
 
+        case protocol::mtCLUSTER:
+        {
+            event->reName ("PeerImp::cluster");
+            protocol::TMCluster msg;
+
+            if (msg.ParseFromArray (&mReadbuf[PackedMessage::kHeaderBytes], mReadbuf.size () - PackedMessage::kHeaderBytes))
+                recvCluster (msg);
+	    else
+	        WriteLog (lsWARNING, Peer) << "parse error: " << type;
+        }
+
         case protocol::mtERROR_MSG:
         {
             event->reName ("PeerImp::errormessage");
@@ -1406,6 +1418,11 @@ void PeerImp::recvValidation (const boost::shared_ptr<protocol::TMValidation>& p
 #endif
 }
 
+void PeerImp::recvCluster (protocol::TMCluster& packet)
+{
+    // WRITEME
+}
+
 void PeerImp::recvGetValidation (protocol::TMGetValidations& packet)
 {
 }