def start(queue = nil)
      queue.nil? and queue = @queue
      logger.debug "Listener starts..."

      @thread = Thread.new {
        # listen to connFu
        @connfu_stream.start_listening
      }

      while continue do
        logger.debug "Waiting for a message from connFu stream"
        message = @connfu_stream.get
        @counter = @counter + 1

        logger.debug "#{self.class} got message => #{message}"
        # Write in internal Queue
        queue.put(message)
      end

    end
def start(queue = nil)
      queue.nil? and queue = @queue
      logger.debug "Listener starts..."

      @thread = Thread.new {
        # listen to connFu
        @connfu_stream.start_listening
      }

      while continue do
        logger.debug "Waiting for a message from connFu stream"
        message = @connfu_stream.get
        @counter = @counter + 1

        logger.debug "#{self.class} got message => #{message}"
        # Write in internal Queue
        queue.put(message)
      end

    end
max amount of messages to receive

 Listener initializer.

 ==== Parameters
 * +queue+ Connfu::Events instance to forward incoming events to be processed by the Dispatcher class
 * +app_stream+ valid HTTP stream url to connect and listen events
 * +token+ valid token to get access to a connFu Stream
 * +stream_endpoint+ endpoint to open a keepalive HTTP connection

 start listening.
 Should create a new thread and wait to new events to come
 ==== Parameters
 * +queue+ to send incoming events to the Dispatcher class