     private var onConnect:MilkCocoa->Void
     
     public init(app_id: String, host: String, onConnect:MilkCocoa->Void) {
-        self.app_id = app_id;
-        self.host = host;
+        self.app_id = app_id
+        self.host = host
         self.dataStores = Dictionary<String, DataStore>()
         self.onConnect = onConnect
         let clientIdPid = "sw" + String(NSProcessInfo().processIdentifier)


    
    public func call(api:String, params: NSMutableDictionary, callback: (Dictionary<String, AnyObject>)->Void, error_handler: (NSError)->Void) {
        params["api"] = api;
        params["appid"] = self.app_id;
        //params["mlkccasid"] = self.session_id;
        getAsync("/api", params: params, callback: callback, error_handler: error_handler);
    }
    
    private func getAsync(path : String, params: NSDictionary, callback: (Dictionary<String, AnyObject>)->Void, error_handler: (NSError)->Void) {

    }
    
    public func dataStore(path: String)->DataStore {
        self.dataStores[path] = DataStore(milkcocoa: self, path: path)
        return self.dataStores[path]!
    }
    
    public func publish(path : String, event : String, params : [String: AnyObject]) {
        let topic:String = self.app_id + "/" + path + "/" + event
        do {
            let data:NSData? = try NSJSONSerialization.dataWithJSONObject(params, options: NSJSONWritingOptions())
            let payload:NSString = NSString(data:data!, encoding:NSUTF8StringEncoding)!
            self.mqtt.publish(topic, withString: payload as String, qos: CocoaMQTTQOS.QOS0)
        } catch let error as NSError {
            // Handle any errors
            print(error)
