 	//----------------------------------
 	//  destination
 	//----------------------------------
-    
+
     /**
      *  @private
      *  Updates the destination for this Consumer and resubscribes if the
-     *  Consumer is currently subscribed. 
+     *  Consumer is currently subscribed.
      */
 	override public function set destination(value:String):void
 	{

	    _log = Log.getLogger("mx.messaging.Consumer");
		_agentType = "consumer";
	}
	
    //--------------------------------------------------------------------------
    //
    // Variables
    // 
    //--------------------------------------------------------------------------

    /**
     *  @private
     *  This is the current number of resubscribe attempts that we've done.
     */
    private var _currentAttempt:int; 
    
    /**
     *  @private
     *  The timer used for resubscribe attempts.

		if (message is ErrorMessage)
			dispatchEvent(MessageFaultEvent.createEvent(ErrorMessage(message)));
		else
			dispatchEvent(MessageEvent.createEvent(MessageEvent.MESSAGE, message));
	}

    //--------------------------------------------------------------------------
    //
    // Protected Methods
    //
    //--------------------------------------------------------------------------

	/**
	 *  Returns a subscribe message.
	 *  This method should be overridden by subclasses if they need custom
	 *  subscribe messages.
	 *
	 *  @return The subscribe CommandMessage.
	 */
	protected function buildSubscribeMessage():CommandMessage
