private ThreadContextBase handlePushModule(final LocalPhysicalVertex pv, final PushModulesThreadUnit unit,
                                               final PushModule<?, ?> instance) {
        final PushModuleContext<?, ?> context = unitController.addPushThreadContext(unit, instance);

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

        return context;
    }