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