lib/ruby_skynet/client.rb in ruby_skynet-0.1.1 vs lib/ruby_skynet/client.rb in ruby_skynet-0.1.2
- old
+ new
@@ -125,11 +125,11 @@
# Send blank ClientHandshake
client_handshake = { 'clientid' => @client_id }
@logger.debug "Sending Client Handshake"
@logger.trace 'Client Handshake', client_handshake
- socket.send(BSON.serialize(client_handshake))
+ socket.write(BSON.serialize(client_handshake))
end
@socket = ResilientSocket::TCPClient.new(params)
end
@@ -162,11 +162,11 @@
'servicemethod' => "#{@service_name}.Forward",
'seq' => socket.user_data,
}
@logger.debug "Sending Header"
@logger.trace 'Header', header
- socket.send(BSON.serialize(header))
+ socket.write(BSON.serialize(header))
@logger.trace 'Parameters:', parameters
# The parameters are placed in the request object in BSON serialized
# form
@@ -186,10 +186,10 @@
}
}
@logger.debug "Sending Request"
@logger.trace 'Request', request
- socket.send(BSON.serialize(request))
+ socket.write(BSON.serialize(request))
end
# Once send is successful it could have been processed, so we can no
# longer retry now otherwise we could create a duplicate
# retry_count += 1