Module Expr Str ImportFrom alias TryExcept body Import alias handlers ExceptHandler type NameLoad body Assign NameStore NameLoad ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam defaults NameLoad body Expr Str Expr Call AttributeLoad NameLoad attr NameLoad NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr Str Str Assign AttributeStore NameLoad attr Call NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr Str Num Assign AttributeStore NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr Str Str Assign AttributeStore NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr Str Str Assign AttributeStore NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr Str Str Assign AttributeStore NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr Str Str Assign AttributeStore NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr Str Str Assign AttributeStore NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr Str Str If UnaryOpNot NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str Assign AttributeStore NameLoad attr NameLoad Return TryExcept body Expr Call AttributeLoad NameLoad attr handlers ExceptHandler type AttributeLoad AttributeLoad NameLoad attr attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str decorator_list FunctionDef arguments args NameParam defaults body Expr Str Assign NameStore Call AttributeLoad Call NameLoad NameLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Dict Str Str Str Str Str Str Str Str Str Str Str Str Str Str Return NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Assign NameStore Call AttributeLoad Call NameLoad NameLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Dict Str Str Str Str Str Str Str Str Str Str Str Str Return NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Assign NameStore Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr keyword NameLoad keyword AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr keyword AttributeLoad NameLoad attr keyword Str decorator_list FunctionDef arguments args NameParam defaults body Expr Str TryExcept body Expr Call AttributeLoad AttributeLoad NameLoad attr attr handlers ExceptHandler type NameLoad body Pass decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str If UnaryOpNot NameLoad body Return Assign NameStore Dict Str Str Str Str Str Str Lambda arguments args defaults AttributeLoad NameLoad attr Lambda arguments args defaults AttributeLoad NameLoad attr Lambda arguments args defaults AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr TryExcept body Expr Call AttributeLoad AttributeLoad NameLoad attr attr keyword AttributeLoad NameLoad attr keyword Call SubscriptLoad NameLoad Index AttributeLoad NameLoad attr keyword BinOpMod Str NameLoad handlers ExceptHandler type NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str Expr Call AttributeLoad NameLoad attr decorator_list decorator_list
N/A N/A 
Output the collected values to RabitMQ Topic Exchange
This allows for 'subscribing' to messages based on the routing key, which is
the metric path
 Handler Handler N/A N/A N/A pika N/A N/A N/A ImportError N/A N/A pika None rmqHandler N/A Handler N/A N/A 
      Implements the abstract Handler class
      Sending data to a RabbitMQ topic exchange.
      The routing key will be the full name of the metric being sent.

      Based on the rmqHandler and zmpqHandler code.
     __init__ N/A N/A self config N/A None N/A N/A 
          Create a new instance of rmqHandler class
         N/A N/A N/A Handler __init__ self config N/A N/A self connection None N/A N/A self channel None N/A N/A self server N/A N/A N/A self config get server 127.0.0.1 N/A N/A self port N/A int N/A N/A N/A self config get port 5672 N/A N/A self topic_exchange N/A N/A N/A self config get topic_exchange diamond N/A N/A self vhost N/A N/A N/A self config get vhost N/A N/A self user N/A N/A N/A self config get user guest N/A N/A self password N/A N/A N/A self config get password guest N/A N/A self routing_key N/A N/A N/A self config get routing_key metric N/A N/A self custom_routing_key N/A N/A N/A self config get custom_routing_key diamond N/A N/A pika N/A N/A N/A N/A N/A self log error pika import failed. Handler disabled N/A N/A self enabled False N/A N/A N/A N/A N/A N/A self _bind N/A N/A N/A N/A N/A pika exceptions AMQPConnectionError N/A N/A N/A N/A N/A self log error Failed to bind to rabbitMQ topic exchange N/A get_default_config_help N/A N/A self N/A N/A N/A 
        Returns the help text for the configuration options for this handler
         N/A config N/A N/A N/A super rmqHandler self get_default_config_help N/A N/A N/A config update N/A server topic_exchange vhost user password routing_key custom_routing_key N/A config N/A get_default_config N/A N/A self N/A N/A N/A 
        Return the default config for the handler
         N/A config N/A N/A N/A super rmqHandler self get_default_config N/A N/A N/A config update N/A server topic_exchange vhost user password port 127.0.0.1 diamond / guest guest 5672 N/A config N/A _bind N/A N/A self N/A N/A N/A 
           Create  socket and bind
         N/A credentials N/A N/A pika PlainCredentials N/A self user N/A self password N/A params N/A N/A pika ConnectionParameters credentials credentials host N/A self server virtual_host N/A self vhost port N/A self port N/A N/A self connection N/A N/A pika BlockingConnection params N/A N/A self channel N/A N/A N/A self connection channel N/A N/A N/A N/A self channel exchange_declare exchange N/A self topic_exchange exchange_type topic N/A __del__ N/A N/A self N/A N/A N/A 
          Destroy instance of the rmqHandler class
         N/A N/A N/A N/A N/A N/A self connection close N/A N/A N/A AttributeError N/A N/A N/A process N/A N/A self metric N/A N/A N/A 
          Process a metric and send it to RabbitMQ topic exchange
         N/A N/A pika N/A N/A N/A routingKeyDic N/A metric custom host metric.path path.prefix collector.path N/A N/A N/A N/A N/A metric path N/A N/A N/A N/A N/A self custom_routing_key N/A N/A N/A N/A N/A metric host N/A metric getMetricPath N/A metric getPathPrefix N/A metric getCollectorPath N/A N/A N/A N/A N/A N/A self channel basic_publish exchange N/A self topic_exchange routing_key N/A N/A routingKeyDic N/A N/A self routing_key body N/A %s metric N/A N/A N/A Exception N/A N/A N/A N/A N/A self log info Failed publishing to rabbitMQ. Attempting reconnect N/A N/A N/A self _bind N/A N/A