#NEWLINE# def remove_consumer_process( self , consumer , name ) : #NEWLINE# #INDENT# 'Remove all details for the specified consumer and process name.\n\n        :param str consumer: The consumer name\n        :param str name: The process name\n\n        ' #NEWLINE# my_pid = os . getpid ( ) #NEWLINE# for conn in self . consumers [ consumer ] . connections : #NEWLINE# #INDENT# if ( name in self . consumers [ consumer ] . connections [ conn ] ) : #NEWLINE# #INDENT# self . consumers [ consumer ] . connections [ conn ] . remove ( name ) #NEWLINE# #UNINDENT# #UNINDENT# if ( name in self . consumers [ consumer ] . processes ) : #NEWLINE# #INDENT# child = self . consumers [ consumer ] . processes [ name ] #NEWLINE# if child . is_alive ( ) : #NEWLINE# #INDENT# if ( child . pid != my_pid ) : #NEWLINE# #INDENT# try : #NEWLINE# #INDENT# child . terminate ( ) #NEWLINE# #UNINDENT# except OSError : #NEWLINE# #INDENT# pass #NEWLINE# #UNINDENT# #UNINDENT# else : #NEWLINE# #INDENT# LOGGER . debug ( 'Child has my pid? %r, %r' , my_pid , child . pid ) #NEWLINE# #UNINDENT# #UNINDENT# del self . consumers [ consumer ] . processes [ name ]