code: def query(self, query):
          
          if isinstance(self.transport, riemann_client.transport.UDPTransport):
              raise Exception('Cannot query the Riemann server over UDP')
          response = self.send_query(query)
          return [self.create_dict(e) for e in response.events]
docs: Sends a query to the Riemann server
  
          >>> client.query('true')
  
          :returns: A list of event dictionaries taken from the response
          :raises Exception: if used with a :py:class:`.UDPTransport`