demos: fix pubsub_forwarder to call nng_init

1 files changed, 9 insertions, 4 deletions

diff --git a/demo/pubsub_forwarder/pubsub_forwarder.c b/demo/pubsub_forwarder/pubsub_forwarder.c
index e79c04b0..8da3a3aa 100644
--- a/demo/pubsub_forwarder/pubsub_forwarder.c
+++ b/demo/pubsub_forwarder/pubsub_forwarder.c
@@ -28,8 +28,6 @@
 #include <stdlib.h>
 
 #include <nng/nng.h>
-#include <nng/protocol/pubsub0/pub.h>
-#include <nng/protocol/pubsub0/sub.h>
 
 #define PROXY_FRONT_URL "tcp://localhost:3327"
 #define PROXY_BACK_URL "tcp://localhost:3328"
@@ -47,16 +45,22 @@ panic_on_error(int should_panic, const char *format, ...)
 }
 
 int
-main()
+main(int argc, char **argv)
 {
 	nng_socket sock_front_end = NNG_SOCKET_INITIALIZER;
 	nng_socket sock_back_end  = NNG_SOCKET_INITIALIZER;
 	int        ret            = 0;
 
+	(void) argc;
+	(void) argv;
+
 	//
 	//  First we need some nng sockets. Not to be confused with network
 	//  sockets
 	//
+	ret = nng_init(NULL);
+	panic_on_error(ret, "Failed to init library\n");
+
 	ret = nng_sub0_open_raw(&sock_front_end);
 	panic_on_error(ret, "Failed to open front end socket\n");
 
@@ -92,5 +96,6 @@ main()
 	    ret, "nng_device returned %d: %s\n", ret, nng_strerror(ret));
 
 	printf("done");
+	nng_fini();
 	return 0;
-}
\ No newline at end of file
+}