Skip to content

Commit

Permalink
Changed calls in zmq to send messages
Browse files Browse the repository at this point in the history
  • Loading branch information
alper committed Aug 13, 2012
1 parent f5e254a commit 9ff3f87
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/ZMQSocket.m
Original file line number Diff line number Diff line change
Expand Up @@ -154,7 +154,7 @@ - (BOOL)sendData:(NSData *)messageData withFlags:(ZMQMessageSendFlags)flags {

[messageData getBytes:zmq_msg_data(&msg) length:zmq_msg_size(&msg)];

err = zmq_send(self.socket, &msg, flags);
err = zmq_sendmsg(self.socket, &msg, flags);
BOOL didSendData = (0 == err);
if (!didSendData) {
ZMQLogError(self, @"zmq_send");
Expand All @@ -177,7 +177,7 @@ - (NSData *)receiveDataWithFlags:(ZMQMessageReceiveFlags)flags {
return nil;
}

err = zmq_recv(self.socket, &msg, flags);
err = zmq_recvmsg(self.socket, &msg, flags);
if (err) {
ZMQLogError(self, @"zmq_recv");
err = zmq_msg_close(&msg);
Expand Down

0 comments on commit 9ff3f87

Please sign in to comment.