

def _message_received(self, msg, headers):
    "\n        Message received override.\n\n        Sets the process' context here to be picked up by subsequent calls out by this service to other services, or replies.\n        "
    with self._process.push_context(headers):
        return SubscriberEndpointUnit._message_received(self, msg, headers)

dataset/ETHPy150Open ooici/pyon/pyon/ion/endpoint.py ProcessSubscriberEndpointUnit._message_received/original