class TCPSumac::Adapter
Public Class Methods
new(messenger)
click to toggle source
# File lib/tcp_sumac/adapter.rb, line 4 def initialize(messenger) @messenger = messenger end
Public Instance Methods
close()
click to toggle source
# File lib/tcp_sumac/adapter.rb, line 26 def close begin @messenger.close rescue TCPMessenger::ClosedError raise Sumac::Adapter::ClosedError end nil end
closed?()
click to toggle source
# File lib/tcp_sumac/adapter.rb, line 35 def closed? @messenger.closed? end
receive()
click to toggle source
# File lib/tcp_sumac/adapter.rb, line 17 def receive begin message = @messenger.receive rescue TCPMessenger::ClosedError raise Sumac::Adapter::ClosedError end message end
send(message)
click to toggle source
# File lib/tcp_sumac/adapter.rb, line 8 def send(message) begin @messenger.send(message) rescue TCPMessenger::ClosedError raise Sumac::Adapter::ClosedError end nil end