   disconnect:(reconnect=true)->
     @autoReconnect = !!reconnect  if reconnect?
     @ws.close()
+
+  connect:->
+    if @servicesEndpoint?
+    then @selectAndConnect()
+    else @connectDirectly()
 
   initBackoff:(options)->
     backoff = options.backoff ? {}

      @connect()
    xhr.send()

  connect:->
    @ws = new SockJS @sockURL
    @ws.addEventListener 'open', @bound 'onopen'
    @ws.addEventListener 'close', @bound 'onclose'

    @namespacedEvents = {}
    @subscriptions = {}
    @initBackoff options  if @autoReconnect
    @connect()

  setP2PKeys:(channelName, { routingKey, bindingKey }, serviceType)->
    channel = @channels[channelName]
