class RubyKpi::TCPConnection

Public Class Methods

new(ip, port) click to toggle source

Constructor

# File lib/TCPConnection.rb, line 12
def initialize(ip, port)

  # Read parameters
  @ip = ip
  @port = port

  # Connect
  begin
    @sib_socket = TCPSocket.new(@ip, @port)
  rescue Errno::ECONNREFUSED
    raise SIBError, 'Connection refused'
  end
end

Public Instance Methods

close() click to toggle source

Close the connection

# File lib/TCPConnection.rb, line 50
def close()
  @sib_socket.close()
end
receive_reply() click to toggle source

Receive the reply

# File lib/TCPConnection.rb, line 32
def receive_reply()
  rmsg = ""
  while true do
    begin
      r = @sib_socket.recv(4096)
      rmsg += r
      if rmsg.include?("</SSAP_message>")
        break
      end
    rescue
      raise SIBError, 'Error while receiving a reply'
    end
  end

  return rmsg
end
send_request(msg) click to toggle source

Send the request message

# File lib/TCPConnection.rb, line 27
def send_request(msg)  
  @sib_socket.write(msg)
end