diff --git a/iguana/exchanges/LP_nativeDEX.c b/iguana/exchanges/LP_nativeDEX.c
index a9923fc48..c7b8e5cf5 100644
--- a/iguana/exchanges/LP_nativeDEX.c
+++ b/iguana/exchanges/LP_nativeDEX.c
@@ -347,15 +347,17 @@ void LP_mainloop(char *myipaddr,struct LP_peerinfo *mypeer,uint16_t mypubport,in
 void nn_tests(int32_t pullsock,char *pushaddr)
 {
     int32_t sock,n,timeout,m=0; //void *ptr;
-    if ( (sock= nn_socket(AF_SP,NN_REQ)) >= 0 )
+    if ( (sock= nn_socket(AF_SP,NN_SUB)) >= 0 )
     {
         if ( nn_connect(sock,pushaddr) < 0 )
             printf("connect error %s\n",nn_strerror(nn_errno()));
         else
         {
-            timeout = 1000;
-            nn_setsockopt(sock,NN_SOL_SOCKET,NN_SNDTIMEO,&timeout,sizeof(timeout));
-            n = nn_send(sock,"nn_tests",(int32_t)strlen("nn_tests")+1,0*NN_DONTWAIT);
+            timeout = 1;
+            nn_setsockopt(sock,NN_SOL_SOCKET,NN_RCVTIMEO,&timeout,sizeof(timeout));
+            nn_setsockopt(sock,NN_SUB,NN_SUB_SUBSCRIBE,"",0);
+            nn_setsockopt(pullsock,NN_SOL_SOCKET,NN_SNDTIMEO,&timeout,sizeof(timeout));
+            n = nn_send(pullsock,"nn_tests",(int32_t)strlen("nn_tests")+1,0*NN_DONTWAIT);
             //n = LP_send(sock,"nn_tests",0);//
             //m = nn_recv(pullsock,&ptr,NN_MSG,0);
             //LP_pullsock_check("127.0.0.1",-1,pullsock,0.);
@@ -403,7 +405,7 @@ void LPinit(uint16_t myport,uint16_t mypullport,uint16_t mypubport,double profit
         } else printf("error getting myipaddr\n");
     } else printf("error issuing curl\n");
     nanomsg_tcpname(pushaddr,myipaddr,mypullport);
-    if ( (pullsock= nn_socket(AF_SP,NN_REP)) >= 0 )
+    if ( (pullsock= nn_socket(AF_SP,NN_PUB)) >= 0 )
     {
         timeout = 1;
         nn_setsockopt(pullsock,NN_SOL_SOCKET,NN_RCVTIMEO,&timeout,sizeof(timeout));