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