 	    _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 var _currentAttempt:int;
+
     /**
      *  @private
      *  The timer used for resubscribe attempts.

    [Bindable(event="propertyChange")]

	/**
	 *  Contains the timestamp of the most recent message this Consumer 
	 *  has received.
	 *  This value is passed to the destination in a <code>receive()</code> call
	 *  to request that it deliver messages for the Consumer from the timestamp
	 *  forward.
	 *  All messages with a timestamp value greater than the 
	 *  <code>timestamp</code> value will be returned during a poll operation.
	 *  Setting this value to -1 will retrieve all cached messages from the 
	 *  destination.
	 */
	public function get timestamp():Number
	{
	    return _timestamp;
	}
	
	/**
	 *  @private
	 */

		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
