Added support for forward queue/subscriptions