aboutsummaryrefslogtreecommitdiff
path: root/src/zmq/zmqpublishnotifier.h
diff options
context:
space:
mode:
authorJonas Schnelli <dev@jonasschnelli.ch>2016-03-29 14:30:02 +0200
committerJonas Schnelli <dev@jonasschnelli.ch>2016-04-19 15:32:11 +0200
commit0b25a9fb42d5df54ea35ddb2bb4837e1e29355fd (patch)
tree429fe7843fbb85f3d46653381d0f82a39a4be595 /src/zmq/zmqpublishnotifier.h
parentde821d56e1f458fbe580520c77ac066107f4d77c (diff)
downloadbitcoin-0b25a9fb42d5df54ea35ddb2bb4837e1e29355fd.tar.xz
[ZMQ] append a message sequence number to every ZMQ notification
Diffstat (limited to 'src/zmq/zmqpublishnotifier.h')
-rw-r--r--src/zmq/zmqpublishnotifier.h12
1 files changed, 12 insertions, 0 deletions
diff --git a/src/zmq/zmqpublishnotifier.h b/src/zmq/zmqpublishnotifier.h
index 44d5cbea67..22f02a3d0d 100644
--- a/src/zmq/zmqpublishnotifier.h
+++ b/src/zmq/zmqpublishnotifier.h
@@ -11,7 +11,19 @@ class CBlockIndex;
class CZMQAbstractPublishNotifier : public CZMQAbstractNotifier
{
+private:
+ uint32_t nSequence; //! upcounting per message sequence number
+
public:
+
+ /* send zmq multipart message
+ parts:
+ * command
+ * data
+ * message sequence number
+ */
+ bool SendMessage(const char *command, const void* data, size_t size);
+
bool Initialize(void *pcontext);
void Shutdown();
};