private ThreadContextBase handleMultipleOutputPushModule(final LocalPhysicalVertex pv,
                                                             final PushModulesThreadUnit unit,
                                                             final MultipleOutputPushModule<?, ?> instance) {
        final MultipleOutputPushModuleContext<?, ?> context = unitController
                .addMultipleOutputPushThreadContext(unit, instance);

        createQueues(unit, pv);

        unitController.addThreadInputRoute(unit, pv.getInputQueueThreadLocalId(0), context, 0);
        unitController.addThreadOutputRoute(unit, context, 0, pv.getOutputQueueThreadLocalId(0));
        return context;
    }