+
+/*
+Initialize and send policies
+*/
+func TestNngPushInitializeandsendPolicies(t *testing.T) {
+ var nngpush = NngPush{}
+ _,_ = createNewPushSocket()
+ policies := []string{"hello","welcome"}
+ nngpush.send(rtmgr.Eps["10.1.1.1:0"],&policies)
+}
+
+/*
+func TestPipeEventHandler(t *testing.T) {
+ var sock mangos.Socket
+ var event mangos.PipeEvent
+ var pipe mangos.Pipe
+
+ var err error
+ sock, err = push.NewSocket()
+ sock.Dial("tcp://127.0.0.1:4555")
+ sock.SetPipeEventHook(pipeEventHandler)
+ pipeEventHandler(event,pipe)
+ t.Log(err)
+}
+*/