private ThreadContextBase handleSwitcherModule(final LocalPhysicalVertex pv, final PushModulesThreadUnit unit,
                                                   final FlowSwitcherModule<?> instance) {
        final SwitcherModuleContext<?> context = unitController.addSwitcherContext(unit, instance);

        createQueues(unit, pv);
        unitController.addThreadInputRoute(unit, pv.getInputQueueThreadLocalId(0), context, 0);
        for (int i = 0; i < pv.getOutputQueueCount(); i++)
            unitController.addThreadOutputRoute(unit, context, i, pv.getOutputQueueThreadLocalId(i));

        return context;
    }