 
 import flash.events.TimerEvent;
 import flash.utils.Timer;
+
+import mx.collections.ArrayCollection;
 import mx.core.mx_internal;
-import mx.collections.ArrayCollection;
+import mx.events.CollectionEvent;
 import mx.events.PropertyChangeEvent;
-import mx.events.CollectionEvent;
-import mx.logging.ILogger;
-import mx.logging.Log;
+import mx.messaging.errors.MessagingError;
 import mx.messaging.events.MessageEvent;
-import mx.messaging.errors.MessagingError;
-import mx.messaging.messages.AsyncMessage;
 import mx.messaging.messages.CommandMessage;
 import mx.messaging.messages.IMessage;
 

        for (var i:int = 0; i < subscriptions.length; i++)
        {
            var si:SubscriptionInfo = SubscriptionInfo(subscriptions.getItemAt(i));
            subs[(si.subtopic == null ? "" : si.subtopic) + 
                  CommandMessage.SUBTOPIC_SEPARATOR + 
                  (si.selector == null ? "" : si.selector)] = true;
        }
        return subs;
    }

     * @param subtopic The subtopic for the new subscription.
     *
     * @param selector The selector for the new subscription.
     * 
     * @param maxFrequency The maximum number of messages per second the Consumer wants
     * to receive for the subscription. Note that this value overwrites the Consumer
     * wide maxFrequency. 
     */
    public function addSubscription(subtopic:String = null, selector:String = null, maxFrequency:uint = 0):void
    {
        subscriptions.addItem(new SubscriptionInfo(subtopic, selector, maxFrequency));
    }

    /**
