         if (maxFrequency > 0)
             msg.headers[CommandMessage.MAX_FREQUENCY_HEADER] = maxFrequency;
         return msg;
-	}
-
-	/**
-	 *  Returns an unsubscribe message.
-	 *  This method should be overridden by subclasses if they need custom
-	 *  unsubscribe messages.
-	 *
-	 *  @param preserveDurable - when true, durable JMS subscriptions are not destroyed
-	 * 			allowing consumers to later resubscribe and receive missed messages
-	 *
-	 *  @return The unsubscribe CommandMessage.
-	 *  
-	 *  @langversion 3.0
-	 *  @playerversion Flash 9
-	 *  @playerversion AIR 1.1
-	 *  @productversion BlazeDS 4
-	 *  @productversion LCDS 3 
-	 */
-	protected function buildUnsubscribeMessage(preserveDurable:Boolean):CommandMessage
-	{
+    }
+
+    /**
+     *  Returns an unsubscribe message.
+     *  This method should be overridden by subclasses if they need custom
+     *  unsubscribe messages.
+     *
+     *  @param preserveDurable - when true, durable JMS subscriptions are not destroyed
+     *          allowing consumers to later resubscribe and receive missed messages
+     *
+     *  @return The unsubscribe CommandMessage.
+     *  
+     *  @langversion 3.0
+     *  @playerversion Flash 9
+     *  @playerversion AIR 1.1
+     *  @productversion BlazeDS 4
+     *  @productversion LCDS 3 
+     */
+    protected function buildUnsubscribeMessage(preserveDurable:Boolean):CommandMessage
+    {
         var msg:CommandMessage = new CommandMessage();
         msg.operation = CommandMessage.UNSUBSCRIBE_OPERATION;
         msg.clientId = clientId;

    //--------------------------------------------------------------------------

    /**
	 *  @private
	 *  Consumers subscribe for messages from a destination and this is the handler
	 *  method that is invoked when a message for this Consumer is pushed or polled
	 *  from the server.
	 *
	 *  @param event The MessageEvent.
	 */
	mx_internal function messageHandler(event:MessageEvent):void
	{
	    // NOTE: This method is invoked directly by the ConsumerMessageDispatcher.
	    // The event flow for a pushed message is:
	    // 1. Channel receives a pushed/polled message and dispatches a message event
	    // 2. Any ChannelSets connected to the Channel will handle these events in ChannelSet.messageHandler();
	    //    simply redispatching them.
	    // 3. Consumers that subscribe to a destination trigger the internal use of a shared ConsumerMessageDispatcher
	    //    that listens for message events from any ChannelSets that Consumers have subscribed over and this helper routes pushed messages to the proper Consumer instances.
	    var message:IMessage = event.message;
	    if (message is CommandMessage)
        {
            var command:CommandMessage = message as CommandMessage;
            switch (command.operation)

    //
    //--------------------------------------------------------------------------

    /**
     *  @private
     *  Custom processing for subscribe, unsubscribe and poll message
     *  acknowledgments.
     *
     *  @param ackMsg The AcknowledgeMessage.
     *
     *  @param msg The original subscribe, unsubscribe or poll message.
     */
    override public function acknowledge(ackMsg:AcknowledgeMessage, msg:IMessage):void
    {
        // Ignore acks for any outstanding messages that return after disconnect() is invoked.
        if (_disconnectBarrier)
            return;

        // Only run Consumer processing if this isn't an error.
        if (!ackMsg.headers[AcknowledgeMessage.ERROR_HINT_HEADER] && (msg is CommandMessage))
        {
            var command:CommandMessage = msg as CommandMessage;

            var op:int = command.operation;

