lib/amqp/session.rb in amqp-1.1.5 vs lib/amqp/session.rb in amqp-1.1.6
- old
+ new
@@ -4,10 +4,11 @@
require "amqp/framing/string/frame"
require "amqp/auth_mechanism_adapter"
require "amqp/broker"
require "amqp/channel"
+require "amqp/channel_id_allocator"
module AMQP
# AMQP session represents connection to the broker. Session objects let you define callbacks for
# various TCP connection lifecycle events, for instance:
#
@@ -31,10 +32,10 @@
# * {Session#connected?}
#
#
# @api public
class Session < EM::Connection
-
+ include AMQP::ChannelIdAllocator
#
# Behaviours
#