def prepEndpoint(self, assignedLocalAddr, capabilities):
        if isinstance(assignedLocalAddr.addressDetails, ActorLocalAddress):
            return MpQTEndpoint(assignedLocalAddr.addressDetails.addressInstanceNum,
                                self._nextSubAddress(),
                                Queue(MAX_ACTOR_QUEUESIZE),
                                self._myInputQ, self._adminQ, self._adminAddr)
        return MpQTEndpoint(None,
                            assignedLocalAddr,
                            self._adminQ, self._myInputQ, self._adminQ, self._adminAddr)
In the parent, prepare to establish a new communications endpoint
dataset/ETHPy150Open godaddy/Thespian/thespian/system/transport/MultiprocessQueueTransport.py/MultiprocessQueueTransport.prepEndpoint