parameters: (self, connector=None, *args, **kwargs)
docstring: Setup connector if supplied. **kwargs will be passed along as arguments
          for your connection.
  
          :param connector: The connector type to make a connection for.
          :type connector: str
          :raises: UnknownConnector
docstring_summary: Setup connector if supplied. **kwargs will be passed along as arguments
          for your connection.
docstring_tokens: Setup connector if supplied . ** kwargs will be passed along as arguments for your connection .
function: def connector(self, connector=None, *args, **kwargs):
          """
          Setup connector if supplied. **kwargs will be passed along as arguments
          for your connection.
  
          :param connector: The connector type to make a connection for.
          :type connector: str
          :raises: UnknownConnector
          """
  
          # If we don't have a connector, or we received an unknown one, raise an
          # Exception.
          if not connector:
              raise UnknownConnector("Need to supply a connector!")
          if connector not in self.connectors:
              raise UnknownConnector("Connector %s is unknown!" % connector)
  
          # AMQP connection
          if connector == 'amqp':
              if 'uri' not in kwargs:
                  raise MissingConfiguration("Need to provide 'uri'!")
              uri = kwargs['uri']
              del kwargs['uri']
              self.connection = self._amqp_connector(uri=uri, **kwargs)
              self.connection.connect()
function_tokens: def connector ( self , connector = None , * args , * * kwargs ) : # If we don't have a connector, or we received an unknown one, raise an # Exception. if not connector : raise UnknownConnector ( "Need to supply a connector!" ) if connector not in self . connectors : raise UnknownConnector ( "Connector %s is unknown!" % connector ) # AMQP connection if connector == 'amqp' : if 'uri' not in kwargs : raise MissingConfiguration ( "Need to provide 'uri'!" ) uri = kwargs [ 'uri' ] del kwargs [ 'uri' ] self . connection = self . _amqp_connector ( uri = uri , * * kwargs ) self . connection . connect ( )