private ThreadContextBase handleMutipleInputQueuesPushModule(final LocalPhysicalVertex pv,
                                                                 final PushModulesThreadUnit unit,
                                                                 final MultipleInputQueuesPushModule<?, ?> instance) {
        final MultipleInputQueuesPushModuleContext<?, ?> context = unitController
                .addMultipleInputQueuesPushModuleContext(unit, instance);
        final Vertex v = pv.getVertex();
        createQueues(unit, pv);

        for (int i = 0; i < v.getInputQueueCount(); i++) {
            unitController.addNewInputQueue(context, i);

            unitController.addThreadInputRoute(unit, pv.getInputQueueThreadLocalId(i), context, i);
        }

        unitController.addThreadOutputRoute(unit, context, 0, pv.getOutputQueueThreadLocalId(0));

        return context;
    }