lib/openwfe/participants/socketparticipants.rb in openwferu-0.9.10.653 vs lib/openwfe/participants/socketparticipants.rb in openwferu-0.9.11
- old
+ new
@@ -92,10 +92,12 @@
socket = TCPSocket.new(@host, @port)
socket.puts encode_workitem(workitem)
socket.puts
socket.close_write
+ #print "\n__socket.closed? #{socket.closed?}"
+
reply = fetch_reply(socket)
socket.close
decode_reply(reply)
@@ -188,10 +190,10 @@
# This implementation encodes the workitem as an XML document.
# This is compatible with OpenWFEja.
#
def encode_workitem (wi)
- sxml = OpenWFE::xml_encode(wi)
+ sxml = OpenWFE::XmlCodec::encode(wi)
s = "xmlCoder #{sxml.length}\n"
s << "\n"
s << sxml
s << "\n"