src/zeromq.c
/* Initialize the ZeroMQ context, create the sockets and connect/bind them */
Initialize the ZeroMQ context, create the sockets and connect/bind them
Initialize the ZeroMQ context create the sockets and connect / bind them
void zeroMqInit(void) {
  int major, minor, patch;
  if (server.zeromq_publish_bind == NULL) return;
  context = zmq_ctx_new();
  if (context == NULL) {
    redisLog(REDIS_WARNING, "Failed to create ZeroMQ context");
    return;
  }
  zmq_version (&major, &minor, &patch);
  redisLog(REDIS_DEBUG, "ZeroMQ context started, version is %d.%d.%d", major, minor, patch);
  zeroMqSetupPublisher();
}
void zeroMqInit ( void ) { int major , minor , patch ; if ( server . zeromq_publish_bind == NULL ) return ; context = zmq_ctx_new ( ) ; if ( context == NULL ) { redisLog ( REDIS_WARNING , " " ) ; return ; } zmq_version ( & major , & minor , & patch ) ; redisLog ( REDIS_DEBUG , " " , major , minor , patch ) ; zeroMqSetupPublisher ( ) ; }
Initialize the ZeroMQ context, create the sockets and connect/bind them
Initialize the ZeroMQ context create the sockets and connect / bind them
/* skip if we don't have any use for ZeroMQ */