From a7f3b2b6674424e7ab356fa7f1778fecc36af7e4 Mon Sep 17 00:00:00 2001
From: Donghwan Kim <flowersinthesand@gmail.com>
Date: Wed, 31 Jul 2013 17:37:08 +0900
Subject: [PATCH] Update atmosphere.js to 2.0.0.RC4

---
 ajax/libs/atmosphere/2.0.0.RC4/atmosphere.js  | 2855 +++++++++++++++++
 .../atmosphere/2.0.0.RC4/atmosphere.min.js    |   16 +
 ajax/libs/atmosphere/package.json             |    2 +-
 3 files changed, 2872 insertions(+), 1 deletion(-)
 create mode 100644 ajax/libs/atmosphere/2.0.0.RC4/atmosphere.js
 create mode 100644 ajax/libs/atmosphere/2.0.0.RC4/atmosphere.min.js

diff --git a/ajax/libs/atmosphere/2.0.0.RC4/atmosphere.js b/ajax/libs/atmosphere/2.0.0.RC4/atmosphere.js
new file mode 100644
index 000000000..3391b5309
--- /dev/null
+++ b/ajax/libs/atmosphere/2.0.0.RC4/atmosphere.js
@@ -0,0 +1,2855 @@
+/**
+ * Copyright 2012 Jeanfrancois Arcand
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+/*
+ * Highly inspired by Portal v1.0
+ * http://github.com/flowersinthesand/portal
+ *
+ * Copyright 2011-2013, Donghwan Kim
+ * Licensed under the Apache License, Version 2.0
+ * http://www.apache.org/licenses/LICENSE-2.0
+ */
+/**
+ * Official documentation of this library: https://github.com/Atmosphere/atmosphere/wiki/jQuery.atmosphere.js-API
+ */
+(function() {
+	
+	"use strict";
+	
+	var version = "2.0.0-javascript",
+		atmosphere = {},
+		guid,
+		requests = [],
+		callbacks = [],
+		hasOwn = Object.prototype.hasOwnProperty;
+	
+	atmosphere = {
+		
+		onError: function(response) {},
+		onClose: function(response) {},
+		onOpen: function(response) {},
+		onReopen: function(response) {},
+		onMessage: function(response) {},
+		onReconnect: function(request, response) {},
+		onMessagePublished: function(response) {},
+		onTransportFailure: function(errorMessage, _request) {},
+		onLocalMessage: function(response) {},
+		onFailureToReconnect: function(request, response) {},
+		
+		AtmosphereRequest: function(options) {
+			
+			/**
+			 * {Object} Request parameters.
+			 * 
+			 * @private
+			 */
+			var _request = {
+				timeout: 300000,
+				method: 'GET',
+				headers: {},
+				contentType: '',
+				callback: null,
+				url: '',
+				data: '',
+				suspend: true,
+				maxRequest: -1,
+				reconnect: true,
+				maxStreamingLength: 10000000,
+				lastIndex: 0,
+				logLevel: 'info',
+				requestCount: 0,
+				fallbackMethod: 'GET',
+				fallbackTransport: 'streaming',
+				transport: 'long-polling',
+				webSocketImpl: null,
+				webSocketBinaryType: null,
+				dispatchUrl: null,
+				webSocketPathDelimiter: "@@",
+				enableXDR: false,
+				rewriteURL: false,
+				attachHeadersAsQueryString: true,
+				executeCallbackBeforeReconnect: false,
+				readyState: 0,
+				lastTimestamp: 0,
+				withCredentials: false,
+				trackMessageLength: false,
+				messageDelimiter: '|',
+				connectTimeout: -1,
+				reconnectInterval: 0,
+				dropAtmosphereHeaders: true,
+				uuid: 0,
+				async: true,
+				shared: false,
+				readResponsesHeaders: false,
+				maxReconnectOnClose: 5,
+				enableProtocol: true,
+				onError: function(response) {},
+				onClose: function(response) {},
+				onOpen: function(response) {},
+				onMessage: function(response) {},
+				onReopen: function(request, response) {},
+				onReconnect: function(request, response) {},
+				onMessagePublished: function(response) {},
+				onTransportFailure: function(reason, request) {},
+				onLocalMessage: function(request) {},
+				onFailureToReconnect: function(request, response) {}
+			};
+			
+			/**
+			 * {Object} Request's last response.
+			 * 
+			 * @private
+			 */
+			var _response = {
+				status: 200,
+				reasonPhrase: "OK",
+				responseBody: '',
+				messages: [],
+				headers: [],
+				state: "messageReceived",
+				transport: "polling",
+				error: null,
+				request: null,
+				partialMessage: "",
+				errorHandled: false,
+				id: 0
+			};
+			
+			/**
+			 * {websocket} Opened web socket.
+			 * 
+			 * @private
+			 */
+			var _websocket = null;
+			
+			/**
+			 * {SSE} Opened SSE.
+			 * 
+			 * @private
+			 */
+			var _sse = null;
+			
+			/**
+			 * {XMLHttpRequest, ActiveXObject} Opened ajax request (in case of http-streaming or long-polling)
+			 * 
+			 * @private
+			 */
+			var _activeRequest = null;
+			
+			/**
+			 * {Object} Object use for streaming with IE.
+			 * 
+			 * @private
+			 */
+			var _ieStream = null;
+			
+			/**
+			 * {Object} Object use for jsonp transport.
+			 * 
+			 * @private
+			 */
+			var _jqxhr = null;
+			
+			/**
+			 * {boolean} If request has been subscribed or not.
+			 * 
+			 * @private
+			 */
+			var _subscribed = true;
+			
+			/**
+			 * {number} Number of test reconnection.
+			 * 
+			 * @private
+			 */
+			var _requestCount = 0;
+			
+			/**
+			 * {boolean} If request is currently aborded.
+			 * 
+			 * @private
+			 */
+			var _abordingConnection = false;
+			
+			/**
+			 * A local "channel' of communication.
+			 * 
+			 * @private
+			 */
+			var _localSocketF = null;
+			
+			/**
+			 * The storage used.
+			 * 
+			 * @private
+			 */
+			var _storageService;
+			
+			/**
+			 * Local communication
+			 * 
+			 * @private
+			 */
+			var _localStorageService = null;
+			
+			/**
+			 * A Unique ID
+			 * 
+			 * @private
+			 */
+			var guid = atmosphere.util.now();
+			
+			/** Trace time */
+			var _traceTimer;
+			
+			// Automatic call to subscribe
+			_subscribe(options);
+			
+			/**
+			 * Initialize atmosphere request object.
+			 * 
+			 * @private
+			 */
+			function _init() {
+				_subscribed = true;
+				_abordingConnection = false;
+				_requestCount = 0;
+				
+				_websocket = null;
+				_sse = null;
+				_activeRequest = null;
+				_ieStream = null;
+			}
+			
+			/**
+			 * Re-initialize atmosphere object.
+			 * 
+			 * @private
+			 */
+			function _reinit() {
+				_clearState();
+				_init();
+			}
+			
+			/**
+			 * 
+			 * @private
+			 */
+			function _verifyStreamingLength(ajaxRequest, rq) {
+				// Wait to be sure we have the full message before closing.
+				if (_response.partialMessage === "" && (rq.transport === 'streaming') && (ajaxRequest.responseText.length > rq.maxStreamingLength)) {
+					_response.messages = [];
+					_invokeClose(true);
+					_disconnect();
+					_clearState();
+					_reconnect(ajaxRequest, rq, 0);
+				}
+			}
+			
+			/**
+			 * Disconnect
+			 * 
+			 * @private
+			 */
+			function _disconnect() {
+				if (_request.enableProtocol && !_request.firstMessage) {
+					var query = "X-Atmosphere-Transport=close&X-Atmosphere-tracking-id=" + _request.uuid;
+					var url = _request.url.replace(/([?&])_=[^&]*/, query);
+					url = url + (url === _request.url ? (/\?/.test(_request.url) ? "&" : "?") + query : "");
+					_request.attachHeadersAsQueryString = false;
+					_request.dropAtmosphereHeaders = true;
+					_request.url = url;
+					_request.transport = 'polling';
+					_pushOnClose("", _request);
+				}
+			}
+			
+			/**
+			 * Close request.
+			 * 
+			 * @private
+			 */
+			function _close() {
+				_request.reconnect = false;
+				_abordingConnection = true;
+				_response.request = _request;
+				_response.state = 'unsubscribe';
+				_response.responseBody = "";
+				_response.status = 408;
+				_invokeCallback();
+				_disconnect();
+				_clearState();
+			}
+			
+			function _clearState() {
+                if (_request.id) {
+                    clearTimeout(_request.id);
+                }
+
+				if (_ieStream != null) {
+					_ieStream.close();
+					_ieStream = null;
+				}
+				if (_jqxhr != null) {
+					_jqxhr.abort();
+					_jqxhr = null;
+				}
+				if (_activeRequest != null) {
+					_activeRequest.abort();
+					_activeRequest = null;
+				}
+				if (_websocket != null) {
+					if (_websocket.webSocketOpened) {
+						_websocket.close();
+					}
+					_websocket = null;
+				}
+				if (_sse != null) {
+					_sse.close();
+					_sse = null;
+				}
+				_clearStorage();
+			}
+			
+			function _clearStorage() {
+				// Stop sharing a connection
+				if (_storageService != null) {
+					// Clears trace timer
+					clearInterval(_traceTimer);
+					// Removes the trace
+					document.cookie = encodeURIComponent("atmosphere-" + _request.url) + "=; expires=Thu, 01 Jan 1970 00:00:00 GMT";
+					// The heir is the parent unless unloading
+					_storageService.signal("close", {
+						reason: "",
+						heir: !_abordingConnection ? guid : (_storageService.get("children") || [])[0]
+					});
+					_storageService.close();
+				}
+				if (_localStorageService != null) {
+					_localStorageService.close();
+				}
+			}
+			
+			/**
+			 * Subscribe request using request transport. <br>
+			 * If request is currently opened, this one will be closed.
+			 * 
+			 * @param {Object} Request parameters.
+			 * @private
+			 */
+			function _subscribe(options) {
+				_reinit();
+				
+				_request = atmosphere.util.extend(_request, options);
+				// Allow at least 1 request
+				_request.mrequest = _request.reconnect;
+				if (!_request.reconnect) {
+					_request.reconnect = true;
+				}
+			}
+			
+			/**
+			 * Check if web socket is supported (check for custom implementation provided by request object or browser implementation).
+			 * 
+			 * @returns {boolean} True if web socket is supported, false otherwise.
+			 * @private
+			 */
+			function _supportWebsocket() {
+				return _request.webSocketImpl != null || window.WebSocket || window.MozWebSocket;
+			}
+			
+			/**
+			 * Check if server side events (SSE) is supported (check for custom implementation provided by request object or browser implementation).
+			 * 
+			 * @returns {boolean} True if web socket is supported, false otherwise.
+			 * @private
+			 */
+			function _supportSSE() {
+				return window.EventSource;
+			}
+			
+			/**
+			 * Open request using request transport. <br>
+			 * If request transport is 'websocket' but websocket can't be opened, request will automatically reconnect using fallback transport.
+			 * 
+			 * @private
+			 */
+			function _execute() {
+				// Shared across multiple tabs/windows.
+				if (_request.shared) {
+					_localStorageService = _local(_request);
+					if (_localStorageService != null) {
+						if (_request.logLevel === 'debug') {
+							atmosphere.util.debug("Storage service available. All communication will be local");
+						}
+						
+						if (_localStorageService.open(_request)) {
+							// Local connection.
+							return;
+						}
+					}
+					
+					if (_request.logLevel === 'debug') {
+						atmosphere.util.debug("No Storage service available.");
+					}
+					// Wasn't local or an error occurred
+					_localStorageService = null;
+				}
+				
+				// Protocol
+				_request.firstMessage = true;
+				_request.isOpen = false;
+				_request.ctime = atmosphere.util.now();
+				
+				if (_request.transport !== 'websocket' && _request.transport !== 'sse') {
+					_executeRequest(_request);
+					
+				} else if (_request.transport === 'websocket') {
+					if (!_supportWebsocket()) {
+						_reconnectWithFallbackTransport("Websocket is not supported, using request.fallbackTransport (" + _request.fallbackTransport
+							+ ")");
+					} else {
+						_executeWebSocket(false);
+					}
+				} else if (_request.transport === 'sse') {
+					if (!_supportSSE()) {
+						_reconnectWithFallbackTransport("Server Side Events(SSE) is not supported, using request.fallbackTransport ("
+							+ _request.fallbackTransport + ")");
+					} else {
+						_executeSSE(false);
+					}
+				}
+			}
+			
+			function _local(request) {
+				var trace, connector, orphan, name = "atmosphere-" + request.url, connectors = {
+					storage: function() {
+						if (!atmosphere.util.supportStorage()) {
+							return;
+						}
+						
+						var storage = window.localStorage, get = function(key) {
+							return atmosphere.util.parseJSON(storage.getItem(name + "-" + key));
+						}, set = function(key, value) {
+							storage.setItem(name + "-" + key, atmosphere.util.stringifyJSON(value));
+						};
+						
+						return {
+							init: function() {
+								set("children", get("children").concat([guid]));
+								atmosphere.util.on("storage.socket", function(event) {
+									event = event.originalEvent;
+									if (event.key === name && event.newValue) {
+										listener(event.newValue);
+									}
+								});
+								return get("opened");
+							},
+							signal: function(type, data) {
+								storage.setItem(name, atmosphere.util.stringifyJSON({
+									target: "p",
+									type: type,
+									data: data
+								}));
+							},
+							close: function() {
+								var children = get("children");
+								
+								atmosphere.util.off("storage.socket");
+								if (children) {
+									if (removeFromArray(children, request.id)) {
+										set("children", children);
+									}
+								}
+							}
+						};
+					},
+					windowref: function() {
+						var win = window.open("", name.replace(/\W/g, ""));
+						
+						if (!win || win.closed || !win.callbacks) {
+							return;
+						}
+						
+						return {
+							init: function() {
+								win.callbacks.push(listener);
+								win.children.push(guid);
+								return win.opened;
+							},
+							signal: function(type, data) {
+								if (!win.closed && win.fire) {
+									win.fire(atmosphere.util.stringifyJSON({
+										target: "p",
+										type: type,
+										data: data
+									}));
+								}
+							},
+							close: function() {
+								// Removes traces only if the parent is alive
+								if (!orphan) {
+									removeFromArray(win.callbacks, listener);
+									removeFromArray(win.children, guid);
+								}
+							}
+						
+						};
+					}
+				};
+				
+				function removeFromArray(array, val) {
+					var i, length = array.length;
+					
+					for (i = 0; i < length; i++) {
+						if (array[i] === val) {
+							array.splice(i, 1);
+						}
+					}
+					
+					return length !== array.length;
+				}
+				
+				// Receives open, close and message command from the parent
+				function listener(string) {
+					var command = atmosphere.util.parseJSON(string), data = command.data;
+					
+					if (command.target === "c") {
+						switch (command.type) {
+						case "open":
+							_open("opening", 'local', _request);
+							break;
+						case "close":
+							if (!orphan) {
+								orphan = true;
+								if (data.reason === "aborted") {
+									_close();
+								} else {
+									// Gives the heir some time to reconnect
+									if (data.heir === guid) {
+										_execute();
+									} else {
+										setTimeout(function() {
+											_execute();
+										}, 100);
+									}
+								}
+							}
+							break;
+						case "message":
+							_prepareCallback(data, "messageReceived", 200, request.transport);
+							break;
+						case "localMessage":
+							_localMessage(data);
+							break;
+						}
+					}
+				}
+				
+				function findTrace() {
+					var matcher = new RegExp("(?:^|; )(" + encodeURIComponent(name) + ")=([^;]*)").exec(document.cookie);
+					if (matcher) {
+						return atmosphere.util.parseJSON(decodeURIComponent(matcher[2]));
+					}
+				}
+				
+				// Finds and validates the parent socket's trace from the cookie
+				trace = findTrace();
+				if (!trace || atmosphere.util.now() - trace.ts > 1000) {
+					return;
+				}
+				
+				// Chooses a connector
+				connector = connectors.storage() || connectors.windowref();
+				if (!connector) {
+					return;
+				}
+				
+				return {
+					open: function() {
+						var parentOpened;
+						
+						// Checks the shared one is alive
+						_traceTimer = setInterval(function() {
+							var oldTrace = trace;
+							trace = findTrace();
+							if (!trace || oldTrace.ts === trace.ts) {
+								// Simulates a close signal
+								listener(atmosphere.util.stringifyJSON({
+									target: "c",
+									type: "close",
+									data: {
+										reason: "error",
+										heir: oldTrace.heir
+									}
+								}));
+							}
+						}, 1000);
+						
+						parentOpened = connector.init();
+						if (parentOpened) {
+							// Firing the open event without delay robs the user of the opportunity to bind connecting event handlers
+							setTimeout(function() {
+								_open("opening", 'local', request);
+							}, 50);
+						}
+						return parentOpened;
+					},
+					send: function(event) {
+						connector.signal("send", event);
+					},
+					localSend: function(event) {
+						connector.signal("localSend", atmosphere.util.stringifyJSON({
+							id: guid,
+							event: event
+						}));
+					},
+					close: function() {
+						// Do not signal the parent if this method is executed by the unload event handler
+						if (!_abordingConnection) {
+							clearInterval(_traceTimer);
+							connector.signal("close");
+							connector.close();
+						}
+					}
+				};
+			}
+			
+			function share() {
+				var storageService, name = "atmosphere-" + _request.url, servers = {
+					// Powered by the storage event and the localStorage
+					// http://www.w3.org/TR/webstorage/#event-storage
+					storage: function() {
+						if (!atmosphere.util.supportStorage()) {
+							return;
+						}
+						
+						var storage = window.localStorage;
+						
+						return {
+							init: function() {
+								// Handles the storage event
+								atmosphere.util.on("storage.socket", function(event) {
+									event = event.originalEvent;
+									// When a deletion, newValue initialized to null
+									if (event.key === name && event.newValue) {
+										listener(event.newValue);
+									}
+								});
+							},
+							signal: function(type, data) {
+								storage.setItem(name, atmosphere.util.stringifyJSON({
+									target: "c",
+									type: type,
+									data: data
+								}));
+							},
+							get: function(key) {
+								return atmosphere.util.parseJSON(storage.getItem(name + "-" + key));
+							},
+							set: function(key, value) {
+								storage.setItem(name + "-" + key, atmosphere.util.stringifyJSON(value));
+							},
+							close: function() {
+								atmosphere.util.off("storage.socket");
+								storage.removeItem(name);
+								storage.removeItem(name + "-opened");
+								storage.removeItem(name + "-children");
+							}
+						
+						};
+					},
+					// Powered by the window.open method
+					// https://developer.mozilla.org/en/DOM/window.open
+					windowref: function() {
+						// Internet Explorer raises an invalid argument error
+						// when calling the window.open method with the name containing non-word characters
+						var neim = name.replace(/\W/g, ""), container = document.getElementById(neim), win;
+						
+						if (!container) {
+							container = document.createElement("div");
+							container.id = neim;
+							container.style.display = "none";
+							container.innerHTML = '<iframe name="' + neim + '" />';
+							document.body.appendChild(container);
+						}
+						
+						win = container.firstChild.contentWindow;
+						
+						return {
+							init: function() {
+								// Callbacks from different windows
+								win.callbacks = [listener];
+								// In IE 8 and less, only string argument can be safely passed to the function in other window
+								win.fire = function(string) {
+									var i;
+									
+									for (i = 0; i < win.callbacks.length; i++) {
+										win.callbacks[i](string);
+									}
+								};
+							},
+							signal: function(type, data) {
+								if (!win.closed && win.fire) {
+									win.fire(atmosphere.util.stringifyJSON({
+										target: "c",
+										type: type,
+										data: data
+									}));
+								}
+							},
+							get: function(key) {
+								return !win.closed ? win[key] : null;
+							},
+							set: function(key, value) {
+								if (!win.closed) {
+									win[key] = value;
+								}
+							},
+							close: function() {}
+						};
+					}
+				};
+				
+				// Receives send and close command from the children
+				function listener(string) {
+					var command = atmosphere.util.parseJSON(string), data = command.data;
+					
+					if (command.target === "p") {
+						switch (command.type) {
+						case "send":
+							_push(data);
+							break;
+						case "localSend":
+							_localMessage(data);
+							break;
+						case "close":
+							_close();
+							break;
+						}
+					}
+				}
+				
+				_localSocketF = function propagateMessageEvent(context) {
+					storageService.signal("message", context);
+				};
+				
+				function leaveTrace() {
+					document.cookie = encodeURIComponent(name) + "=" +
+					// Opera's JSON implementation ignores a number whose a last digit of 0 strangely
+					// but has no problem with a number whose a last digit of 9 + 1
+					encodeURIComponent(atmosphere.util.stringifyJSON({
+						ts: atmosphere.util.now() + 1,
+						heir: (storageService.get("children") || [])[0]
+					}));
+				}
+				
+				// Chooses a storageService
+				storageService = servers.storage() || servers.windowref();
+				storageService.init();
+				
+				if (_request.logLevel === 'debug') {
+					atmosphere.util.debug("Installed StorageService " + storageService);
+				}
+				
+				// List of children sockets
+				storageService.set("children", []);
+				
+				if (storageService.get("opened") != null && !storageService.get("opened")) {
+					// Flag indicating the parent socket is opened
+					storageService.set("opened", false);
+				}
+				// Leaves traces
+				leaveTrace();
+				_traceTimer = setInterval(leaveTrace, 1000);
+				
+				_storageService = storageService;
+			}
+			
+			/**
+			 * @private
+			 */
+			function _open(state, transport, request) {
+				if (_request.shared && transport !== 'local') {
+					share();
+				}
+				
+				if (_storageService != null) {
+					_storageService.set("opened", true);
+				}
+				
+				request.close = function() {
+					_close();
+				};
+				
+				if (_requestCount > 0 && state === 're-connecting') {
+					request.isReopen = true;
+					_tryingToReconnect(_response);
+				} else if (_response.error == null) {
+					_response.request = request;
+					var prevState = _response.state;
+					_response.state = state;
+					var prevTransport = _response.transport;
+					_response.transport = transport;
+					
+					var _body = _response.responseBody;
+					_invokeCallback();
+					_response.responseBody = _body;
+					
+					_response.state = prevState;
+					_response.transport = prevTransport;
+				}
+			}
+			
+			/**
+			 * Execute request using jsonp transport.
+			 * 
+			 * @param request {Object} request Request parameters, if undefined _request object will be used.
+			 * @private
+			 */
+			function _jsonp(request) {
+				// When CORS is enabled, make sure we force the proper transport.
+				request.transport = "jsonp";
+				
+				var rq = _request, script;
+				if ((request != null) && (typeof (request) !== 'undefined')) {
+					rq = request;
+				}
+				
+				_jqxhr = {
+					open: function() {
+						var callback = "atmosphere" + (++guid);
+						
+						function poll() {
+							var url = rq.url;
+							if (rq.dispatchUrl != null) {
+								url += rq.dispatchUrl;
+							}
+							
+							var data = rq.data;
+							if (rq.attachHeadersAsQueryString) {
+								url = _attachHeaders(rq);
+								if (data !== '') {
+									url += "&X-Atmosphere-Post-Body=" + encodeURIComponent(data);
+								}
+								data = '';
+							}
+							
+							var head = document.head || document.getElementsByTagName("head")[0] || document.documentElement;
+							
+							script = document.createElement("script");
+							script.src = url + "&jsonpTransport=" + callback;
+							script.clean = function() {
+								script.clean = script.onerror = script.onload = script.onreadystatechange = null;
+								if (script.parentNode) {
+									script.parentNode.removeChild(script);
+								}
+							};
+							script.onload = script.onreadystatechange = function() {
+								if (!script.readyState || /loaded|complete/.test(script.readyState)) {
+									script.clean();
+								}
+							};
+							script.onerror = function() {
+								script.clean();
+								_onError(0, "maxReconnectOnClose reached");
+							};
+							
+							head.insertBefore(script, head.firstChild);
+						}
+						
+						// Attaches callback
+						window[callback] = function(msg) {
+							if (rq.reconnect) {
+								if (rq.maxRequest === -1 || rq.requestCount++ < rq.maxRequest) {
+									// _readHeaders(_jqxhr, rq);
+									
+									if (!rq.executeCallbackBeforeReconnect) {
+										_reconnect(_jqxhr, rq, 0);
+									}
+									
+									if (msg != null && typeof msg !== 'string') {
+										try {
+											msg = msg.message;
+										} catch (err) {
+											// The message was partial
+										}
+									}
+									
+									var skipCallbackInvocation = _trackMessageSize(msg, rq, _response);
+									if (!skipCallbackInvocation) {
+										_prepareCallback(_response.responseBody, "messageReceived", 200, rq.transport);
+									}
+									
+									if (rq.executeCallbackBeforeReconnect) {
+										_reconnect(_jqxhr, rq, 0);
+									}
+								} else {
+									atmosphere.util.log(_request.logLevel, ["JSONP reconnect maximum try reached " + _request.requestCount]);
+									_onError(0, "maxRequest reached");
+								}
+							}
+						};
+						setTimeout(function() {
+							poll();
+						}, 50);
+					},
+					abort: function() {
+						if (script.clean) {
+							script.clean();
+						}
+					}
+				};
+				
+				_jqxhr.open();
+			}
+			
+			/**
+			 * Build websocket object.
+			 * 
+			 * @param location {string} Web socket url.
+			 * @returns {websocket} Web socket object.
+			 * @private
+			 */
+			function _getWebSocket(location) {
+				if (_request.webSocketImpl != null) {
+					return _request.webSocketImpl;
+				} else {
+					if (window.WebSocket) {
+						return new WebSocket(location);
+					} else {
+						return new MozWebSocket(location);
+					}
+				}
+			}
+			
+			/**
+			 * Build web socket url from request url.
+			 * 
+			 * @return {string} Web socket url (start with "ws" or "wss" for secure web socket).
+			 * @private
+			 */
+			function _buildWebSocketUrl() {
+				return atmosphere.util.getAbsoluteURL(_attachHeaders(_request)).replace(/^http/, "ws");
+			}
+			
+			/**
+			 * Build SSE url from request url.
+			 * 
+			 * @return a url with Atmosphere's headers
+			 * @private
+			 */
+			function _buildSSEUrl() {
+				var url = _attachHeaders(_request);
+				return url;
+			}
+			
+			/**
+			 * Open SSE. <br>
+			 * Automatically use fallback transport if SSE can't be opened.
+			 * 
+			 * @private
+			 */
+			function _executeSSE(sseOpened) {
+				
+				_response.transport = "sse";
+				
+				var location = _buildSSEUrl(_request.url);
+				
+				if (_request.logLevel === 'debug') {
+					atmosphere.util.debug("Invoking executeSSE");
+					atmosphere.util.debug("Using URL: " + location);
+				}
+				
+				if (_request.enableProtocol && sseOpened) {
+					var time = atmosphere.util.now() - _request.ctime;
+					_request.lastTimestamp = Number(_request.stime) + Number(time);
+				}
+				
+				if (sseOpened && !_request.reconnect) {
+					if (_sse != null) {
+						_clearState();
+					}
+					return;
+				}
+				
+				try {
+					_sse = new EventSource(location, {
+						withCredentials: _request.withCredentials
+					});
+				} catch (e) {
+					_onError(0, e);
+					_reconnectWithFallbackTransport("SSE failed. Downgrading to fallback transport and resending");
+					return;
+				}
+				
+				if (_request.connectTimeout > 0) {
+					_request.id = setTimeout(function() {
+						if (!sseOpened) {
+							_clearState();
+						}
+					}, _request.connectTimeout);
+				}
+				
+				_sse.onopen = function(event) {
+					_timeout(_request);
+					if (_request.logLevel === 'debug') {
+						atmosphere.util.debug("SSE successfully opened");
+					}
+					
+					if (!_request.enableProtocol) {
+						if (!sseOpened) {
+							_open('opening', "sse", _request);
+						} else {
+							_open('re-opening', "sse", _request);
+						}
+					}
+					sseOpened = true;
+					
+					if (_request.method === 'POST') {
+						_response.state = "messageReceived";
+						_sse.send(_request.data);
+					}
+				};
+				
+				_sse.onmessage = function(message) {
+					_timeout(_request);
+					
+					if (!_request.enableXDR && message.origin && message.origin !== window.location.protocol + "//" + window.location.host) {
+						atmosphere.util.log(_request.logLevel, ["Origin was not " + window.location.protocol + "//" + window.location.host]);
+						return;
+					}
+					
+					_response.state = 'messageReceived';
+					_response.status = 200;
+					
+					message = message.data;
+					var skipCallbackInvocation = _trackMessageSize(message, _request, _response);
+					
+					// https://github.com/remy/polyfills/blob/master/EventSource.js
+					// Since we polling.
+					if (_sse.URL) {
+						_sse.interval = 100;
+						_sse.URL = _buildSSEUrl(_request.url);
+					}
+					
+					if (!skipCallbackInvocation) {
+						_invokeCallback();
+						_response.responseBody = '';
+						_response.messages = [];
+					}
+				};
+				
+				_sse.onerror = function(message) {
+					clearTimeout(_request.id);
+					_invokeClose(sseOpened);
+					_clearState();
+					
+					if (_abordingConnection) {
+						atmosphere.util.log(_request.logLevel, ["SSE closed normally"]);
+					} else if (!sseOpened) {
+						_reconnectWithFallbackTransport("SSE failed. Downgrading to fallback transport and resending");
+					} else if (_request.reconnect && (_response.transport === 'sse')) {
+						if (_requestCount++ < _request.maxReconnectOnClose) {
+							_open('re-connecting', _request.transport, _request);
+							_request.id = setTimeout(function() {
+								_executeSSE(true);
+							}, _request.reconnectInterval);
+							_response.responseBody = "";
+							_response.messages = [];
+						} else {
+							atmosphere.util.log(_request.logLevel, ["SSE reconnect maximum try reached " + _requestCount]);
+							_onError(0, "maxReconnectOnClose reached");
+						}
+					}
+				};
+			}
+			
+			/**
+			 * Open web socket. <br>
+			 * Automatically use fallback transport if web socket can't be opened.
+			 * 
+			 * @private
+			 */
+			function _executeWebSocket(webSocketOpened) {
+				
+				_response.transport = "websocket";
+				
+				if (_request.enableProtocol && webSocketOpened) {
+					var time = atmosphere.util.now() - _request.ctime;
+					_request.lastTimestamp = Number(_request.stime) + Number(time);
+				}
+				
+				var location = _buildWebSocketUrl(_request.url);
+				if (_request.logLevel === 'debug') {
+					atmosphere.util.debug("Invoking executeWebSocket");
+					atmosphere.util.debug("Using URL: " + location);
+				}
+				
+				if (webSocketOpened && !_request.reconnect) {
+					if (_websocket != null) {
+						_clearState();
+					}
+					return;
+				}
+				
+				_websocket = _getWebSocket(location);
+				if (_request.webSocketBinaryType != null) {
+					_websocket.binaryType = _request.webSocketBinaryType;
+				}
+				
+				if (_request.connectTimeout > 0) {
+					_request.id = setTimeout(function() {
+						if (!webSocketOpened) {
+							var _message = {
+								code: 1002,
+								reason: "",
+								wasClean: false
+							};
+							_websocket.onclose(_message);
+							// Close it anyway
+							try {
+								_clearState();
+							} catch (e) {}
+							return;
+						}
+						
+					}, _request.connectTimeout);
+				}
+				
+				_websocket.onopen = function(message) {
+					_timeout(_request);
+					
+					if (_request.logLevel === 'debug') {
+						atmosphere.util.debug("Websocket successfully opened");
+					}
+					
+					if (!_request.enableProtocol) {
+						if (!webSocketOpened) {
+							_open('opening', "websocket", _request);
+						} else {
+							_open('re-opening', "websocket", _request);
+						}
+					}
+					
+					webSocketOpened = true;
+					_websocket.webSocketOpened = webSocketOpened;
+					
+					if (_request.method === 'POST') {
+						_response.state = "messageReceived";
+						_websocket.send(_request.data);
+					}
+				};
+				
+				_websocket.onmessage = function(message) {
+					_timeout(_request);
+					
+					_response.state = 'messageReceived';
+					_response.status = 200;
+					
+					message = message.data;
+					var isString = typeof (message) === 'string';
+					if (isString) {
+						var skipCallbackInvocation = _trackMessageSize(message, _request, _response);
+						if (!skipCallbackInvocation) {
+							_invokeCallback();
+							_response.responseBody = '';
+							_response.messages = [];
+						}
+					} else {
+						if (!_handleProtocol(_request, message))
+							return;
+						
+						_response.responseBody = message;
+						_invokeCallback();
+						_response.responseBody = null;
+					}
+				};
+				
+				_websocket.onerror = function(message) {
+					clearTimeout(_request.id);
+				};
+				
+				_websocket.onclose = function(message) {
+					clearTimeout(_request.id);
+					if (_response.state === 'closed')
+						return;
+					
+					var reason = message.reason;
+					if (reason === "") {
+						switch (message.code) {
+						case 1000:
+							reason = "Normal closure; the connection successfully completed whatever purpose for which " + "it was created.";
+							break;
+						case 1001:
+							reason = "The endpoint is going away, either because of a server failure or because the "
+								+ "browser is navigating away from the page that opened the connection.";
+							break;
+						case 1002:
+							reason = "The endpoint is terminating the connection due to a protocol error.";
+							break;
+						case 1003:
+							reason = "The connection is being terminated because the endpoint received data of a type it "
+								+ "cannot accept (for example, a text-only endpoint received binary data).";
+							break;
+						case 1004:
+							reason = "The endpoint is terminating the connection because a data frame was received that " + "is too large.";
+							break;
+						case 1005:
+							reason = "Unknown: no status code was provided even though one was expected.";
+							break;
+						case 1006:
+							reason = "Connection was closed abnormally (that is, with no close frame being sent).";
+							break;
+						}
+					}
+					
+					atmosphere.util.warn("Websocket closed, reason: " + reason);
+					atmosphere.util.warn("Websocket closed, wasClean: " + message.wasClean);
+					
+					_invokeClose(webSocketOpened);
+					
+					_response.state = 'closed';
+					
+					if (_abordingConnection) {
+						atmosphere.util.log(_request.logLevel, ["Websocket closed normally"]);
+					} else if (!webSocketOpened) {
+						_reconnectWithFallbackTransport("Websocket failed. Downgrading to Comet and resending");
+						
+					} else if (_request.reconnect && _response.transport === 'websocket') {
+						_clearState();
+						if (_requestCount++ < _request.maxReconnectOnClose) {
+							_open('re-connecting', _request.transport, _request);
+							_request.id = setTimeout(function() {
+								_response.responseBody = "";
+								_response.messages = [];
+								_executeWebSocket(true);
+							}, _request.reconnectInterval);
+						} else {
+							atmosphere.util.log(_request.logLevel, ["Websocket reconnect maximum try reached " + _request.requestCount]);
+							atmosphere.util.warn("Websocket error, reason: " + message.reason);
+							_onError(0, "maxReconnectOnClose reached");
+						}
+					}
+				};
+				
+				if (_websocket.url === undefined) {
+					// Android 4.1 does not really support websockets and fails silently
+					_websocket.onclose({
+						reason: "Android 4.1 does not support websockets.",
+						wasClean: false
+					});
+				}
+			}
+			
+			function _handleProtocol(request, message) {
+				// The first messages is always the uuid.
+				var b = true;
+				if (atmosphere.util.trim(message) !== 0 && request.enableProtocol && request.firstMessage) {
+					request.firstMessage = false;
+					var messages = message.split(request.messageDelimiter);
+					var pos = messages.length === 2 ? 0 : 1;
+					request.uuid = atmosphere.util.trim(messages[pos]);
+					request.stime = atmosphere.util.trim(messages[pos + 1]);
+					b = false;
+					if (request.transport !== 'long-polling') {
+						_triggerOpen(request);
+					}
+				} else {
+					_triggerOpen(request);
+				}
+				return b;
+			}
+			
+			function _timeout(_request) {
+				clearTimeout(_request.id);
+				if (_request.timeout > 0 &&_request.transport !== 'polling') {
+					_request.id = setTimeout(function() {
+						_invokeClose(true);
+						_clearState();
+						_disconnect();
+					}, _request.timeout);
+				}
+			}
+			
+			function _onError(code, reason) {
+				_clearState();
+				clearTimeout(_request.id);
+				_response.state = 'error';
+				_response.reasonPhrase = reason;
+				_response.responseBody = "";
+				_response.status = code;
+				_response.messages = [];
+				_invokeCallback();
+			}
+			
+			/**
+			 * Track received message and make sure callbacks/functions are only invoked when the complete message has been received.
+			 * 
+			 * @param message
+			 * @param request
+			 * @param response
+			 */
+			function _trackMessageSize(message, request, response) {
+				if (!_handleProtocol(_request, message))
+					return true;
+				if (message.length === 0)
+					return true;
+				
+				if (request.trackMessageLength) {
+					// prepend partialMessage if any
+                    message = response.partialMessage + message;
+					
+					var messages = [];
+					var messageStart = message.indexOf(request.messageDelimiter);
+					while (messageStart !== -1) {
+						var str = atmosphere.util.trim(message.substring(0, messageStart));
+						var messageLength = +str;
+						if (isNaN(messageLength))
+							throw new Error('message length "' + str + '" is not a number');
+						messageStart += request.messageDelimiter.length;
+						if (messageStart + messageLength > message.length) {
+							// message not complete, so there is no trailing messageDelimiter
+							messageStart = -1;
+						} else {
+							// message complete, so add it
+							messages.push(message.substring(messageStart, messageStart + messageLength));
+							// remove consumed characters
+							message = message.substring(messageStart + messageLength, message.length);
+							messageStart = message.indexOf(request.messageDelimiter);
+						}
+					}
+					
+					/* keep any remaining data */
+					response.partialMessage = message;
+					
+					if (messages.length !== 0) {
+						response.responseBody = messages.join(request.messageDelimiter);
+						response.messages = messages;
+						return false;
+					} else {
+						response.responseBody = "";
+						response.messages = [];
+						return true;
+					}
+				} else {
+					response.responseBody = message;
+				}
+				return false;
+			}
+			
+			/**
+			 * Reconnect request with fallback transport. <br>
+			 * Used in case websocket can't be opened.
+			 * 
+			 * @private
+			 */
+			function _reconnectWithFallbackTransport(errorMessage) {
+				atmosphere.util.log(_request.logLevel, [errorMessage]);
+				
+				if (typeof (_request.onTransportFailure) !== 'undefined') {
+					_request.onTransportFailure(errorMessage, _request);
+				} else if (typeof (atmosphere.util.onTransportFailure) !== 'undefined') {
+					atmosphere.util.onTransportFailure(errorMessage, _request);
+				}
+				
+				_request.transport = _request.fallbackTransport;
+				var reconnectInterval = _request.connectTimeout === -1 ? 0 : _request.connectTimeout;
+				if (_request.reconnect && _request.transport !== 'none' || _request.transport == null) {
+					_request.method = _request.fallbackMethod;
+					_response.transport = _request.fallbackTransport;
+					_request.fallbackTransport = 'none';
+					_request.id = setTimeout(function() {
+						_execute();
+					}, reconnectInterval);
+				} else {
+					_onError(500, "Unable to reconnect with fallback transport");
+				}
+			}
+			
+			/**
+			 * Get url from request and attach headers to it.
+			 * 
+			 * @param request {Object} request Request parameters, if undefined _request object will be used.
+			 * 
+			 * @returns {Object} Request object, if undefined, _request object will be used.
+			 * @private
+			 */
+			function _attachHeaders(request, url) {
+				var rq = _request;
+				if ((request != null) && (typeof (request) !== 'undefined')) {
+					rq = request;
+				}
+				
+				if (url == null) {
+					url = rq.url;
+				}
+				
+				// If not enabled
+				if (!rq.attachHeadersAsQueryString)
+					return url;
+				
+				// If already added
+				if (url.indexOf("X-Atmosphere-Framework") !== -1) {
+					return url;
+				}
+				
+				url += (url.indexOf('?') !== -1) ? '&' : '?';
+				url += "X-Atmosphere-tracking-id=" + rq.uuid;
+				url += "&X-Atmosphere-Framework=" + version;
+				url += "&X-Atmosphere-Transport=" + rq.transport;
+				
+				if (rq.trackMessageLength) {
+					url += "&X-Atmosphere-TrackMessageSize=" + "true";
+				}
+				
+				if (rq.lastTimestamp != null) {
+					url += "&X-Cache-Date=" + rq.lastTimestamp;
+				} else {
+					url += "&X-Cache-Date=" + 0;
+				}
+				
+				if (rq.contentType !== '') {
+					url += "&Content-Type=" + rq.contentType;
+				}
+				
+				if (rq.enableProtocol) {
+					url += "&X-atmo-protocol=true";
+				}
+				
+				atmosphere.util.each(rq.headers, function(name, value) {
+					var h = atmosphere.util.isFunction(value) ? value.call(this, rq, request, _response) : value;
+					if (h != null) {
+						url += "&" + encodeURIComponent(name) + "=" + encodeURIComponent(h);
+					}
+				});
+				
+				return url;
+			}
+			
+			function _triggerOpen(rq) {
+				if (!rq.isOpen) {
+					rq.isOpen = true;
+					_open('opening', rq.transport, rq);
+				} else if (rq.isReopen) {
+					rq.isReopen = false;
+					_open('re-opening', rq.transport, rq);
+				}
+			}
+			
+			/**
+			 * Execute ajax request. <br>
+			 * 
+			 * @param request {Object} request Request parameters, if undefined _request object will be used.
+			 * @private
+			 */
+			function _executeRequest(request) {
+				var rq = _request;
+				if ((request != null) || (typeof (request) !== 'undefined')) {
+					rq = request;
+				}
+				
+				rq.lastIndex = 0;
+				rq.readyState = 0;
+				
+				// CORS fake using JSONP
+				if ((rq.transport === 'jsonp') || ((rq.enableXDR) && (atmosphere.util.checkCORSSupport()))) {
+					_jsonp(rq);
+					return;
+				}
+				
+				if (atmosphere.util.browser.msie && atmosphere.util.browser.version < 10) {
+					if ((rq.transport === 'streaming')) {
+						if (rq.enableXDR && window.XDomainRequest) {
+							_ieXDR(rq);
+						} else {
+							_ieStreaming(rq);
+						}
+						return;
+					}
+					
+					if ((rq.enableXDR) && (window.XDomainRequest)) {
+						_ieXDR(rq);
+						return;
+					}
+				}
+				
+				var reconnectF = function() {
+					rq.lastIndex = 0;
+					if (rq.reconnect && _requestCount++ < rq.maxReconnectOnClose) {
+						_open('re-connecting', request.transport, request);
+						_reconnect(ajaxRequest, rq, request.reconnectInterval);
+					} else {
+						_onError(0, "maxReconnectOnClose reached");
+					}
+				};
+				
+				if (rq.force || (rq.reconnect && (rq.maxRequest === -1 || rq.requestCount++ < rq.maxRequest))) {
+					rq.force = false;
+					
+					var ajaxRequest = atmosphere.util.xhr();
+					ajaxRequest.hasData = false;
+					
+					_doRequest(ajaxRequest, rq, true);
+					
+					if (rq.suspend) {
+						_activeRequest = ajaxRequest;
+					}
+					
+					if (rq.transport !== 'polling') {
+						_response.transport = rq.transport;
+						
+						ajaxRequest.onabort = function() {
+							_invokeClose(true);
+						};
+						
+						ajaxRequest.onerror = function() {
+							_response.error = true;
+							try {
+								_response.status = XMLHttpRequest.status;
+							} catch (e) {
+								_response.status = 500;
+							}
+							
+							if (!_response.status) {
+								_response.status = 500;
+							}
+							_clearState();
+							if (!_response.errorHandled) {
+								reconnectF();
+							}
+						};
+					}
+					
+					ajaxRequest.onreadystatechange = function() {
+						if (_abordingConnection) {
+							return;
+						}
+						
+						_response.error = null;
+						var skipCallbackInvocation = false;
+						var update = false;
+						
+						// Opera doesn't call onerror if the server disconnect.
+						if (atmosphere.util.browser.opera && rq.transport === 'streaming' && rq.readyState > 2 && ajaxRequest.readyState === 4) {
+							
+							_clearState();
+							reconnectF();
+							return;
+						}
+						
+						rq.readyState = ajaxRequest.readyState;
+						
+						if (rq.transport === 'streaming' && ajaxRequest.readyState >= 3) {
+							update = true;
+						} else if (rq.transport === 'long-polling' && ajaxRequest.readyState === 4) {
+							update = true;
+						}
+						_timeout(_request);
+						
+						if ((!rq.enableProtocol || !request.firstMessage) && rq.transport !== 'polling' && ajaxRequest.readyState === 2) {
+							_triggerOpen(rq);
+						}
+						
+						if (update) {
+							
+							// MSIE 9 and lower status can be higher than 1000, Chrome can be 0
+							var status = 0;
+							if (ajaxRequest.readyState !== 0) {
+								status = ajaxRequest.status > 1000 ? 0 : ajaxRequest.status;
+							}
+							
+							if (status >= 300 || status === 0) {
+								// Prevent onerror callback to be called
+								_response.errorHandled = true;
+								_clearState();
+								reconnectF();
+								return;
+							}
+							var responseText = ajaxRequest.responseText;
+							
+							if (atmosphere.util.trim(responseText).length === 0 && rq.transport === 'long-polling') {
+								// For browser that aren't support onabort
+								if (!ajaxRequest.hasData) {
+									reconnectF();
+								} else {
+									ajaxRequest.hasData = false;
+								}
+								return;
+							}
+							ajaxRequest.hasData = true;
+							
+							_readHeaders(ajaxRequest, _request);
+							
+							if (rq.transport === 'streaming') {
+								if (!atmosphere.util.browser.opera) {
+									var message = responseText.substring(rq.lastIndex, responseText.length);
+									skipCallbackInvocation = _trackMessageSize(message, rq, _response);
+									
+									rq.lastIndex = responseText.length;
+									if (skipCallbackInvocation) {
+										return;
+									}
+								} else {
+									atmosphere.util.iterate(function() {
+										if (_response.status !== 500 && ajaxRequest.responseText.length > rq.lastIndex) {
+											try {
+												_response.status = ajaxRequest.status;
+												_response.headers = atmosphere.util.parseHeaders(ajaxRequest.getAllResponseHeaders());
+												
+												_readHeaders(ajaxRequest, _request);
+												
+											} catch (e) {
+												_response.status = 404;
+											}
+											_timeout(_request);
+											
+											_response.state = "messageReceived";
+											var message = ajaxRequest.responseText.substring(rq.lastIndex);
+											rq.lastIndex = ajaxRequest.responseText.length;
+											
+											skipCallbackInvocation = _trackMessageSize(message, rq, _response);
+											if (!skipCallbackInvocation) {
+												_invokeCallback();
+											}
+											
+											_verifyStreamingLength(ajaxRequest, rq);
+										} else if (_response.status > 400) {
+											// Prevent replaying the last message.
+											rq.lastIndex = ajaxRequest.responseText.length;
+											return false;
+										}
+									}, 0);
+								}
+							} else {
+								skipCallbackInvocation = _trackMessageSize(responseText, rq, _response);
+							}
+							
+							try {
+								_response.status = ajaxRequest.status;
+								_response.headers = atmosphere.util.parseHeaders(ajaxRequest.getAllResponseHeaders());
+								
+								_readHeaders(ajaxRequest, rq);
+							} catch (e) {
+								_response.status = 404;
+							}
+							
+							if (rq.suspend) {
+								_response.state = _response.status === 0 ? "closed" : "messageReceived";
+							} else {
+								_response.state = "messagePublished";
+							}
+							
+							var isAllowedToReconnect = request.transport !== 'streaming';
+							if (isAllowedToReconnect && !rq.executeCallbackBeforeReconnect) {
+								_reconnect(ajaxRequest, rq, 0);
+							}
+							
+							if (_response.responseBody.length !== 0 && !skipCallbackInvocation)
+								_invokeCallback();
+							
+							if (isAllowedToReconnect && rq.executeCallbackBeforeReconnect) {
+								_reconnect(ajaxRequest, rq, 0);
+							}
+							
+							_verifyStreamingLength(ajaxRequest, rq);
+						}
+					};
+					
+					try {
+						ajaxRequest.send(rq.data);
+						_subscribed = true;
+					} catch (e) {
+						atmosphere.util.log(rq.logLevel, ["Unable to connect to " + rq.url]);
+					}
+					
+				} else {
+					if (rq.logLevel === 'debug') {
+						atmosphere.util.log(rq.logLevel, ["Max re-connection reached."]);
+					}
+					_onError(0, "maxRequest reached");
+				}
+			}
+			
+			/**
+			 * Do ajax request.
+			 * 
+			 * @param ajaxRequest Ajax request.
+			 * @param request Request parameters.
+			 * @param create If ajax request has to be open.
+			 */
+			function _doRequest(ajaxRequest, request, create) {
+				// Prevent Android to cache request
+				var url = request.url;
+				if (request.dispatchUrl != null && request.method === 'POST') {
+					url += request.dispatchUrl;
+				}
+				url = _attachHeaders(request, url);
+				url = atmosphere.util.prepareURL(url);
+				
+				if (create) {
+					ajaxRequest.open(request.method, url, request.async);
+					if (request.connectTimeout > -1) {
+						request.id = setTimeout(function() {
+							if (request.requestCount === 0) {
+								_clearState();
+								_prepareCallback("Connect timeout", "closed", 200, request.transport);
+							}
+						}, request.connectTimeout);
+					}
+				}
+				
+				if (_request.withCredentials) {
+					if ("withCredentials" in ajaxRequest) {
+						ajaxRequest.withCredentials = true;
+					}
+				}
+				
+				if (!_request.dropAtmosphereHeaders) {
+					ajaxRequest.setRequestHeader("X-Atmosphere-Framework", atmosphere.util.version);
+					ajaxRequest.setRequestHeader("X-Atmosphere-Transport", request.transport);
+					if (request.lastTimestamp != null) {
+						ajaxRequest.setRequestHeader("X-Cache-Date", request.lastTimestamp);
+					} else {
+						ajaxRequest.setRequestHeader("X-Cache-Date", 0);
+					}
+					
+					if (request.trackMessageLength) {
+						ajaxRequest.setRequestHeader("X-Atmosphere-TrackMessageSize", "true");
+					}
+					ajaxRequest.setRequestHeader("X-Atmosphere-tracking-id", request.uuid);
+				}
+				
+				if (request.contentType !== '') {
+					ajaxRequest.setRequestHeader("Content-Type", request.contentType);
+				}
+				
+				atmosphere.util.each(request.headers, function(name, value) {
+					var h = atmosphere.util.isFunction(value) ? value.call(this, ajaxRequest, request, create, _response) : value;
+					if (h != null) {
+						ajaxRequest.setRequestHeader(name, h);
+					}
+				});
+			}
+			
+			function _reconnect(ajaxRequest, request, reconnectInterval) {
+				if (request.reconnect || (request.suspend && _subscribed)) {
+					var status = 0;
+					if (ajaxRequest && ajaxRequest.readyState !== 0) {
+						status = ajaxRequest.status > 1000 ? 0 : ajaxRequest.status;
+					}
+					_response.status = status === 0 ? 204 : status;
+					_response.reason = status === 0 ? "Server resumed the connection or down." : "OK";
+					
+					clearTimeout(request.id);
+					request.id = setTimeout(function() {
+						_executeRequest(request);
+					}, reconnectInterval);
+				}
+			}
+			
+			function _tryingToReconnect(response) {
+				response.state = 're-connecting';
+				_invokeFunction(response);
+			}
+			
+			function _ieXDR(request) {
+				if (request.transport !== "polling") {
+					_ieStream = _configureXDR(request);
+					_ieStream.open();
+				} else {
+					_configureXDR(request).open();
+				}
+			}
+			
+			function _configureXDR(request) {
+				var rq = _request;
+				if ((request != null) && (typeof (request) !== 'undefined')) {
+					rq = request;
+				}
+				
+				var transport = rq.transport;
+				var lastIndex = 0;
+				var xdr = new window.XDomainRequest();
+				
+				var reconnect = function() {
+					if (rq.transport === "long-polling" && (rq.reconnect && (rq.maxRequest === -1 || rq.requestCount++ < rq.maxRequest))) {
+						xdr.status = 200;
+						_ieXDR(rq);
+					}
+				};
+				
+				var rewriteURL = rq.rewriteURL || function(url) {
+					// Maintaining session by rewriting URL
+					// http://stackoverflow.com/questions/6453779/maintaining-session-by-rewriting-url
+					var match = /(?:^|;\s*)(JSESSIONID|PHPSESSID)=([^;]*)/.exec(document.cookie);
+					
+					switch (match && match[1]) {
+					case "JSESSIONID":
+						return url.replace(/;jsessionid=[^\?]*|(\?)|$/, ";jsessionid=" + match[2] + "$1");
+					case "PHPSESSID":
+						return url.replace(/\?PHPSESSID=[^&]*&?|\?|$/, "?PHPSESSID=" + match[2] + "&").replace(/&$/, "");
+					}
+					return url;
+				};
+				
+				// Handles open and message event
+				xdr.onprogress = function() {
+					handle(xdr);
+				};
+				// Handles error event
+				xdr.onerror = function() {
+					// If the server doesn't send anything back to XDR will fail with polling
+					if (rq.transport !== 'polling') {
+						_clearState();
+						if (_requestCount++ < rq.maxReconnectOnClose) {
+							rq.id = setTimeout(function() {
+								_open('re-connecting', request.transport, request);
+								_ieXDR(rq);
+							}, rq.reconnectInterval);
+						} else {
+							_onError(0, "maxReconnectOnClose reached");
+						}
+					}
+				};
+				
+				// Handles close event
+				xdr.onload = function() {};
+				
+				var handle = function(xdr) {
+					clearTimeout(rq.id);
+					var message = xdr.responseText;
+					
+					message = message.substring(lastIndex);
+					lastIndex += message.length;
+					
+					if (transport !== 'polling') {
+                        _timeout(rq);
+						
+						var skipCallbackInvocation = _trackMessageSize(message, rq, _response);
+						
+						if (transport === 'long-polling' && atmosphere.util.trim(message) === 0)
+							return;
+						
+						if (rq.executeCallbackBeforeReconnect) {
+							reconnect();
+						}
+						
+						if (!skipCallbackInvocation) {
+							_prepareCallback(_response.responseBody, "messageReceived", 200, transport);
+						}
+						
+						if (!rq.executeCallbackBeforeReconnect) {
+							reconnect();
+						}
+					}
+				};
+				
+				return {
+					open: function() {
+						var url = rq.url;
+						if (rq.dispatchUrl != null) {
+							url += rq.dispatchUrl;
+						}
+						url = _attachHeaders(rq, url);
+						xdr.open(rq.method, rewriteURL(url));
+						if (rq.method === 'GET') {
+							xdr.send();
+						} else {
+							xdr.send(rq.data);
+						}
+						
+						if (rq.connectTimeout > -1) {
+							rq.id = setTimeout(function() {
+								if (rq.requestCount === 0) {
+									_clearState();
+									_prepareCallback("Connect timeout", "closed", 200, rq.transport);
+								}
+							}, rq.connectTimeout);
+						}
+					},
+					close: function() {
+						xdr.abort();
+					}
+				};
+			}
+			
+			function _ieStreaming(request) {
+				_ieStream = _configureIE(request);
+				_ieStream.open();
+			}
+			
+			function _configureIE(request) {
+				var rq = _request;
+				if ((request != null) && (typeof (request) !== 'undefined')) {
+					rq = request;
+				}
+				
+				var stop;
+				var doc = new window.ActiveXObject("htmlfile");
+				
+				doc.open();
+				doc.close();
+				
+				var url = rq.url;
+				if (rq.dispatchUrl != null) {
+					url += rq.dispatchUrl;
+				}
+				
+				if (rq.transport !== 'polling') {
+					_response.transport = rq.transport;
+				}
+				
+				return {
+					open: function() {
+						var iframe = doc.createElement("iframe");
+						
+						url = _attachHeaders(rq);
+						if (rq.data !== '') {
+							url += "&X-Atmosphere-Post-Body=" + encodeURIComponent(rq.data);
+						}
+						
+						// Finally attach a timestamp to prevent Android and IE caching.
+						url = atmosphere.util.prepareURL(url);
+						
+						iframe.src = url;
+						doc.body.appendChild(iframe);
+						
+						// For the server to respond in a consistent format regardless of user agent, we polls response text
+						var cdoc = iframe.contentDocument || iframe.contentWindow.document;
+						
+						stop = atmosphere.util.iterate(function() {
+							try {
+								if (!cdoc.firstChild) {
+									return;
+								}
+								
+								var res = cdoc.body ? cdoc.body.lastChild : cdoc;
+								var readResponse = function() {
+									// Clones the element not to disturb the original one
+									var clone = res.cloneNode(true);
+									
+									// If the last character is a carriage return or a line feed, IE ignores it in the innerText property
+									// therefore, we add another non-newline character to preserve it
+									clone.appendChild(cdoc.createTextNode("."));
+									
+									var text = clone.innerText;
+									
+									text = text.substring(0, text.length - 1);
+									return text;
+									
+								};
+								
+								// To support text/html content type
+								if (!cdoc.body || !cdoc.body.firstChild || cdoc.body.firstChild.nodeName.toLowerCase() !== "pre") {
+									// Injects a plaintext element which renders text without interpreting the HTML and cannot be stopped
+									// it is deprecated in HTML5, but still works
+									var head = cdoc.head || cdoc.getElementsByTagName("head")[0] || cdoc.documentElement || cdoc;
+									var script = cdoc.createElement("script");
+									
+									script.text = "document.write('<plaintext>')";
+									
+									head.insertBefore(script, head.firstChild);
+									head.removeChild(script);
+									
+									// The plaintext element will be the response container
+									res = cdoc.body.lastChild;
+								}
+								
+								if (rq.closed) {
+									rq.isReopen = true;
+								}
+								
+								// Handles message and close event
+								stop = atmosphere.util.iterate(function() {
+									var text = readResponse();
+									if (text.length > rq.lastIndex) {
+										_timeout(_request);
+										
+										_response.status = 200;
+										_response.error = null;
+										
+										// Empties response every time that it is handled
+										res.innerText = "";
+										var skipCallbackInvocation = _trackMessageSize(text, rq, _response);
+										if (skipCallbackInvocation) {
+											return "";
+										}
+										
+										_prepareCallback(_response.responseBody, "messageReceived", 200, rq.transport);
+									}
+									
+									rq.lastIndex = 0;
+									
+									if (cdoc.readyState === "complete") {
+										_invokeClose(true);
+										_open('re-connecting', rq.transport, rq);
+										rq.id = setTimeout(function() {
+											_ieStreaming(rq);
+										}, rq.reconnectInterval);
+										return false;
+									}
+								}, null);
+								
+								return false;
+							} catch (err) {
+								_response.error = true;
+								_open('re-connecting', rq.transport, rq);
+								if (_requestCount++ < rq.maxReconnectOnClose) {
+									rq.id = setTimeout(function() {
+										_ieStreaming(rq);
+									}, rq.reconnectInterval);
+								} else {
+									_onError(0, "maxReconnectOnClose reached");
+								}
+								doc.execCommand("Stop");
+								doc.close();
+								return false;
+							}
+						});
+					},
+					
+					close: function() {
+						if (stop) {
+							stop();
+						}
+						
+						doc.execCommand("Stop");
+						_invokeClose(true);
+					}
+				};
+			}
+			
+			/**
+			 * Send message. <br>
+			 * Will be automatically dispatch to other connected.
+			 * 
+			 * @param {Object, string} Message to send.
+			 * @private
+			 */
+			function _push(message) {
+				
+				if (_localStorageService != null) {
+					_pushLocal(message);
+				} else if (_activeRequest != null || _sse != null) {
+					_pushAjaxMessage(message);
+				} else if (_ieStream != null) {
+					_pushIE(message);
+				} else if (_jqxhr != null) {
+					_pushJsonp(message);
+				} else if (_websocket != null) {
+					_pushWebSocket(message);
+				}
+			}
+			
+			function _pushOnClose(message, rq) {
+				if (!rq) {
+					rq = _getPushRequest(message);
+				}
+				rq.transport = "polling";
+				rq.method = "GET";
+				rq.async = false;
+				rq.reconnect = false;
+				rq.force = true;
+				rq.suspend = false;
+				_executeRequest(rq);
+			}
+			
+			function _pushLocal(message) {
+				_localStorageService.send(message);
+			}
+			
+			function _intraPush(message) {
+				// IE 9 will crash if not.
+				if (message.length === 0)
+					return;
+				
+				try {
+					if (_localStorageService) {
+						_localStorageService.localSend(message);
+					} else if (_storageService) {
+						_storageService.signal("localMessage", atmosphere.util.stringifyJSON({
+							id: guid,
+							event: message
+						}));
+					}
+				} catch (err) {
+					atmosphere.util.error(err);
+				}
+			}
+			
+			/**
+			 * Send a message using currently opened ajax request (using http-streaming or long-polling). <br>
+			 * 
+			 * @param {string, Object} Message to send. This is an object, string message is saved in data member.
+			 * @private
+			 */
+			function _pushAjaxMessage(message) {
+				var rq = _getPushRequest(message);
+				_executeRequest(rq);
+			}
+			
+			/**
+			 * Send a message using currently opened ie streaming (using http-streaming or long-polling). <br>
+			 * 
+			 * @param {string, Object} Message to send. This is an object, string message is saved in data member.
+			 * @private
+			 */
+			function _pushIE(message) {
+				if (_request.enableXDR && atmosphere.util.checkCORSSupport()) {
+					var rq = _getPushRequest(message);
+					// Do not reconnect since we are pushing.
+					rq.reconnect = false;
+					_jsonp(rq);
+				} else {
+					_pushAjaxMessage(message);
+				}
+			}
+			
+			/**
+			 * Send a message using jsonp transport. <br>
+			 * 
+			 * @param {string, Object} Message to send. This is an object, string message is saved in data member.
+			 * @private
+			 */
+			function _pushJsonp(message) {
+				_pushAjaxMessage(message);
+			}
+			
+			function _getStringMessage(message) {
+				var msg = message;
+				if (typeof (msg) === 'object') {
+					msg = message.data;
+				}
+				return msg;
+			}
+			
+			/**
+			 * Build request use to push message using method 'POST' <br>. Transport is defined as 'polling' and 'suspend' is set to false.
+			 * 
+			 * @return {Object} Request object use to push message.
+			 * @private
+			 */
+			function _getPushRequest(message) {
+				var msg = _getStringMessage(message);
+				
+				var rq = {
+					connected: false,
+					timeout: 60000,
+					method: 'POST',
+					url: _request.url,
+					contentType: _request.contentType,
+					headers: _request.headers,
+					reconnect: true,
+					callback: null,
+					data: msg,
+					suspend: false,
+					maxRequest: -1,
+					logLevel: 'info',
+					requestCount: 0,
+					withCredentials: _request.withCredentials,
+					transport: 'polling',
+					isOpen: true,
+					attachHeadersAsQueryString: true,
+					enableXDR: _request.enableXDR,
+					uuid: _request.uuid,
+					dispatchUrl: _request.dispatchUrl,
+					enableProtocol: false,
+					messageDelimiter: '|',
+					maxReconnectOnClose: _request.maxReconnectOnClose
+				};
+				
+				if (typeof (message) === 'object') {
+					rq = atmosphere.util.extend(rq, message);
+				}
+				
+				return rq;
+			}
+			
+			/**
+			 * Send a message using currently opened websocket. <br>
+			 * 
+			 */
+			function _pushWebSocket(message) {
+				var msg = _getStringMessage(message);
+				var data;
+				try {
+					if (_request.dispatchUrl != null) {
+						data = _request.webSocketPathDelimiter + _request.dispatchUrl + _request.webSocketPathDelimiter + msg;
+					} else {
+						data = msg;
+					}
+					
+					_websocket.send(data);
+					
+				} catch (e) {
+					_websocket.onclose = function(message) {};
+					_clearState();
+					
+					_reconnectWithFallbackTransport("Websocket failed. Downgrading to Comet and resending " + data);
+					_pushAjaxMessage(message);
+				}
+			}
+			
+			function _localMessage(message) {
+				var m = atmosphere.util.parseJSON(message);
+				if (m.id !== guid) {
+					if (typeof (_request.onLocalMessage) !== 'undefined') {
+						_request.onLocalMessage(m.event);
+					} else if (typeof (atmosphere.util.onLocalMessage) !== 'undefined') {
+						atmosphere.util.onLocalMessage(m.event);
+					}
+				}
+			}
+			
+			function _prepareCallback(messageBody, state, errorCode, transport) {
+				
+				_response.responseBody = messageBody;
+				_response.transport = transport;
+				_response.status = errorCode;
+				_response.state = state;
+				
+				_invokeCallback();
+			}
+			
+			function _readHeaders(xdr, request) {
+				if (!request.readResponsesHeaders && !request.enableProtocol) {
+					request.lastTimestamp = atmosphere.util.now();
+					request.uuid = guid;
+					return;
+				}
+				
+				try {
+					var tempDate = xdr.getResponseHeader('X-Cache-Date');
+					if (tempDate && tempDate != null && tempDate.length > 0) {
+						request.lastTimestamp = tempDate.split(" ").pop();
+					}
+					
+					var tempUUID = xdr.getResponseHeader('X-Atmosphere-tracking-id');
+					if (tempUUID && tempUUID != null) {
+						request.uuid = tempUUID.split(" ").pop();
+					}
+					
+					// HOTFIX for firefox bug: https://bugzilla.mozilla.org/show_bug.cgi?id=608735
+					if (request.headers) {
+						atmosphere.util.each(_request.headers, function(name) {
+							var v = xdr.getResponseHeader(name);
+							if (v) {
+								_response.headers[name] = v;
+							}
+						});
+					}
+				} catch (e) {}
+			}
+			
+			function _invokeFunction(response) {
+				_f(response, _request);
+				// Global
+				_f(response, atmosphere.util);
+			}
+			
+			function _f(response, f) {
+				switch (response.state) {
+				case "messageReceived":
+					_requestCount = 0;
+					if (typeof (f.onMessage) !== 'undefined')
+						f.onMessage(response);
+					break;
+				case "error":
+					if (typeof (f.onError) !== 'undefined')
+						f.onError(response);
+					break;
+				case "opening":
+					if (typeof (f.onOpen) !== 'undefined')
+						f.onOpen(response);
+					break;
+				case "messagePublished":
+					if (typeof (f.onMessagePublished) !== 'undefined')
+						f.onMessagePublished(response);
+					break;
+				case "re-connecting":
+					if (typeof (f.onReconnect) !== 'undefined')
+						f.onReconnect(_request, response);
+					break;
+				case "re-opening":
+					if (typeof (f.onReopen) !== 'undefined')
+						f.onReopen(_request, response);
+					break;
+				case "fail-to-reconnect":
+					if (typeof (f.onFailureToReconnect) !== 'undefined')
+						f.onFailureToReconnect(_request, response);
+					break;
+				case "unsubscribe":
+				case "closed":
+					var closed = typeof (_request.closed) !== 'undefined' ? _request.closed : false;
+					if (typeof (f.onClose) !== 'undefined' && !closed)
+						f.onClose(response);
+					_request.closed = true;
+					break;
+				}
+			}
+			
+			function _invokeClose(wasOpen) {
+				if (_response.state !== 'closed') {
+					_response.state = 'closed';
+					_response.responseBody = "";
+					_response.messages = [];
+					_response.status = !wasOpen ? 501 : 200;
+					_invokeCallback();
+				}
+			}
+			
+			/**
+			 * Invoke request callbacks.
+			 * 
+			 * @private
+			 */
+			function _invokeCallback() {
+				var call = function(index, func) {
+					func(_response);
+				};
+				
+				if (_localStorageService == null && _localSocketF != null) {
+					_localSocketF(_response.responseBody);
+				}
+				
+				_request.reconnect = _request.mrequest;
+				
+				var isString = typeof (_response.responseBody) === 'string';
+				var messages = (isString && _request.trackMessageLength) ? (_response.messages.length > 0 ? _response.messages : ['']) : new Array(
+					_response.responseBody);
+				for ( var i = 0; i < messages.length; i++) {
+					
+					if (messages.length > 1 && messages[i].length === 0) {
+						continue;
+					}
+					_response.responseBody = (isString) ? atmosphere.util.trim(messages[i]) : messages[i];
+					
+					if (_localStorageService == null && _localSocketF != null) {
+						_localSocketF(_response.responseBody);
+					}
+					
+					if (_response.responseBody.length === 0 && _response.state === "messageReceived") {
+						continue;
+					}
+					
+					_invokeFunction(_response);
+					
+					// Invoke global callbacks
+					if (callbacks.length > 0) {
+						if (_request.logLevel === 'debug') {
+							atmosphere.util.debug("Invoking " + callbacks.length + " global callbacks: " + _response.state);
+						}
+						try {
+							atmosphere.util.each(callbacks, call);
+						} catch (e) {
+							atmosphere.util.log(_request.logLevel, ["Callback exception" + e]);
+						}
+					}
+					
+					// Invoke request callback
+					if (typeof (_request.callback) === 'function') {
+						if (_request.logLevel === 'debug') {
+							atmosphere.util.debug("Invoking request callbacks");
+						}
+						try {
+							_request.callback(_response);
+						} catch (e) {
+							atmosphere.util.log(_request.logLevel, ["Callback exception" + e]);
+						}
+					}
+				}
+			}
+			
+			this.subscribe = function(options) {
+				_subscribe(options);
+				_execute();
+			};
+			
+			this.execute = function() {
+				_execute();
+			};
+			
+			this.close = function() {
+				_close();
+			};
+			
+			this.disconnect = function() {
+				_disconnect();
+			};
+			
+			this.getUrl = function() {
+				return _request.url;
+			};
+			
+			this.push = function(message, dispatchUrl) {
+				if (dispatchUrl != null) {
+					var originalDispatchUrl = _request.dispatchUrl;
+					_request.dispatchUrl = dispatchUrl;
+					_push(message);
+					_request.dispatchUrl = originalDispatchUrl;
+				} else {
+					_push(message);
+				}
+			};
+			
+			this.getUUID = function() {
+				return _request.uuid;
+			};
+			
+			this.pushLocal = function(message) {
+				_intraPush(message);
+			};
+			
+			this.enableProtocol = function(message) {
+				return _request.enableProtocol;
+			};
+			
+			this.request = _request;
+			this.response = _response;
+		}
+	};
+	
+	atmosphere.subscribe = function(url, callback, request) {
+		if (typeof (callback) === 'function') {
+			atmosphere.addCallback(callback);
+		}
+		
+		if (typeof (url) !== "string") {
+			request = url;
+		} else {
+			request.url = url;
+		}
+		
+		var rq = new atmosphere.AtmosphereRequest(request);
+		rq.execute();
+		
+		requests[requests.length] = rq;
+		return rq;
+	};
+	
+	atmosphere.unsubscribe = function() {
+		if (requests.length > 0) {
+			var requestsClone = [].concat(requests);
+			for ( var i = 0; i < requestsClone.length; i++) {
+				var rq = requestsClone[i];
+				rq.close();
+				clearTimeout(rq.response.request.id);
+			}
+		}
+		requests = [];
+		callbacks = [];
+	};
+	
+	atmosphere.unsubscribeUrl = function(url) {
+		var idx = -1;
+		if (requests.length > 0) {
+			for ( var i = 0; i < requests.length; i++) {
+				var rq = requests[i];
+				
+				// Suppose you can subscribe once to an url
+				if (rq.getUrl() === url) {
+					rq.close();
+					clearTimeout(rq.response.request.id);
+					idx = i;
+					break;
+				}
+			}
+		}
+		if (idx >= 0) {
+			requests.splice(idx, 1);
+		}
+	};
+	
+	atmosphere.addCallback = function(func) {
+		if (atmosphere.util.inArray(func, callbacks) === -1) {
+			callbacks.push(func);
+		}
+	};
+	
+	atmosphere.removeCallback = function(func) {
+		var index = atmosphere.util.inArray(func, callbacks);
+		if (index !== -1) {
+			callbacks.splice(index, 1);
+		}
+	};
+	
+	atmosphere.util = {
+		browser: {},
+		
+		parseHeaders: function(headerString) {
+			var match, rheaders = /^(.*?):[ \t]*([^\r\n]*)\r?$/mg, headers = {};
+			while (match = rheaders.exec(headerString)) {
+				headers[match[1]] = match[2];
+			}
+			return headers;
+		},
+		
+		now: function() {
+			return new Date().getTime();
+		},
+		
+		isArray: function(array) {
+			return Object.prototype.toString.call(array) === "[object Array]";
+		},
+		
+		isBinary: function(data) {
+			var string = Object.prototype.toString.call(data);
+			return string === "[object Blob]" || string === "[object ArrayBuffer]";
+		},
+		
+		isFunction: function(fn) {
+			return Object.prototype.toString.call(fn) === "[object Function]";
+		},
+		
+		getAbsoluteURL: function(url) {
+			var div = document.createElement("div");
+			
+			// Uses an innerHTML property to obtain an absolute URL
+			div.innerHTML = '<a href="' + url + '"/>';
+			
+			// encodeURI and decodeURI are needed to normalize URL between IE and non-IE,
+			// since IE doesn't encode the href property value and return it - http://jsfiddle.net/Yq9M8/1/
+			return encodeURI(decodeURI(div.firstChild.href));
+		},
+		
+		prepareURL: function(url) {
+			// Attaches a time stamp to prevent caching
+			var ts = atmosphere.util.now();
+			var ret = url.replace(/([?&])_=[^&]*/, "$1_=" + ts);
+			
+			return ret + (ret === url ? (/\?/.test(url) ? "&" : "?") + "_=" + ts : "");
+		},
+		
+		trim: function(str) {
+			if (!String.prototype.trim) {
+				return str.toString().replace(/(?:(?:^|\n)\s+|\s+(?:$|\n))/g, "").replace(/\s+/g, " ");
+			} else {
+				return str.toString().trim();
+			}
+		},
+		
+		param: function(params) {
+			var prefix, s = [];
+			
+			function add(key, value) {
+				value = atmosphere.util.isFunction(value) ? value() : (value == null ? "" : value);
+				s.push(encodeURIComponent(key) + "=" + encodeURIComponent(value));
+			}
+			
+			function buildParams(prefix, obj) {
+				var name;
+				
+				if (atmosphere.util.isArray(obj)) {
+					atmosphere.util.each(obj, function(i, v) {
+						if (/\[\]$/.test(prefix)) {
+							add(prefix, v);
+						} else {
+							buildParams(prefix + "[" + (typeof v === "object" ? i : "") + "]", v);
+						}
+					});
+				} else if (Object.prototype.toString.call(obj) === "[object Object]") {
+					for (name in obj) {
+						buildParams(prefix + "[" + name + "]", obj[name]);
+					}
+				} else {
+					add(prefix, obj);
+				}
+			}
+			
+			for (prefix in params) {
+				buildParams(prefix, params[prefix]);
+			}
+			
+			return s.join("&").replace(/%20/g, "+");
+		},
+		
+		supportStorage: function() {
+			var storage = window.localStorage;
+			if (storage) {
+				try {
+					storage.setItem("t", "t");
+					storage.removeItem("t");
+					// The storage event of Internet Explorer and Firefox 3 works strangely
+					return window.StorageEvent && !atmosphere.util.browser.msie
+						&& !(atmosphere.util.browser.mozilla && atmosphere.util.browser.version.split(".")[0] === "1");
+				} catch (e) {}
+			}
+			
+			return false;
+		},
+		
+		iterate: function(fn, interval) {
+			var timeoutId;
+			
+			// Though the interval is 0 for real-time application, there is a delay between setTimeout calls
+			// For detail, see https://developer.mozilla.org/en/window.setTimeout#Minimum_delay_and_timeout_nesting
+			interval = interval || 0;
+			
+			(function loop() {
+				timeoutId = setTimeout(function() {
+					if (fn() === false) {
+						return;
+					}
+					
+					loop();
+				}, interval);
+			})();
+			
+			return function() {
+				clearTimeout(timeoutId);
+			};
+		},
+		
+		each: function(obj, callback, args) {
+			var value, i = 0, length = obj.length, isArray = atmosphere.util.isArray(obj);
+			
+			if (args) {
+				if (isArray) {
+					for (; i < length; i++) {
+						value = callback.apply(obj[i], args);
+						
+						if (value === false) {
+							break;
+						}
+					}
+				} else {
+					for (i in obj) {
+						value = callback.apply(obj[i], args);
+						
+						if (value === false) {
+							break;
+						}
+					}
+				}
+				
+				// A special, fast, case for the most common use of each
+			} else {
+				if (isArray) {
+					for (; i < length; i++) {
+						value = callback.call(obj[i], i, obj[i]);
+						
+						if (value === false) {
+							break;
+						}
+					}
+				} else {
+					for (i in obj) {
+						value = callback.call(obj[i], i, obj[i]);
+						
+						if (value === false) {
+							break;
+						}
+					}
+				}
+			}
+			
+			return obj;
+		},
+		
+		extend: function(target) {
+			var i, options, name;
+			
+			for (i = 1; i < arguments.length; i++) {
+				if ((options = arguments[i]) != null) {
+					for (name in options) {
+						target[name] = options[name];
+					}
+				}
+			}
+			
+			return target;
+		},
+		on: function(elem, type, fn) {
+			if (elem.addEventListener) {
+				elem.addEventListener(type, fn, false);
+			} else if (elem.attachEvent) {
+				elem.attachEvent("on" + type, fn);
+			}
+		},
+		off: function(elem, type, fn) {
+			if (elem.removeEventListener) {
+				elem.removeEventListener(type, fn, false);
+			} else if (elem.detachEvent) {
+				elem.detachEvent("on" + type, fn);
+			}
+		},
+		
+		log: function(level, args) {
+			if (window.console) {
+				var logger = window.console[level];
+				if (typeof logger === 'function') {
+					logger.apply(window.console, args);
+				}
+			}
+		},
+		
+		warn: function() {
+			atmosphere.util.log('warn', arguments);
+		},
+		
+		info: function() {
+			atmosphere.util.log('info', arguments);
+		},
+		
+		debug: function() {
+			atmosphere.util.log('debug', arguments);
+		},
+		
+		error: function() {
+			atmosphere.util.log('error', arguments);
+		},
+		xhr: function() {
+			try {
+				return new window.XMLHttpRequest();
+			} catch (e1) {
+				try {
+					return new window.ActiveXObject("Microsoft.XMLHTTP");
+				} catch (e2) {}
+			}
+		},
+		parseJSON: function(data) {
+			return !data ? null : window.JSON && window.JSON.parse ? window.JSON.parse(data) : new Function("return " + data)();
+		},
+		// http://github.com/flowersinthesand/stringifyJSON
+		stringifyJSON: function(value) {
+			var escapable = /[\\\"\x00-\x1f\x7f-\x9f\u00ad\u0600-\u0604\u070f\u17b4\u17b5\u200c-\u200f\u2028-\u202f\u2060-\u206f\ufeff\ufff0-\uffff]/g, meta = {
+				'\b': '\\b',
+				'\t': '\\t',
+				'\n': '\\n',
+				'\f': '\\f',
+				'\r': '\\r',
+				'"': '\\"',
+				'\\': '\\\\'
+			};
+			
+			function quote(string) {
+				return '"' + string.replace(escapable, function(a) {
+					var c = meta[a];
+					return typeof c === "string" ? c : "\\u" + ("0000" + a.charCodeAt(0).toString(16)).slice(-4);
+				}) + '"';
+			}
+			
+			function f(n) {
+				return n < 10 ? "0" + n : n;
+			}
+			
+			return window.JSON && window.JSON.stringify ? window.JSON.stringify(value) : (function str(key, holder) {
+				var i, v, len, partial, value = holder[key], type = typeof value;
+				
+				if (value && typeof value === "object" && typeof value.toJSON === "function") {
+					value = value.toJSON(key);
+					type = typeof value;
+				}
+				
+				switch (type) {
+				case "string":
+					return quote(value);
+				case "number":
+					return isFinite(value) ? String(value) : "null";
+				case "boolean":
+					return String(value);
+				case "object":
+					if (!value) {
+						return "null";
+					}
+					
+					switch (Object.prototype.toString.call(value)) {
+					case "[object Date]":
+						return isFinite(value.valueOf()) ? '"' + value.getUTCFullYear() + "-" + f(value.getUTCMonth() + 1) + "-"
+							+ f(value.getUTCDate()) + "T" + f(value.getUTCHours()) + ":" + f(value.getUTCMinutes()) + ":" + f(value.getUTCSeconds())
+							+ "Z" + '"' : "null";
+					case "[object Array]":
+						len = value.length;
+						partial = [];
+						for (i = 0; i < len; i++) {
+							partial.push(str(i, value) || "null");
+						}
+						
+						return "[" + partial.join(",") + "]";
+					default:
+						partial = [];
+						for (i in value) {
+							if (hasOwn.call(value, i)) {
+								v = str(i, value);
+								if (v) {
+									partial.push(quote(i) + ":" + v);
+								}
+							}
+						}
+						
+						return "{" + partial.join(",") + "}";
+					}
+				}
+			})("", {
+				"": value
+			});
+		},
+		
+		checkCORSSupport: function() {
+			if (atmosphere.util.browser.msie && !window.XDomainRequest) {
+				return true;
+			} else if (atmosphere.util.browser.opera && atmosphere.util.browser.version < 12.0) {
+				return true;
+			}
+			
+			// Force Android to use CORS as some version like 2.2.3 fail otherwise
+			var ua = navigator.userAgent.toLowerCase();
+			var isAndroid = ua.indexOf("android") > -1;
+			if (isAndroid) {
+				return true;
+			}
+			return false;
+		}
+	};
+	
+	guid = atmosphere.util.now();
+	
+	// Browser sniffing
+	(function() {
+		var ua = navigator.userAgent.toLowerCase(),
+			match = /(chrome)[ \/]([\w.]+)/.exec(ua) ||
+				/(webkit)[ \/]([\w.]+)/.exec(ua) ||
+				/(opera)(?:.*version|)[ \/]([\w.]+)/.exec(ua) ||
+				/(msie) ([\w.]+)/.exec(ua) ||
+				ua.indexOf("compatible") < 0 && /(mozilla)(?:.*? rv:([\w.]+)|)/.exec(ua) ||
+				[];
+		
+		atmosphere.util.browser[match[1] || ""] = true;
+		atmosphere.util.browser.version = match[2] || "0";
+		
+		// The storage event of Internet Explorer and Firefox 3 works strangely
+		if (atmosphere.util.browser.msie || (atmosphere.util.browser.mozilla && atmosphere.util.browser.version.split(".")[0] === "1")) {
+			atmosphere.util.storage = false;
+		}
+	})();
+	
+	atmosphere.util.on(window, "unload", function(event) {
+		atmosphere.unsubscribe();
+	});
+	
+	// Pressing ESC key in Firefox kills the connection
+	atmosphere.util.on(window, "keypress", function(event) {
+		if (event.which === 27) {
+			event.preventDefault();
+		}
+	});
+	
+	atmosphere.util.on(window, "offline", function() {
+		atmosphere.unsubscribe();
+	});
+	window.atmosphere = atmosphere;
+})();
+/* jshint eqnull:true, noarg:true, noempty:true, eqeqeq:true, evil:true, laxbreak:true, undef:true, browser:true, indent:false, maxerr:50 */
diff --git a/ajax/libs/atmosphere/2.0.0.RC4/atmosphere.min.js b/ajax/libs/atmosphere/2.0.0.RC4/atmosphere.min.js
new file mode 100644
index 000000000..9202f41ae
--- /dev/null
+++ b/ajax/libs/atmosphere/2.0.0.RC4/atmosphere.min.js
@@ -0,0 +1,16 @@
+/**
+ * Copyright 2012 Jeanfrancois Arcand
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+(function(){var ia="2.0.0-javascript",e={},s=[],D=[],U=Object.prototype.hasOwnProperty,e={onError:function(e){},onClose:function(e){},onOpen:function(e){},onReopen:function(e){},onMessage:function(e){},onReconnect:function(e,h){},onMessagePublished:function(e){},onTransportFailure:function(e,h){},onLocalMessage:function(e){},onFailureToReconnect:function(e,h){},AtmosphereRequest:function(d){function h(b,a){""===f.partialMessage&&("streaming"===a.transport&&b.responseText.length>a.maxStreamingLength)&& (f.messages=[],I(!0),g(),l(),L(b,a,0))}function g(){if(c.enableProtocol&&!c.firstMessage){var b="X-Atmosphere-Transport=close&X-Atmosphere-tracking-id="+c.uuid,a=c.url.replace(/([?&])_=[^&]*/,b),a=a+(a===c.url?(/\?/.test(c.url)?"&":"?")+b:"");c.attachHeadersAsQueryString=!1;c.dropAtmosphereHeaders=!0;c.url=a;c.transport="polling";(b=c)||(b=V(""));b.transport="polling";b.method="GET";b.async=!1;b.reconnect=!1;b.force=!0;b.suspend=!1;Q(b)}}function m(){c.reconnect=!1;J=!0;f.request=c;f.state="unsubscribe"; f.responseBody="";f.status=408;y();g();l()}function l(){c.id&&clearTimeout(c.id);null!=v&&(v.close(),v=null);null!=E&&(E.abort(),E=null);null!=M&&(M.abort(),M=null);null!=r&&(r.webSocketOpened&&r.close(),r=null);null!=t&&(t.close(),t=null);null!=B&&(clearInterval(R),document.cookie=encodeURIComponent("atmosphere-"+c.url)+"=; expires=Thu, 01 Jan 1970 00:00:00 GMT",B.signal("close",{reason:"",heir:J?(B.get("children")||[])[0]:z}),B.close());null!=w&&w.close()}function aa(b){l();W=!0;J=!1;C=0;v=M=t= r=null;c=e.util.extend(c,b);c.mrequest=c.reconnect;c.reconnect||(c.reconnect=!0)}function F(){if(c.shared){w=ja(c);if(null!=w&&("debug"===c.logLevel&&e.util.debug("Storage service available. All communication will be local"),w.open(c)))return;"debug"===c.logLevel&&e.util.debug("No Storage service available.");w=null}c.firstMessage=!0;c.isOpen=!1;c.ctime=e.util.now();"websocket"!==c.transport&&"sse"!==c.transport?Q(c):"websocket"===c.transport?null!=c.webSocketImpl||window.WebSocket||window.MozWebSocket? q(!1):N("Websocket is not supported, using request.fallbackTransport ("+c.fallbackTransport+")"):"sse"===c.transport&&(window.EventSource?x(!1):N("Server Side Events(SSE) is not supported, using request.fallbackTransport ("+c.fallbackTransport+")"))}function ja(b){function a(a,b){var c,e=a.length;for(c=0;c<e;c++)a[c]===b&&a.splice(c,1);return e!==a.length}function k(a){a=e.util.parseJSON(a);var k=a.data;if("c"===a.target)switch(a.type){case "open":u("opening","local",c);break;case "close":p||(p=!0, "aborted"===k.reason?m():k.heir===z?F():setTimeout(function(){F()},100));break;case "message":O(k,"messageReceived",200,b.transport);break;case "localMessage":ba(k)}}function n(){var a=RegExp("(?:^|; )("+encodeURIComponent(h)+")=([^;]*)").exec(document.cookie);if(a)return e.util.parseJSON(decodeURIComponent(a[2]))}var f,d,p,h="atmosphere-"+b.url,g={storage:function(){if(e.util.supportStorage()){var c=window.localStorage,f=function(a){return e.util.parseJSON(c.getItem(h+"-"+a))},n=function(a,b){c.setItem(h+ "-"+a,e.util.stringifyJSON(b))};return{init:function(){n("children",f("children").concat([z]));e.util.on("storage.socket",function(a){a=a.originalEvent;a.key===h&&a.newValue&&k(a.newValue)});return f("opened")},signal:function(a,b){c.setItem(h,e.util.stringifyJSON({target:"p",type:a,data:b}))},close:function(){var c=f("children");e.util.off("storage.socket");c&&a(c,b.id)&&n("children",c)}}}},windowref:function(){var b=window.open("",h.replace(/\W/g,""));if(b&&!b.closed&&b.callbacks)return{init:function(){b.callbacks.push(k); b.children.push(z);return b.opened},signal:function(a,c){!b.closed&&b.fire&&b.fire(e.util.stringifyJSON({target:"p",type:a,data:c}))},close:function(){p||(a(b.callbacks,k),a(b.children,z))}}}};if((f=n())&&!(1E3<e.util.now()-f.ts)&&(d=g.storage()||g.windowref()))return{open:function(){var a;R=setInterval(function(){var a=f;(f=n())&&a.ts!==f.ts||k(e.util.stringifyJSON({target:"c",type:"close",data:{reason:"error",heir:a.heir}}))},1E3);(a=d.init())&&setTimeout(function(){u("opening","local",b)},50); return a},send:function(a){d.signal("send",a)},localSend:function(a){d.signal("localSend",e.util.stringifyJSON({id:z,event:a}))},close:function(){J||(clearInterval(R),d.signal("close"),d.close())}}}function s(){function b(a){a=e.util.parseJSON(a);var b=a.data;if("p"===a.target)switch(a.type){case "send":X(b);break;case "localSend":ba(b);break;case "close":m()}}function a(){document.cookie=encodeURIComponent(f)+"="+encodeURIComponent(e.util.stringifyJSON({ts:e.util.now()+1,heir:(k.get("children")|| [])[0]}))}var k,f="atmosphere-"+c.url,d={storage:function(){if(e.util.supportStorage()){var a=window.localStorage;return{init:function(){e.util.on("storage.socket",function(a){a=a.originalEvent;a.key===f&&a.newValue&&b(a.newValue)})},signal:function(b,c){a.setItem(f,e.util.stringifyJSON({target:"c",type:b,data:c}))},get:function(b){return e.util.parseJSON(a.getItem(f+"-"+b))},set:function(b,c){a.setItem(f+"-"+b,e.util.stringifyJSON(c))},close:function(){e.util.off("storage.socket");a.removeItem(f); a.removeItem(f+"-opened");a.removeItem(f+"-children")}}}},windowref:function(){var a=f.replace(/\W/g,""),c=document.getElementById(a),k;c||(c=document.createElement("div"),c.id=a,c.style.display="none",c.innerHTML='<iframe name="'+a+'" />',document.body.appendChild(c));k=c.firstChild.contentWindow;return{init:function(){k.callbacks=[b];k.fire=function(a){var b;for(b=0;b<k.callbacks.length;b++)k.callbacks[b](a)}},signal:function(a,b){!k.closed&&k.fire&&k.fire(e.util.stringifyJSON({target:"c",type:a, data:b}))},get:function(a){return k.closed?null:k[a]},set:function(a,b){k.closed||(k[a]=b)},close:function(){}}}};P=function(a){k.signal("message",a)};k=d.storage()||d.windowref();k.init();"debug"===c.logLevel&&e.util.debug("Installed StorageService "+k);k.set("children",[]);null==k.get("opened")||k.get("opened")||k.set("opened",!1);a();R=setInterval(a,1E3);B=k}function u(b,a,k){c.shared&&"local"!==a&&s();null!=B&&B.set("opened",!0);k.close=function(){m()};0<C&&"re-connecting"===b?(k.isReopen=!0, ka(f)):null==f.error&&(f.request=k,k=f.state,f.state=b,b=f.transport,f.transport=a,a=f.responseBody,y(),f.responseBody=a,f.state=k,f.transport=b)}function ca(b){b.transport="jsonp";var a=c,k;null!=b&&"undefined"!==typeof b&&(a=b);E={open:function(){function b(){var c=a.url;null!=a.dispatchUrl&&(c+=a.dispatchUrl);var e=a.data;a.attachHeadersAsQueryString&&(c=K(a),""!==e&&(c+="&X-Atmosphere-Post-Body="+encodeURIComponent(e)),e="");e=document.head||document.getElementsByTagName("head")[0]||document.documentElement; k=document.createElement("script");k.src=c+"&jsonpTransport="+d;k.clean=function(){k.clean=k.onerror=k.onload=k.onreadystatechange=null;k.parentNode&&k.parentNode.removeChild(k)};k.onload=k.onreadystatechange=function(){k.readyState&&!/loaded|complete/.test(k.readyState)||k.clean()};k.onerror=function(){k.clean();A(0,"maxReconnectOnClose reached")};e.insertBefore(k,e.firstChild)}var d="atmosphere"+ ++z;window[d]=function(b){if(a.reconnect)if(-1===a.maxRequest||a.requestCount++<a.maxRequest){a.executeCallbackBeforeReconnect|| L(E,a,0);if(null!=b&&"string"!==typeof b)try{b=b.message}catch(k){}G(b,a,f)||O(f.responseBody,"messageReceived",200,a.transport);a.executeCallbackBeforeReconnect&&L(E,a,0)}else e.util.log(c.logLevel,["JSONP reconnect maximum try reached "+c.requestCount]),A(0,"maxRequest reached")};setTimeout(function(){b()},50)},abort:function(){k.clean&&k.clean()}};E.open()}function x(b){f.transport="sse";var a=K(c);"debug"===c.logLevel&&(e.util.debug("Invoking executeSSE"),e.util.debug("Using URL: "+a));if(c.enableProtocol&& b){var k=e.util.now()-c.ctime;c.lastTimestamp=Number(c.stime)+Number(k)}if(b&&!c.reconnect)null!=t&&l();else{try{t=new EventSource(a,{withCredentials:c.withCredentials})}catch(d){A(0,d);N("SSE failed. Downgrading to fallback transport and resending");return}0<c.connectTimeout&&(c.id=setTimeout(function(){b||l()},c.connectTimeout));t.onopen=function(a){H(c);"debug"===c.logLevel&&e.util.debug("SSE successfully opened");c.enableProtocol||(b?u("re-opening","sse",c):u("opening","sse",c));b=!0;"POST"=== c.method&&(f.state="messageReceived",t.send(c.data))};t.onmessage=function(a){H(c);!c.enableXDR&&a.origin&&a.origin!==window.location.protocol+"//"+window.location.host?e.util.log(c.logLevel,["Origin was not "+window.location.protocol+"//"+window.location.host]):(f.state="messageReceived",f.status=200,a=a.data,a=G(a,c,f),t.URL&&(t.interval=100,t.URL=K(c)),a||(y(),f.responseBody="",f.messages=[]))};t.onerror=function(a){clearTimeout(c.id);I(b);l();J?e.util.log(c.logLevel,["SSE closed normally"]):b? c.reconnect&&"sse"===f.transport&&(C++<c.maxReconnectOnClose?(u("re-connecting",c.transport,c),c.id=setTimeout(function(){x(!0)},c.reconnectInterval),f.responseBody="",f.messages=[]):(e.util.log(c.logLevel,["SSE reconnect maximum try reached "+C]),A(0,"maxReconnectOnClose reached"))):N("SSE failed. Downgrading to fallback transport and resending")}}}function q(b){f.transport="websocket";if(c.enableProtocol&&b){var a=e.util.now()-c.ctime;c.lastTimestamp=Number(c.stime)+Number(a)}a=e.util.getAbsoluteURL(K(c)).replace(/^http/, "ws");"debug"===c.logLevel&&(e.util.debug("Invoking executeWebSocket"),e.util.debug("Using URL: "+a));if(b&&!c.reconnect)null!=r&&l();else if(r=null!=c.webSocketImpl?c.webSocketImpl:window.WebSocket?new WebSocket(a):new MozWebSocket(a),null!=c.webSocketBinaryType&&(r.binaryType=c.webSocketBinaryType),0<c.connectTimeout&&(c.id=setTimeout(function(){if(!b){r.onclose({code:1002,reason:"",wasClean:!1});try{l()}catch(a){}}},c.connectTimeout)),r.onopen=function(a){H(c);"debug"===c.logLevel&&e.util.debug("Websocket successfully opened"); c.enableProtocol||(b?u("re-opening","websocket",c):u("opening","websocket",c));b=!0;r.webSocketOpened=b;"POST"===c.method&&(f.state="messageReceived",r.send(c.data))},r.onmessage=function(a){H(c);f.state="messageReceived";f.status=200;a=a.data;"string"===typeof a?G(a,c,f)||(y(),f.responseBody="",f.messages=[]):da(c,a)&&(f.responseBody=a,y(),f.responseBody=null)},r.onerror=function(a){clearTimeout(c.id)},r.onclose=function(a){clearTimeout(c.id);if("closed"!==f.state){var d=a.reason;if(""===d)switch(a.code){case 1E3:d= "Normal closure; the connection successfully completed whatever purpose for which it was created.";break;case 1001:d="The endpoint is going away, either because of a server failure or because the browser is navigating away from the page that opened the connection.";break;case 1002:d="The endpoint is terminating the connection due to a protocol error.";break;case 1003:d="The connection is being terminated because the endpoint received data of a type it cannot accept (for example, a text-only endpoint received binary data)."; break;case 1004:d="The endpoint is terminating the connection because a data frame was received that is too large.";break;case 1005:d="Unknown: no status code was provided even though one was expected.";break;case 1006:d="Connection was closed abnormally (that is, with no close frame being sent)."}e.util.warn("Websocket closed, reason: "+d);e.util.warn("Websocket closed, wasClean: "+a.wasClean);I(b);f.state="closed";J?e.util.log(c.logLevel,["Websocket closed normally"]):b?c.reconnect&&"websocket"=== f.transport&&(l(),C++<c.maxReconnectOnClose?(u("re-connecting",c.transport,c),c.id=setTimeout(function(){f.responseBody="";f.messages=[];q(!0)},c.reconnectInterval)):(e.util.log(c.logLevel,["Websocket reconnect maximum try reached "+c.requestCount]),e.util.warn("Websocket error, reason: "+a.reason),A(0,"maxReconnectOnClose reached"))):N("Websocket failed. Downgrading to Comet and resending")}},void 0===r.url)r.onclose({reason:"Android 4.1 does not support websockets.",wasClean:!1})}function da(b, a){var c=!0;if(0!==e.util.trim(a)&&b.enableProtocol&&b.firstMessage){b.firstMessage=!1;var c=a.split(b.messageDelimiter),f=2===c.length?0:1;b.uuid=e.util.trim(c[f]);b.stime=e.util.trim(c[f+1]);c=!1;"long-polling"!==b.transport&&Y(b)}else Y(b);return c}function H(b){clearTimeout(b.id);0<b.timeout&&"polling"!==b.transport&&(b.id=setTimeout(function(){I(!0);l();g()},b.timeout))}function A(b,a){l();clearTimeout(c.id);f.state="error";f.reasonPhrase=a;f.responseBody="";f.status=b;f.messages=[];y()}function G(b, a,f){if(!da(c,b)||0===b.length)return!0;if(a.trackMessageLength){b=f.partialMessage+b;for(var d=[],h=b.indexOf(a.messageDelimiter);-1!==h;){var g=e.util.trim(b.substring(0,h)),p=+g;if(isNaN(p))throw Error('message length "'+g+'" is not a number');h+=a.messageDelimiter.length;h+p>b.length?h=-1:(d.push(b.substring(h,h+p)),b=b.substring(h+p,b.length),h=b.indexOf(a.messageDelimiter))}f.partialMessage=b;if(0!==d.length)f.responseBody=d.join(a.messageDelimiter),f.messages=d;else return f.responseBody="", f.messages=[],!0}else f.responseBody=b;return!1}function N(b){e.util.log(c.logLevel,[b]);if("undefined"!==typeof c.onTransportFailure)c.onTransportFailure(b,c);else if("undefined"!==typeof e.util.onTransportFailure)e.util.onTransportFailure(b,c);c.transport=c.fallbackTransport;b=-1===c.connectTimeout?0:c.connectTimeout;c.reconnect&&"none"!==c.transport||null==c.transport?(c.method=c.fallbackMethod,f.transport=c.fallbackTransport,c.fallbackTransport="none",c.id=setTimeout(function(){F()},b)):A(500, "Unable to reconnect with fallback transport")}function K(b,a){var d=c;null!=b&&"undefined"!==typeof b&&(d=b);null==a&&(a=d.url);if(!d.attachHeadersAsQueryString||-1!==a.indexOf("X-Atmosphere-Framework"))return a;a+=-1!==a.indexOf("?")?"&":"?";a+="X-Atmosphere-tracking-id="+d.uuid;a+="&X-Atmosphere-Framework="+ia;a+="&X-Atmosphere-Transport="+d.transport;d.trackMessageLength&&(a+="&X-Atmosphere-TrackMessageSize=true");a=null!=d.lastTimestamp?a+("&X-Cache-Date="+d.lastTimestamp):a+"&X-Cache-Date=0"; ""!==d.contentType&&(a+="&Content-Type="+d.contentType);d.enableProtocol&&(a+="&X-atmo-protocol=true");e.util.each(d.headers,function(c,h){var g=e.util.isFunction(h)?h.call(this,d,b,f):h;null!=g&&(a+="&"+encodeURIComponent(c)+"="+encodeURIComponent(g))});return a}function Y(b){b.isOpen?b.isReopen&&(b.isReopen=!1,u("re-opening",b.transport,b)):(b.isOpen=!0,u("opening",b.transport,b))}function Q(b){var a=c;if(null!=b||"undefined"!==typeof b)a=b;a.lastIndex=0;a.readyState=0;if("jsonp"===a.transport|| a.enableXDR&&e.util.checkCORSSupport())ca(a);else{if(e.util.browser.msie&&10>e.util.browser.version){if("streaming"===a.transport){a.enableXDR&&window.XDomainRequest?S(a):(v=Z(a),v.open());return}if(a.enableXDR&&window.XDomainRequest){S(a);return}}var d=function(){a.lastIndex=0;a.reconnect&&C++<a.maxReconnectOnClose?(u("re-connecting",b.transport,b),L(n,a,b.reconnectInterval)):A(0,"maxReconnectOnClose reached")};if(a.force||a.reconnect&&(-1===a.maxRequest||a.requestCount++<a.maxRequest)){a.force= !1;var n=e.util.xhr();n.hasData=!1;U(n,a,!0);a.suspend&&(M=n);"polling"!==a.transport&&(f.transport=a.transport,n.onabort=function(){I(!0)},n.onerror=function(){f.error=!0;try{f.status=XMLHttpRequest.status}catch(a){f.status=500}f.status||(f.status=500);l();f.errorHandled||d()});n.onreadystatechange=function(){if(!J){f.error=null;var g=!1,p=!1;if(e.util.browser.opera&&"streaming"===a.transport&&2<a.readyState&&4===n.readyState)l(),d();else if(a.readyState=n.readyState,"streaming"===a.transport&&3<= n.readyState?p=!0:"long-polling"===a.transport&&4===n.readyState&&(p=!0),H(c),a.enableProtocol&&b.firstMessage||("polling"===a.transport||2!==n.readyState)||Y(a),p)if(p=0,0!==n.readyState&&(p=1E3<n.status?0:n.status),300<=p||0===p)f.errorHandled=!0,l(),d();else if(p=n.responseText,0===e.util.trim(p).length&&"long-polling"===a.transport)n.hasData?n.hasData=!1:d();else{n.hasData=!0;$(n,c);if("streaming"===a.transport)if(e.util.browser.opera)e.util.iterate(function(){if(500!==f.status&&n.responseText.length> a.lastIndex){try{f.status=n.status,f.headers=e.util.parseHeaders(n.getAllResponseHeaders()),$(n,c)}catch(b){f.status=404}H(c);f.state="messageReceived";var d=n.responseText.substring(a.lastIndex);a.lastIndex=n.responseText.length;(g=G(d,a,f))||y();h(n,a)}else if(400<f.status)return a.lastIndex=n.responseText.length,!1},0);else{var m=p.substring(a.lastIndex,p.length),g=G(m,a,f);a.lastIndex=p.length;if(g)return}else g=G(p,a,f);try{f.status=n.status,f.headers=e.util.parseHeaders(n.getAllResponseHeaders()), $(n,a)}catch(q){f.status=404}f.state=a.suspend?0===f.status?"closed":"messageReceived":"messagePublished";(p="streaming"!==b.transport)&&!a.executeCallbackBeforeReconnect&&L(n,a,0);0===f.responseBody.length||g||y();p&&a.executeCallbackBeforeReconnect&&L(n,a,0);h(n,a)}}};try{n.send(a.data),W=!0}catch(g){e.util.log(a.logLevel,["Unable to connect to "+a.url])}}else"debug"===a.logLevel&&e.util.log(a.logLevel,["Max re-connection reached."]),A(0,"maxRequest reached")}}function U(b,a,d){var n=a.url;null!= a.dispatchUrl&&"POST"===a.method&&(n+=a.dispatchUrl);n=K(a,n);n=e.util.prepareURL(n);d&&(b.open(a.method,n,a.async),-1<a.connectTimeout&&(a.id=setTimeout(function(){0===a.requestCount&&(l(),O("Connect timeout","closed",200,a.transport))},a.connectTimeout)));c.withCredentials&&"withCredentials"in b&&(b.withCredentials=!0);c.dropAtmosphereHeaders||(b.setRequestHeader("X-Atmosphere-Framework",e.util.version),b.setRequestHeader("X-Atmosphere-Transport",a.transport),null!=a.lastTimestamp?b.setRequestHeader("X-Cache-Date", a.lastTimestamp):b.setRequestHeader("X-Cache-Date",0),a.trackMessageLength&&b.setRequestHeader("X-Atmosphere-TrackMessageSize","true"),b.setRequestHeader("X-Atmosphere-tracking-id",a.uuid));""!==a.contentType&&b.setRequestHeader("Content-Type",a.contentType);e.util.each(a.headers,function(c,n){var h=e.util.isFunction(n)?n.call(this,b,a,d,f):n;null!=h&&b.setRequestHeader(c,h)})}function L(b,a,c){if(a.reconnect||a.suspend&&W){var d=0;b&&0!==b.readyState&&(d=1E3<b.status?0:b.status);f.status=0===d?204: d;f.reason=0===d?"Server resumed the connection or down.":"OK";clearTimeout(a.id);a.id=setTimeout(function(){Q(a)},c)}}function ka(b){b.state="re-connecting";ea(b)}function S(b){"polling"!==b.transport?(v=fa(b),v.open()):fa(b).open()}function fa(b){var a=c;null!=b&&"undefined"!==typeof b&&(a=b);var d=a.transport,h=0,g=new window.XDomainRequest,m=function(){"long-polling"===a.transport&&(a.reconnect&&(-1===a.maxRequest||a.requestCount++<a.maxRequest))&&(g.status=200,S(a))},p=a.rewriteURL||function(a){var b= /(?:^|;\s*)(JSESSIONID|PHPSESSID)=([^;]*)/.exec(document.cookie);switch(b&&b[1]){case "JSESSIONID":return a.replace(/;jsessionid=[^\?]*|(\?)|$/,";jsessionid="+b[2]+"$1");case "PHPSESSID":return a.replace(/\?PHPSESSID=[^&]*&?|\?|$/,"?PHPSESSID="+b[2]+"&").replace(/&$/,"")}return a};g.onprogress=function(){clearTimeout(a.id);var b=g.responseText,b=b.substring(h);h+=b.length;if("polling"!==d){H(a);var c=G(b,a,f);if("long-polling"!==d||0!==e.util.trim(b))a.executeCallbackBeforeReconnect&&m(),c||O(f.responseBody, "messageReceived",200,d),a.executeCallbackBeforeReconnect||m()}};g.onerror=function(){"polling"!==a.transport&&(l(),C++<a.maxReconnectOnClose?a.id=setTimeout(function(){u("re-connecting",b.transport,b);S(a)},a.reconnectInterval):A(0,"maxReconnectOnClose reached"))};g.onload=function(){};return{open:function(){var b=a.url;null!=a.dispatchUrl&&(b+=a.dispatchUrl);b=K(a,b);g.open(a.method,p(b));"GET"===a.method?g.send():g.send(a.data);-1<a.connectTimeout&&(a.id=setTimeout(function(){0===a.requestCount&& (l(),O("Connect timeout","closed",200,a.transport))},a.connectTimeout))},close:function(){g.abort()}}}function Z(b){var a=c;null!=b&&"undefined"!==typeof b&&(a=b);var d,h=new window.ActiveXObject("htmlfile");h.open();h.close();var g=a.url;null!=a.dispatchUrl&&(g+=a.dispatchUrl);"polling"!==a.transport&&(f.transport=a.transport);return{open:function(){var b=h.createElement("iframe");g=K(a);""!==a.data&&(g+="&X-Atmosphere-Post-Body="+encodeURIComponent(a.data));g=e.util.prepareURL(g);b.src=g;h.body.appendChild(b); var p=b.contentDocument||b.contentWindow.document;d=e.util.iterate(function(){try{if(p.firstChild){var b=p.body?p.body.lastChild:p,g=function(){var a=b.cloneNode(!0);a.appendChild(p.createTextNode("."));a=a.innerText;return a=a.substring(0,a.length-1)};if(!p.body||!p.body.firstChild||"pre"!==p.body.firstChild.nodeName.toLowerCase()){var l=p.head||p.getElementsByTagName("head")[0]||p.documentElement||p,m=p.createElement("script");m.text="document.write('<plaintext>')";l.insertBefore(m,l.firstChild); l.removeChild(m);b=p.body.lastChild}a.closed&&(a.isReopen=!0);d=e.util.iterate(function(){var d=g();if(d.length>a.lastIndex){H(c);f.status=200;f.error=null;b.innerText="";if(G(d,a,f))return"";O(f.responseBody,"messageReceived",200,a.transport)}a.lastIndex=0;if("complete"===p.readyState)return I(!0),u("re-connecting",a.transport,a),a.id=setTimeout(function(){v=Z(a);v.open()},a.reconnectInterval),!1},null);return!1}}catch(q){return f.error=!0,u("re-connecting",a.transport,a),C++<a.maxReconnectOnClose? a.id=setTimeout(function(){v=Z(a);v.open()},a.reconnectInterval):A(0,"maxReconnectOnClose reached"),h.execCommand("Stop"),h.close(),!1}})},close:function(){d&&d();h.execCommand("Stop");I(!0)}}}function X(b){null!=w?w.send(b):null!=M||null!=t?T(b):null!=v?c.enableXDR&&e.util.checkCORSSupport()?(b=V(b),b.reconnect=!1,ca(b)):T(b):null!=E?T(b):null!=r&&la(b)}function T(b){b=V(b);Q(b)}function ga(b){var a=b;"object"===typeof a&&(a=b.data);return a}function V(b){var a=ga(b),a={connected:!1,timeout:6E4, method:"POST",url:c.url,contentType:c.contentType,headers:c.headers,reconnect:!0,callback:null,data:a,suspend:!1,maxRequest:-1,logLevel:"info",requestCount:0,withCredentials:c.withCredentials,transport:"polling",isOpen:!0,attachHeadersAsQueryString:!0,enableXDR:c.enableXDR,uuid:c.uuid,dispatchUrl:c.dispatchUrl,enableProtocol:!1,messageDelimiter:"|",maxReconnectOnClose:c.maxReconnectOnClose};"object"===typeof b&&(a=e.util.extend(a,b));return a}function la(b){var a=ga(b),d;try{d=null!=c.dispatchUrl? c.webSocketPathDelimiter+c.dispatchUrl+c.webSocketPathDelimiter+a:a,r.send(d)}catch(e){r.onclose=function(a){},l(),N("Websocket failed. Downgrading to Comet and resending "+d),T(b)}}function ba(b){b=e.util.parseJSON(b);if(b.id!==z)if("undefined"!==typeof c.onLocalMessage)c.onLocalMessage(b.event);else if("undefined"!==typeof e.util.onLocalMessage)e.util.onLocalMessage(b.event)}function O(b,a,c,d){f.responseBody=b;f.transport=d;f.status=c;f.state=a;y()}function $(b,a){if(a.readResponsesHeaders||a.enableProtocol)try{var d= b.getResponseHeader("X-Cache-Date");d&&(null!=d&&0<d.length)&&(a.lastTimestamp=d.split(" ").pop());var h=b.getResponseHeader("X-Atmosphere-tracking-id");h&&null!=h&&(a.uuid=h.split(" ").pop());a.headers&&e.util.each(c.headers,function(a){var c=b.getResponseHeader(a);c&&(f.headers[a]=c)})}catch(g){}else a.lastTimestamp=e.util.now(),a.uuid=z}function ea(b){ha(b,c);ha(b,e.util)}function ha(b,a){switch(b.state){case "messageReceived":C=0;if("undefined"!==typeof a.onMessage)a.onMessage(b);break;case "error":if("undefined"!== typeof a.onError)a.onError(b);break;case "opening":if("undefined"!==typeof a.onOpen)a.onOpen(b);break;case "messagePublished":if("undefined"!==typeof a.onMessagePublished)a.onMessagePublished(b);break;case "re-connecting":if("undefined"!==typeof a.onReconnect)a.onReconnect(c,b);break;case "re-opening":if("undefined"!==typeof a.onReopen)a.onReopen(c,b);break;case "fail-to-reconnect":if("undefined"!==typeof a.onFailureToReconnect)a.onFailureToReconnect(c,b);break;case "unsubscribe":case "closed":var d= "undefined"!==typeof c.closed?c.closed:!1;if("undefined"!==typeof a.onClose&&!d)a.onClose(b);c.closed=!0}}function I(b){"closed"!==f.state&&(f.state="closed",f.responseBody="",f.messages=[],f.status=b?200:501,y())}function y(){var b=function(a,b){b(f)};null==w&&null!=P&&P(f.responseBody);c.reconnect=c.mrequest;for(var a="string"===typeof f.responseBody,d=a&&c.trackMessageLength?0<f.messages.length?f.messages:[""]:Array(f.responseBody),h=0;h<d.length;h++)if(!(1<d.length&&0===d[h].length)&&(f.responseBody= a?e.util.trim(d[h]):d[h],null==w&&null!=P&&P(f.responseBody),0!==f.responseBody.length||"messageReceived"!==f.state)){ea(f);if(0<D.length){"debug"===c.logLevel&&e.util.debug("Invoking "+D.length+" global callbacks: "+f.state);try{e.util.each(D,b)}catch(g){e.util.log(c.logLevel,["Callback exception"+g])}}if("function"===typeof c.callback){"debug"===c.logLevel&&e.util.debug("Invoking request callbacks");try{c.callback(f)}catch(l){e.util.log(c.logLevel,["Callback exception"+l])}}}}var c={timeout:3E5, method:"GET",headers:{},contentType:"",callback:null,url:"",data:"",suspend:!0,maxRequest:-1,reconnect:!0,maxStreamingLength:1E7,lastIndex:0,logLevel:"info",requestCount:0,fallbackMethod:"GET",fallbackTransport:"streaming",transport:"long-polling",webSocketImpl:null,webSocketBinaryType:null,dispatchUrl:null,webSocketPathDelimiter:"@@",enableXDR:!1,rewriteURL:!1,attachHeadersAsQueryString:!0,executeCallbackBeforeReconnect:!1,readyState:0,lastTimestamp:0,withCredentials:!1,trackMessageLength:!1,messageDelimiter:"|", connectTimeout:-1,reconnectInterval:0,dropAtmosphereHeaders:!0,uuid:0,async:!0,shared:!1,readResponsesHeaders:!1,maxReconnectOnClose:5,enableProtocol:!0,onError:function(b){},onClose:function(b){},onOpen:function(b){},onMessage:function(b){},onReopen:function(b,a){},onReconnect:function(b,a){},onMessagePublished:function(b){},onTransportFailure:function(b,a){},onLocalMessage:function(b){},onFailureToReconnect:function(b,a){}},f={status:200,reasonPhrase:"OK",responseBody:"",messages:[],headers:[], state:"messageReceived",transport:"polling",error:null,request:null,partialMessage:"",errorHandled:!1,id:0},r=null,t=null,M=null,v=null,E=null,W=!0,C=0,J=!1,P=null,B,w=null,z=e.util.now(),R;aa(d);this.subscribe=function(b){aa(b);F()};this.execute=function(){F()};this.close=function(){m()};this.disconnect=function(){g()};this.getUrl=function(){return c.url};this.push=function(b,a){if(null!=a){var d=c.dispatchUrl;c.dispatchUrl=a;X(b);c.dispatchUrl=d}else X(b)};this.getUUID=function(){return c.uuid}; this.pushLocal=function(b){if(0!==b.length)try{w?w.localSend(b):B&&B.signal("localMessage",e.util.stringifyJSON({id:z,event:b}))}catch(a){e.util.error(a)}};this.enableProtocol=function(b){return c.enableProtocol};this.request=c;this.response=f},subscribe:function(d,h,g){"function"===typeof h&&e.addCallback(h);"string"!==typeof d?g=d:g.url=d;d=new e.AtmosphereRequest(g);d.execute();return s[s.length]=d},unsubscribe:function(){if(0<s.length)for(var d=[].concat(s),e=0;e<d.length;e++){var g=d[e];g.close(); clearTimeout(g.response.request.id)}s=[];D=[]},unsubscribeUrl:function(d){var e=-1;if(0<s.length)for(var g=0;g<s.length;g++){var m=s[g];if(m.getUrl()===d){m.close();clearTimeout(m.response.request.id);e=g;break}}0<=e&&s.splice(e,1)},addCallback:function(d){-1===e.util.inArray(d,D)&&D.push(d)},removeCallback:function(d){d=e.util.inArray(d,D);-1!==d&&D.splice(d,1)},util:{browser:{},parseHeaders:function(d){for(var e,g=/^(.*?):[ \t]*([^\r\n]*)\r?$/mg,m={};e=g.exec(d);)m[e[1]]=e[2];return m},now:function(){return(new Date).getTime()}, isArray:function(d){return"[object Array]"===Object.prototype.toString.call(d)},isBinary:function(d){d=Object.prototype.toString.call(d);return"[object Blob]"===d||"[object ArrayBuffer]"===d},isFunction:function(d){return"[object Function]"===Object.prototype.toString.call(d)},getAbsoluteURL:function(d){var e=document.createElement("div");e.innerHTML='<a href="'+d+'"/>';return encodeURI(decodeURI(e.firstChild.href))},prepareURL:function(d){var h=e.util.now(),g=d.replace(/([?&])_=[^&]*/,"$1_="+h); return g+(g===d?(/\?/.test(d)?"&":"?")+"_="+h:"")},trim:function(d){return String.prototype.trim?d.toString().trim():d.toString().replace(/(?:(?:^|\n)\s+|\s+(?:$|\n))/g,"").replace(/\s+/g," ")},param:function(d){function h(d,g){g=e.util.isFunction(g)?g():null==g?"":g;l.push(encodeURIComponent(d)+"="+encodeURIComponent(g))}function g(d,l){var m;if(e.util.isArray(l))e.util.each(l,function(e,l){/\[\]$/.test(d)?h(d,l):g(d+"["+("object"===typeof l?e:"")+"]",l)});else if("[object Object]"===Object.prototype.toString.call(l))for(m in l)g(d+ "["+m+"]",l[m]);else h(d,l)}var m,l=[];for(m in d)g(m,d[m]);return l.join("&").replace(/%20/g,"+")},supportStorage:function(){var d=window.localStorage;if(d)try{return d.setItem("t","t"),d.removeItem("t"),window.StorageEvent&&!e.util.browser.msie&&!(e.util.browser.mozilla&&"1"===e.util.browser.version.split(".")[0])}catch(h){}return!1},iterate:function(d,e){var g;e=e||0;(function l(){g=setTimeout(function(){!1!==d()&&l()},e)})();return function(){clearTimeout(g)}},each:function(d,h,g){var m,l=0,s= d.length;m=e.util.isArray(d);if(g)if(m)for(;l<s&&(m=h.apply(d[l],g),!1!==m);l++);else for(l in d){if(m=h.apply(d[l],g),!1===m)break}else if(m)for(;l<s&&(m=h.call(d[l],l,d[l]),!1!==m);l++);else for(l in d)if(m=h.call(d[l],l,d[l]),!1===m)break;return d},extend:function(d){var e,g,m;for(e=1;e<arguments.length;e++)if(null!=(g=arguments[e]))for(m in g)d[m]=g[m];return d},on:function(d,e,g){d.addEventListener?d.addEventListener(e,g,!1):d.attachEvent&&d.attachEvent("on"+e,g)},off:function(d,e,g){d.removeEventListener? d.removeEventListener(e,g,!1):d.detachEvent&&d.detachEvent("on"+e,g)},log:function(d,e){if(window.console){var g=window.console[d];"function"===typeof g&&g.apply(window.console,e)}},warn:function(){e.util.log("warn",arguments)},info:function(){e.util.log("info",arguments)},debug:function(){e.util.log("debug",arguments)},error:function(){e.util.log("error",arguments)},xhr:function(){try{return new window.XMLHttpRequest}catch(d){try{return new window.ActiveXObject("Microsoft.XMLHTTP")}catch(e){}}}, parseJSON:function(d){return d?window.JSON&&window.JSON.parse?window.JSON.parse(d):(new Function("return "+d))():null},stringifyJSON:function(d){function e(d){return'"'+d.replace(m,function(d){var e=l[d];return"string"===typeof e?e:"\\u"+("0000"+d.charCodeAt(0).toString(16)).slice(-4)})+'"'}function g(d){return 10>d?"0"+d:d}var m=/[\\\"\x00-\x1f\x7f-\x9f\u00ad\u0600-\u0604\u070f\u17b4\u17b5\u200c-\u200f\u2028-\u202f\u2060-\u206f\ufeff\ufff0-\uffff]/g,l={"\b":"\\b","\t":"\\t","\n":"\\n","\f":"\\f", "\r":"\\r",'"':'\\"',"\\":"\\\\"};return window.JSON&&window.JSON.stringify?window.JSON.stringify(d):function F(d,l){var m,s,x,q=l[d];x=typeof q;q&&("object"===typeof q&&"function"===typeof q.toJSON)&&(q=q.toJSON(d),x=typeof q);switch(x){case "string":return e(q);case "number":return isFinite(q)?String(q):"null";case "boolean":return String(q);case "object":if(!q)return"null";switch(Object.prototype.toString.call(q)){case "[object Date]":return isFinite(q.valueOf())?'"'+q.getUTCFullYear()+"-"+g(q.getUTCMonth()+ 1)+"-"+g(q.getUTCDate())+"T"+g(q.getUTCHours())+":"+g(q.getUTCMinutes())+":"+g(q.getUTCSeconds())+'Z"':"null";case "[object Array]":s=q.length;x=[];for(m=0;m<s;m++)x.push(F(m,q)||"null");return"["+x.join(",")+"]";default:x=[];for(m in q)U.call(q,m)&&(s=F(m,q))&&x.push(e(m)+":"+s);return"{"+x.join(",")+"}"}}}("",{"":d})},checkCORSSupport:function(){return e.util.browser.msie&&!window.XDomainRequest||e.util.browser.opera&&12>e.util.browser.version?!0:-1<navigator.userAgent.toLowerCase().indexOf("android")? !0:!1}}};e.util.now();(function(){var d=navigator.userAgent.toLowerCase(),d=/(chrome)[ \/]([\w.]+)/.exec(d)||/(webkit)[ \/]([\w.]+)/.exec(d)||/(opera)(?:.*version|)[ \/]([\w.]+)/.exec(d)||/(msie) ([\w.]+)/.exec(d)||0>d.indexOf("compatible")&&/(mozilla)(?:.*? rv:([\w.]+)|)/.exec(d)||[];e.util.browser[d[1]||""]=!0;e.util.browser.version=d[2]||"0";if(e.util.browser.msie||e.util.browser.mozilla&&"1"===e.util.browser.version.split(".")[0])e.util.storage=!1})();e.util.on(window,"unload",function(d){e.unsubscribe()}); e.util.on(window,"keypress",function(d){27===d.which&&d.preventDefault()});e.util.on(window,"offline",function(){e.unsubscribe()});window.atmosphere=e})();
diff --git a/ajax/libs/atmosphere/package.json b/ajax/libs/atmosphere/package.json
index 112c8d5d9..d572c5c9e 100644
--- a/ajax/libs/atmosphere/package.json
+++ b/ajax/libs/atmosphere/package.json
@@ -1,7 +1,7 @@
 {
     "name": "atmosphere",
     "filename": "atmosphere.min.js",
-    "version": "2.0.0.RC2",
+    "version": "2.0.0.RC4",
     "description": "A browser-side JavaScript client for the Atmosphere",
     "homepage": "https://github.com/Atmosphere/atmosphere-javascript",
     "keywords": [