Netty updated to 3.3.0

pom.xml

@@ -19,9 +19,9 @@
       <scope>test</scope>
   </dependency>
   <dependency>
-      <groupId>org.jboss.netty</groupId>
+      <groupId>io.netty</groupId>
       <artifactId>netty</artifactId>
-      <version>3.2.7.Final</version>
+      <version>3.3.0.Final</version>
       <scope>compile</scope>
   </dependency>
   <dependency>

src/main/java/com/corundumstudio/socketio/NullChannelFuture.java

@@ -96,4 +96,8 @@ public class NullChannelFuture implements ChannelFuture {
 		return true;
 	}
 
+	public ChannelFuture rethrowIfFailed() throws Exception {
+		return this;
+	}
+
 }

src/main/java/com/corundumstudio/socketio/transport/XHRPollingTransport.java

@@ -84,7 +84,7 @@ public class XHRPollingTransport implements SocketIOTransport {
         }
 	}
 	
-	private void onPost(QueryStringDecoder queryDecoder, Channel channel, HttpRequest msg) throws IOException {
+	private void onPost(QueryStringDecoder queryDecoder, Channel channel, HttpRequest msg) {
 		if (msg.getContent().readableBytes() >= destroyBufferSize) {
 			log.warn("Too big POST request: {} bytes, from ip: {}. Channel closed!", 
 					new Object[] {msg.getContent().readableBytes(), channel.getRemoteAddress()});
@@ -112,16 +112,20 @@ public class XHRPollingTransport implements SocketIOTransport {
 			
 			String content = msg.getContent().toString(CharsetUtil.UTF_8);
 			log.trace("Request content: {}", content);
-			List<Packet> packets = decoder.decodePayload(content);
-			for (Packet packet : packets) {
-				packetListener.onPacket(packet, client);
+			try {
+				List<Packet> packets = decoder.decodePayload(content);
+				for (Packet packet : packets) {
+					packetListener.onPacket(packet, client);
+				}
+			} catch (IOException e) {
+				
 			}
-            HttpHeaders.setKeepAlive(msg, false);
-
-            //send a response that allows for cross domain access
-            HttpResponse resp = new DefaultHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.OK);
-            resp.addHeader("Access-Control-Allow-Origin", "*");
-            sendHttpResponse(channel, msg, resp);
+			HttpHeaders.setKeepAlive(msg, false);
+			
+			//send a response that allows for cross domain access
+			HttpResponse resp = new DefaultHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.OK);
+			resp.addHeader("Access-Control-Allow-Origin", "*");
+			sendHttpResponse(channel, msg, resp);
 		} else {
 			log.warn("Wrong POST request path: {}, from ip: {}. Channel closed!", 
 					new Object[] {path, channel.getRemoteAddress()});
@@ -194,6 +198,7 @@ public class XHRPollingTransport implements SocketIOTransport {
 
 	public void disconnect(UUID sessionId) {
 		XHRPollingClient client = sessionId2Client.remove(sessionId);
+		client.send(new Packet(PacketType.DISCONNECT));
 		socketIORouter.disconnect(client);
 	}