class Qpid::Proton::Reactor::SessionPerConnection
Public Class Methods
new()
click to toggle source
# File lib/reactor/session_per_connection.rb, line 26 def initialize @default_session = nil end
Public Instance Methods
on_session_remote_close(event)
click to toggle source
# File lib/reactor/session_per_connection.rb, line 38 def on_session_remote_close(event) event.connection.close @default_session = nil end
session(connection)
click to toggle source
# File lib/reactor/session_per_connection.rb, line 30 def session(connection) if @default_session.nil? @default_session = self.create_session @default_session.context = self end return @default_session end