Class: Qpid::Proton::Reactor::SessionPerConnection

Inherits:
Object
  • Object
show all
Includes:
Util::Reactor
Defined in:
lib/reactor/session_per_connection.rb

Instance Method Summary collapse

Methods included from Util::Reactor

#create_session

Constructor Details

#initialize ⇒ SessionPerConnection

Returns a new instance of SessionPerConnection.



26
27
28
 
# File 'lib/reactor/session_per_connection.rb', line 26

def initialize
  @default_session = nil
end

Instance Method Details

#on_session_remote_close(event) ⇒ Object 



38
39
40
41
 
# File 'lib/reactor/session_per_connection.rb', line 38

def on_session_remote_close(event)
  event.connection.close
  @default_session = nil
end

#session(connection) ⇒ Object 



30
31
32
33
34
35
36
 
# 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