                     reject(new errors.PubSubFailureResponse(
                       record.message, null, record.code, record.details, record
                     ))
+
               else if record.action == 'msg'
                 {id, action, time, chan, msg} = record
 

                if not promise?
                  message = 'Received a record containing an unknown sequence number.'
                  setImmediate => @emit 'error', new errors.PubSubError("#{message}: #{rec}")

                  logger.error "#{message}: #{rec}"
                else
                  {resolve, reject} = promise

            logger.verbose "Received a record:", rec
            @recordCount += 1

            setImmediate => @emit 'raw-record', rec

            validation = dialect.parseAndAutoValidate rec

            if not validation.isValid
