# File gofer/messaging/consumer.rb, line 72 def open() session = self.session() @destination.create(session) puts "{%s} opening: #{@destination}" % self.id() session.message_subscribe( :destination => @uuid, :queue => @destination.to_s, :accept_mode => session.message_accept_mode.none) @incoming = session.incoming(@uuid) end