|
|
|
@ -7,6 +7,7 @@
|
|
|
|
|
#include "zmqpublishnotifier.h"
|
|
|
|
|
#include "validation.h"
|
|
|
|
|
#include "util.h"
|
|
|
|
|
#include "rpc/server.h"
|
|
|
|
|
|
|
|
|
|
static std::multimap<std::string, CZMQAbstractPublishNotifier*> mapPublishNotifiers;
|
|
|
|
|
|
|
|
|
@ -166,7 +167,7 @@ bool CZMQPublishRawBlockNotifier::NotifyBlock(const CBlockIndex *pindex)
|
|
|
|
|
LogPrint("zmq", "zmq: Publish rawblock %s\n", pindex->GetBlockHash().GetHex());
|
|
|
|
|
|
|
|
|
|
const Consensus::Params& consensusParams = Params().GetConsensus();
|
|
|
|
|
CDataStream ss(SER_NETWORK, PROTOCOL_VERSION);
|
|
|
|
|
CDataStream ss(SER_NETWORK, PROTOCOL_VERSION | RPCSerializationFlags());
|
|
|
|
|
{
|
|
|
|
|
LOCK(cs_main);
|
|
|
|
|
CBlock block;
|
|
|
|
@ -186,7 +187,7 @@ bool CZMQPublishRawTransactionNotifier::NotifyTransaction(const CTransaction &tr
|
|
|
|
|
{
|
|
|
|
|
uint256 hash = transaction.GetHash();
|
|
|
|
|
LogPrint("zmq", "zmq: Publish rawtx %s\n", hash.GetHex());
|
|
|
|
|
CDataStream ss(SER_NETWORK, PROTOCOL_VERSION);
|
|
|
|
|
CDataStream ss(SER_NETWORK, PROTOCOL_VERSION | RPCSerializationFlags());
|
|
|
|
|
ss << transaction;
|
|
|
|
|
return SendMessage(MSG_RAWTX, &(*ss.begin()), ss.size());
|
|
|
|
|
}
|
|
|
|
|