#NEWLINE# def process_message( self , message ) : #NEWLINE# #INDENT# for target in self . global_config [ self . plugin_name ] [ 'targets' ] : #NEWLINE# #INDENT# strfind = target [ 0 ] #NEWLINE# strreplace = target [ 1 ] #NEWLINE# ( message [ 'headers' ] , count ) = re . subn ( count , strreplace , message [ 'headers' ] ) #NEWLINE# if ( count > 0 ) : #NEWLINE# #INDENT# self . logger . info ( ( "replaced %s matching '%s' header/s %s" % ( count , strfind , message ) ) )