Module Expr Str Assign NameStore Str ImportFrom alias alias alias alias alias alias alias alias alias alias alias ImportFrom alias ImportFrom alias ImportFrom alias identifier ImportFrom alias ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam defaults NameLoad kwarg body Expr Call AttributeLoad NameLoad attr NameLoad NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str If Call NameLoad AttributeLoad NameLoad attr Str body Return Call AttributeLoad AttributeLoad NameLoad attr attr orelse Return NameLoad decorator_list FunctionDef arguments args NameParam defaults kwarg body Assign NameStore Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Dict Str AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad Assign NameStore Call NameLoad IfExp CompareIn Str AttributeLoad NameLoad attr SubscriptLoad AttributeLoad NameLoad attr Index Str ListLoad NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Assign NameStore Call NameLoad IfExp CompareIn Str AttributeLoad NameLoad attr SubscriptLoad AttributeLoad NameLoad attr Index Str ListLoad NameLoad Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad Expr Call AttributeLoad NameLoad attr Dict Str Str BoolOpOr AttributeLoad AttributeLoad NameLoad attr attr Str AttributeLoad AttributeLoad NameLoad attr attr If Call NameLoad AttributeLoad NameLoad attr Str body Expr Call AttributeLoad NameLoad attr Dict Str BoolOpOr AttributeLoad AttributeLoad NameLoad attr attr Str If BoolOpAnd CompareEq AttributeLoad AttributeLoad NameLoad attr attr Str Call NameLoad AttributeLoad NameLoad attr Str body Expr Call AttributeLoad NameLoad attr Dict Str BinOpMod Str TupleLoad AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr AttributeLoad AttributeLoad NameLoad attr attr Assign NameStore Call AttributeLoad NameLoad attr If Call NameLoad NameLoad NameLoad body Assign NameStore Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr NameLoad orelse Assign NameStore AttributeLoad Call AttributeLoad NameLoad attr attr Assign SubscriptStore NameLoad Index Str NameLoad If CompareIn Str NameLoad body Assign SubscriptStore NameLoad Index Str SubscriptLoad NameLoad Index Str Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Assign NameStore Dict Assign NameStore Call AttributeLoad NameLoad attr Str NameLoad Assign NameStore Call AttributeLoad NameLoad attr Str NameLoad Assign NameStore Call AttributeLoad NameLoad attr Str NameLoad Assign NameStore Call AttributeLoad NameLoad attr Str NameLoad Assign NameStore Call AttributeLoad NameLoad attr Str NameLoad Assign NameStore Call AttributeLoad NameLoad attr Str NameLoad Assign NameStore Call AttributeLoad NameLoad attr Str NameLoad If NameLoad body Assign SubscriptStore NameLoad Index Str NameLoad If NameLoad body Assign SubscriptStore NameLoad Index Str NameLoad If NameLoad body Assign SubscriptStore NameLoad Index Str NameLoad If NameLoad body Assign SubscriptStore NameLoad Index Str NameLoad If NameLoad body Assign SubscriptStore NameLoad Index Str NameLoad If NameLoad body Assign SubscriptStore NameLoad Index Str NameLoad orelse If NameLoad body Assign SubscriptStore NameLoad Index Str NameLoad Return NameLoad decorator_list NameLoad FunctionDef arguments args NameParam defaults body Return Call NameLoad AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam defaults body Return Call NameLoad AttributeLoad AttributeLoad NameLoad attr attr Str NameLoad decorator_list decorator_list ClassDef bases NameLoad NameLoad body FunctionDef arguments args NameParam NameParam defaults NameLoad kwarg body Expr Call AttributeLoad NameLoad attr NameLoad keyword NameLoad Expr Call AttributeLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Return NameLoad decorator_list decorator_list ClassDef bases NameLoad body Assign NameStore NameLoad FunctionDef arguments args NameParam NameParam defaults NameLoad kwarg body Assign AttributeStore NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad NameLoad kwarg body If UnaryOpNot AttributeLoad NameLoad attr body Raise Call NameLoad Str Assign NameStore Call AttributeLoad NameLoad attr Assign SubscriptStore NameLoad Index Str AttributeLoad NameLoad attr Return Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad NameLoad decorator_list decorator_list ClassDef bases NameLoad NameLoad body FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad NameLoad kwarg body Expr Call AttributeLoad NameLoad attr NameLoad keyword NameLoad Expr Call AttributeLoad NameLoad attr NameLoad NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str With Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad body Return Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Assign NameStore AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr If NameLoad body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad NameLoad Assign TupleStore NameStore NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad TryExcept body Assign SubscriptStore NameLoad Index Str Call AttributeLoad NameLoad attr handlers ExceptHandler type NameLoad name NameStore body Expr Call AttributeLoad NameLoad attr Str NameLoad Return TupleLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults vararg kwarg body If UnaryOpNot AttributeLoad NameLoad attr body Return Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad NameLoad NameLoad Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad NameLoad Assign NameStore Call AttributeLoad NameLoad attr If Call NameLoad AttributeLoad NameLoad attr Str body If AttributeLoad AttributeLoad NameLoad attr attr body Expr Call AttributeLoad NameLoad attr Str AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr Return NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Assign TupleStore NameStore NameStore NameStore NameStore NameStore AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr Return Call NameLoad Call NameLoad BinOpMult BinOpDiv NameLoad Call NameLoad NameLoad Num decorator_list decorator_list ClassDef bases NameLoad body Assign NameStore NameLoad FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad NameLoad kwarg body Assert NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad If UnaryOpNot CompareIn Str NameLoad body Assign NameStore Call AttributeLoad NameLoad attr Assign SubscriptStore NameLoad Index Str NameLoad Expr Call AttributeLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return AttributeLoad NameLoad attr decorator_list NameLoad FunctionDef arguments args NameParam NameParam defaults body Assign AttributeStore NameLoad attr NameLoad decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam defaults kwarg body Assign NameStore Call AttributeLoad NameLoad attr Assign SubscriptStore NameLoad Index Str AttributeLoad NameLoad attr Assign SubscriptStore NameLoad Index Str AttributeLoad NameLoad attr Return Call AttributeLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return BinOpMod Str TupleLoad Call NameLoad Call NameLoad NameLoad Call NameLoad AttributeLoad NameLoad attr Call NameLoad AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad NameLoad body FunctionDef arguments args NameParam NameParam defaults NameLoad kwarg body Expr Call AttributeLoad NameLoad attr NameLoad keyword NameLoad Expr Call AttributeLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Return NameLoad decorator_list decorator_list ClassDef bases NameLoad body Assign NameStore NameLoad FunctionDef arguments args NameParam NameParam defaults NameLoad kwarg body Assert NameLoad Assign AttributeStore NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults vararg kwarg body Assign NameStore Call AttributeLoad NameLoad attr Assign SubscriptStore NameLoad Index Str AttributeLoad NameLoad attr Return Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad decorator_list decorator_list ClassDef bases NameLoad body Expr Str Pass decorator_list ClassDef bases NameLoad body Expr Str Pass decorator_list ClassDef bases NameLoad NameLoad body FunctionDef arguments args NameParam NameParam NameParam NameParam defaults NameLoad NameLoad NameLoad kwarg body Expr Call AttributeLoad NameLoad attr NameLoad keyword NameLoad Expr Call AttributeLoad NameLoad attr NameLoad keyword NameLoad NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str With Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad body Return Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults vararg kwarg body If UnaryOpNot AttributeLoad NameLoad attr body Return Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad NameLoad NameLoad Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad NameLoad Return Call AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad body Assign NameStore NameLoad FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad NameLoad kwarg body Assert NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return AttributeLoad NameLoad attr decorator_list NameLoad FunctionDef arguments args NameParam NameParam defaults body Assign AttributeStore NameLoad attr NameLoad decorator_list AttributeLoad NameLoad attr FunctionDef arguments args NameParam defaults kwarg body Assign NameStore Call AttributeLoad NameLoad attr Assign SubscriptStore NameLoad Index Str AttributeLoad NameLoad attr Assign SubscriptStore NameLoad Index Str AttributeLoad NameLoad attr Return Call AttributeLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return BinOpMod Str TupleLoad Call NameLoad Call NameLoad NameLoad Call NameLoad AttributeLoad NameLoad attr Call NameLoad AttributeLoad NameLoad attr Call NameLoad AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad NameLoad body FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam defaults NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad vararg kwarg body Assign AttributeStore NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad Expr Call AttributeLoad NameLoad attr Str AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad keyword AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr keyword NameLoad keyword NameLoad keyword NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return BinOpMod Str TupleLoad Call NameLoad Call NameLoad NameLoad Call NameLoad AttributeLoad NameLoad attr Call NameLoad AttributeLoad NameLoad attr Call NameLoad AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults kwarg body Expr Str Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad If CompareIsNot AttributeLoad NameLoad attr NameLoad body Assign AttributeStore NameLoad attr AttributeLoad NameLoad attr Return NameLoad decorator_list decorator_list
N/A N/A ION messaging endpoints N/A __author__ Michael Meisinger, David Stuebe, Dave Foster <dfoster@asascience.com> pyon.net.endpoint Publisher Subscriber EndpointUnit process_interceptors RPCRequestEndpointUnit BaseEndpoint RPCClient RPCResponseEndpointUnit RPCServer PublisherEndpointUnit SubscriberEndpointUnit pyon.ion.event BaseEventSubscriberMixin pyon.util.log log pyon.core.exception Timeout IonTimeout gevent.timeout Timeout ProcessEndpointUnitMixin N/A EndpointUnit N/A N/A 
    Common-base mixin for Process related endpoints.

    This reduces code duplication on either side of the ProcessRPCRequest/ProcessRPCResponse.
     __init__ N/A N/A self process N/A None kwargs N/A N/A N/A N/A EndpointUnit __init__ self kwargs N/A N/A self _process process N/A get_context N/A N/A self N/A N/A N/A 
        Gets context used to build headers for the conversation.

        This method may be overridden for advanced purposes.
         N/A N/A hasattr N/A self _process get_context N/A N/A N/A N/A N/A self _process get_context N/A N/A None N/A _build_invocation N/A N/A self N/A kwargs N/A N/A newkwargs N/A N/A kwargs copy N/A N/A N/A newkwargs update N/A process N/A self _process N/A inv N/A N/A EndpointUnit _build_invocation self newkwargs N/A inv N/A _intercept_msg_in N/A N/A self inv N/A N/A N/A 
        Override for incoming message interception.

        This is a request, so the order should be Message, Process
         N/A inv_one N/A N/A EndpointUnit _intercept_msg_in self inv N/A inv_two N/A process_interceptors N/A N/A process_incoming N/A self interceptors N/A N/A self interceptors N/A process_incoming N/A inv_one N/A inv_two N/A _intercept_msg_out N/A N/A self inv N/A N/A N/A 
        Override for outgoing message interception.

        This is request, so the order should be Process, Message
         N/A inv_one N/A process_interceptors N/A N/A process_outgoing N/A self interceptors N/A N/A self interceptors N/A process_outgoing N/A inv N/A inv_two N/A N/A EndpointUnit _intercept_msg_out self inv_one N/A inv_two N/A _build_header N/A N/A self raw_msg raw_headers N/A N/A N/A 
        Builds the header for this Process-level RPC conversation.
        https://confluence.oceanobservatories.org/display/syseng/CIAD+COI+OV+Common+Message+Format
         N/A header N/A N/A EndpointUnit _build_header self raw_msg raw_headers N/A N/A N/A header update N/A sender-name sender N/A N/A N/A self _process name unnamed-process N/A N/A self _process id N/A N/A hasattr N/A self _process process_type N/A N/A N/A N/A header update N/A sender-type N/A N/A N/A self _process process_type unknown-process-type N/A N/A N/A N/A N/A self _process process_type service N/A hasattr N/A self channel _send_name N/A N/A N/A N/A header update N/A sender-service N/A %s,%s N/A N/A N/A N/A self channel _send_name exchange N/A N/A self _process name N/A context N/A N/A self get_context N/A N/A isinstance context dict N/A N/A new_header N/A N/A self build_security_headers context N/A N/A N/A header update new_header N/A N/A container_id N/A N/A N/A BaseEndpoint _get_container_instance id N/A N/A header N/A origin-container-id container_id N/A N/A conv-id raw_headers N/A N/A N/A header N/A original-conv-id N/A raw_headers N/A conv-id N/A header N/A build_security_headers N/A N/A cls context N/A N/A N/A 
        Examining context, builds a set of headers containing necessary forwarded items.

        @return     A new dictionary containing headers from the context that are important.
         N/A header N/A N/A actor_id N/A N/A context get ion-actor-id None N/A actor_roles N/A N/A context get ion-actor-roles None N/A actor_tokens N/A N/A context get ion-actor-tokens None N/A expiry N/A N/A context get expiry None N/A container_id N/A N/A context get origin-container-id None N/A original_conv_id N/A N/A context get original-conv-id None N/A conv_id N/A N/A context get conv-id None N/A actor_id N/A N/A N/A header N/A ion-actor-id actor_id N/A actor_roles N/A N/A N/A header N/A ion-actor-roles actor_roles N/A actor_tokens N/A N/A N/A header N/A ion-actor-tokens actor_tokens N/A expiry N/A N/A N/A header N/A expiry expiry N/A container_id N/A N/A N/A header N/A origin-container-id container_id N/A original_conv_id N/A N/A N/A header N/A original-conv-id original_conv_id N/A N/A conv_id N/A N/A N/A header N/A original-conv-id conv_id N/A header N/A classmethod _get_sample_name N/A N/A self N/A N/A N/A N/A str N/A N/A self _process id N/A _get_sflow_manager N/A N/A self N/A N/A N/A N/A getattr N/A N/A self _process container sflow_manager None N/A N/A ProcessRPCRequestEndpointUnit N/A ProcessEndpointUnitMixin RPCRequestEndpointUnit N/A __init__ N/A N/A self process N/A None kwargs N/A N/A N/A N/A ProcessEndpointUnitMixin __init__ self process process N/A N/A N/A RPCRequestEndpointUnit __init__ self kwargs N/A _build_header N/A N/A self raw_msg raw_headers N/A N/A N/A 
        Override to direct the calls in _build_header - first the RPCRequest side, then the Process mixin.
         N/A header1 N/A N/A RPCRequestEndpointUnit _build_header self raw_msg raw_headers N/A header2 N/A N/A ProcessEndpointUnitMixin _build_header self raw_msg raw_headers N/A N/A N/A header1 update header2 N/A header1 N/A N/A ProcessRPCClient N/A RPCClient N/A N/A endpoint_unit_type ProcessRPCRequestEndpointUnit __init__ N/A N/A self process N/A None kwargs N/A N/A N/A self _process process N/A N/A N/A RPCClient __init__ self kwargs N/A create_endpoint N/A N/A self to_name existing_channel N/A None None kwargs N/A N/A N/A N/A self _process N/A N/A N/A StandardError No Process specified N/A newkwargs N/A N/A kwargs copy N/A N/A newkwargs N/A process N/A self _process N/A N/A N/A RPCClient create_endpoint self to_name existing_channel newkwargs N/A N/A ProcessRPCResponseEndpointUnit N/A ProcessEndpointUnitMixin RPCResponseEndpointUnit N/A __init__ N/A N/A self process routing_call N/A None None kwargs N/A N/A N/A N/A ProcessEndpointUnitMixin __init__ self process process N/A N/A N/A RPCResponseEndpointUnit __init__ self kwargs N/A N/A self _routing_call routing_call N/A _message_received N/A N/A self msg headers N/A N/A N/A 
        Message received override.

        Sets the process' context here to be picked up by subsequent calls out by this service to other services, or replies.
         N/A N/A N/A N/A self _process push_context headers N/A N/A N/A N/A RPCResponseEndpointUnit _message_received self msg headers N/A message_received N/A N/A self msg headers N/A N/A N/A gc N/A N/A N/A self _routing_obj container governance_controller N/A gc N/A N/A N/A N/A gc check_process_operation_preconditions N/A self _routing_obj msg headers N/A N/A result response_headers N/A N/A RPCResponseEndpointUnit message_received self msg headers N/A N/A N/A N/A response_headers N/A process-saturation N/A N/A self _get_process_saturation N/A N/A N/A Exception N/A ex N/A N/A N/A N/A log warn Could not set process-saturation header, ignoring: %s ex N/A N/A result response_headers N/A _build_header N/A N/A self raw_msg raw_headers N/A N/A N/A 
        Override to direct the calls in _build_header - first the RPCResponse side, then the Process mixin.
         N/A header1 N/A N/A RPCResponseEndpointUnit _build_header self raw_msg raw_headers N/A header2 N/A N/A ProcessEndpointUnitMixin _build_header self raw_msg raw_headers N/A N/A N/A header1 update header2 N/A header1 N/A _make_routing_call N/A N/A self call timeout N/A op_args op_kwargs N/A N/A N/A N/A self _routing_call N/A N/A N/A N/A RPCResponseEndpointUnit _make_routing_call self call timeout op_args op_kwargs N/A ctx N/A N/A N/A self _process get_context N/A ar N/A N/A self _routing_call call ctx op_args op_kwargs N/A res N/A N/A ar get N/A N/A hasattr N/A self _process _proc_state N/A N/A N/A N/A self _process _proc_state_changed N/A N/A N/A N/A log debug Process %s state changed. State=%s N/A N/A self _process id N/A N/A self _process _proc_state N/A N/A N/A N/A self _process _flush_state N/A res N/A _get_process_saturation N/A N/A self N/A N/A N/A 
        Gets the process' saturation, as an integer percentage (process time / total time).
         N/A N/A total _ proc interval interval_run N/A N/A N/A self _process _process time_stats N/A N/A str N/A int N/A N/A interval_run N/A float interval 100 N/A N/A ProcessRPCServer N/A RPCServer N/A N/A endpoint_unit_type ProcessRPCResponseEndpointUnit __init__ N/A N/A self process routing_call N/A None None kwargs N/A N/A process N/A N/A self _process process N/A N/A self _routing_call routing_call N/A N/A N/A service kwargs N/A N/A kwargs N/A N/A kwargs copy N/A N/A kwargs N/A service process N/A N/A N/A RPCServer __init__ self kwargs N/A routing_call N/A N/A self N/A N/A N/A N/A self _routing_call N/A property routing_call N/A N/A self value N/A N/A N/A N/A self _routing_call value N/A N/A routing_call setter create_endpoint N/A N/A self N/A kwargs N/A N/A newkwargs N/A N/A kwargs copy N/A N/A newkwargs N/A process N/A self _process N/A N/A newkwargs N/A routing_call N/A self _routing_call N/A N/A N/A RPCServer create_endpoint self newkwargs N/A __str__ N/A N/A self N/A N/A N/A N/A ProcessRPCServer at %s:
	recv_name: %s
	process: %s N/A N/A hex N/A id self N/A str N/A self _recv_name N/A str N/A self _process N/A N/A ProcessPublisherEndpointUnit N/A ProcessEndpointUnitMixin PublisherEndpointUnit N/A __init__ N/A N/A self process N/A None kwargs N/A N/A N/A N/A ProcessEndpointUnitMixin __init__ self process process N/A N/A N/A PublisherEndpointUnit __init__ self kwargs N/A _build_header N/A N/A self raw_msg raw_headers N/A N/A N/A 
        Override to direct the calls in _build_header - first the Publisher, then the Process mixin.
         N/A header1 N/A N/A PublisherEndpointUnit _build_header self raw_msg raw_headers N/A header2 N/A N/A ProcessEndpointUnitMixin _build_header self raw_msg raw_headers N/A N/A N/A header1 update header2 N/A header1 N/A N/A ProcessPublisher N/A Publisher N/A N/A endpoint_unit_type ProcessPublisherEndpointUnit __init__ N/A N/A self process N/A None kwargs N/A N/A process N/A N/A self _process process N/A N/A N/A Publisher __init__ self kwargs N/A create_endpoint N/A N/A self N/A args kwargs N/A N/A newkwargs N/A N/A kwargs copy N/A N/A newkwargs N/A process N/A self _process N/A N/A N/A Publisher create_endpoint self args newkwargs N/A N/A PublisherError N/A StandardError N/A N/A 
    An exception class for errors in the subscriber
     N/A N/A SubscriberError N/A StandardError N/A N/A 
    An exception class for errors in the subscriber
     N/A N/A ProcessSubscriberEndpointUnit N/A ProcessEndpointUnitMixin SubscriberEndpointUnit N/A __init__ N/A N/A self process callback routing_call N/A None None None kwargs N/A N/A N/A N/A ProcessEndpointUnitMixin __init__ self process process N/A N/A N/A SubscriberEndpointUnit __init__ self callback callback kwargs N/A N/A self _routing_call routing_call N/A _message_received N/A N/A self msg headers N/A N/A N/A 
        Message received override.

        Sets the process' context here to be picked up by subsequent calls out by this service to other services, or replies.
         N/A N/A N/A N/A self _process push_context headers N/A N/A N/A N/A SubscriberEndpointUnit _message_received self msg headers N/A _build_header N/A N/A self raw_msg raw_headers N/A N/A N/A 
        Override to direct the calls in _build_header - first the Subscriber, then the Process mixin.
         N/A header1 N/A N/A SubscriberEndpointUnit _build_header self raw_msg raw_headers N/A header2 N/A N/A ProcessEndpointUnitMixin _build_header self raw_msg raw_headers N/A N/A N/A header1 update header2 N/A header1 N/A _make_routing_call N/A N/A self call timeout N/A op_args op_kwargs N/A N/A N/A N/A self _routing_call N/A N/A N/A N/A SubscriberEndpointUnit _make_routing_call self call timeout op_args op_kwargs N/A ctx N/A N/A N/A self _process get_context N/A ar N/A N/A self _routing_call call ctx op_args op_kwargs N/A N/A N/A ar get N/A N/A ProcessSubscriber N/A Subscriber N/A N/A endpoint_unit_type ProcessSubscriberEndpointUnit __init__ N/A N/A self process routing_call N/A None None kwargs N/A N/A process N/A N/A self _process process N/A N/A self _routing_call routing_call N/A N/A N/A Subscriber __init__ self kwargs N/A routing_call N/A N/A self N/A N/A N/A N/A self _routing_call N/A property routing_call N/A N/A self value N/A N/A N/A N/A self _routing_call value N/A N/A routing_call setter create_endpoint N/A N/A self N/A kwargs N/A N/A newkwargs N/A N/A kwargs copy N/A N/A newkwargs N/A process N/A self _process N/A N/A newkwargs N/A routing_call N/A self _routing_call N/A N/A N/A Subscriber create_endpoint self newkwargs N/A __str__ N/A N/A self N/A N/A N/A N/A ProcessSubscriber at %s:
	recv_name: %s
	process: %s
	cb: %s N/A N/A hex N/A id self N/A str N/A self _recv_name N/A str N/A self _process N/A str N/A self _callback N/A N/A ProcessEventSubscriber N/A ProcessSubscriber BaseEventSubscriberMixin N/A __init__ N/A N/A self xp_name event_type origin queue_name callback sub_type origin_type process routing_call auto_delete N/A None None None None None None None None None None args kwargs N/A N/A N/A self _auto_delete auto_delete N/A N/A N/A BaseEventSubscriberMixin __init__ self xp_name xp_name event_type event_type origin origin queue_name queue_name sub_type sub_type origin_type origin_type N/A N/A N/A log debug ProcessEventSubscriber events pattern %s N/A self binding N/A N/A N/A ProcessSubscriber __init__ self from_name N/A self _ev_recv_name binding N/A self binding callback callback process process routing_call routing_call kwargs N/A __str__ N/A N/A self N/A N/A N/A N/A ProcessEventSubscriber at %s:
	recv_name: %s
	process: %s
	cb: %s N/A N/A hex N/A id self N/A str N/A self _recv_name N/A str N/A self _process N/A str N/A self _callback N/A _create_channel N/A N/A self N/A kwargs N/A N/A 
        Override to set the channel's queue_auto_delete property.
         N/A ch N/A N/A ProcessSubscriber _create_channel self kwargs N/A N/A N/A self _auto_delete None N/A N/A N/A ch queue_auto_delete N/A self _auto_delete N/A ch N/A N/A