Issue #1 fixed

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

@@ -1,3 +1,18 @@
+/**
+ * Copyright 2012 Nikita Koksharov
+ *
+ * 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.
+ */
 package com.corundumstudio.socketio;
 
 import java.io.IOException;

src/main/java/com/corundumstudio/socketio/messages/AuthorizeMessage.java

@@ -24,10 +24,10 @@
 
 public class AuthorizeMessage extends BaseMessage {
 
-    private UUID sessionId;
-    private String origin;
-    private String msg;
-    private String jsonpParam;
+    private final UUID sessionId;
+    private final String origin;
+    private final String msg;
+    private final String jsonpParam;
 
     public AuthorizeMessage(String msg, String jsonpParam, String origin, UUID sessionId) {
         this.origin = origin;

src/main/java/com/corundumstudio/socketio/messages/PacketsMessage.java

@@ -1,3 +1,18 @@
+/**
+ * Copyright 2012 Nikita Koksharov
+ *
+ * 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.
+ */
 package com.corundumstudio.socketio.messages;
 
 import org.jboss.netty.buffer.ChannelBuffer;

src/main/java/com/corundumstudio/socketio/messages/WebSocketPacketMessage.java

@@ -25,8 +25,8 @@
 
 public class WebSocketPacketMessage extends BaseMessage {
 
-    private UUID sessionId;
-    private Packet packet;
+    private final UUID sessionId;
+    private final Packet packet;
 
     public WebSocketPacketMessage(UUID sessionId, Packet packet) {
         super();

src/main/java/com/corundumstudio/socketio/messages/WebsocketErrorMessage.java

@@ -24,7 +24,7 @@
 
 public class WebsocketErrorMessage extends BaseMessage {
 
-    private Packet packet;
+    private final Packet packet;
 
     public WebsocketErrorMessage(Packet packet) {
         super();

src/main/java/com/corundumstudio/socketio/messages/XHRErrorMessage.java

@@ -24,8 +24,8 @@
 
 public class XHRErrorMessage extends BaseMessage {
 
-    private Packet packet;
-    private String origin;
+    private final Packet packet;
+    private final String origin;
 
     public XHRErrorMessage(Packet packet, String origin) {
         this.packet = packet;

src/main/java/com/corundumstudio/socketio/messages/XHRNewChannelMessage.java

@@ -24,8 +24,8 @@
 
 public class XHRNewChannelMessage extends BaseMessage {
 
-    private UUID sessionId;
-    private String origin;
+    private final UUID sessionId;
+    private final String origin;
 
     public XHRNewChannelMessage(UUID sessionId, String origin) {
         this.sessionId = sessionId;

src/main/java/com/corundumstudio/socketio/messages/XHRPostMessage.java

@@ -21,7 +21,7 @@
 
 public class XHRPostMessage extends BaseMessage {
 
-    private String origin;
+    private final String origin;
 
     public XHRPostMessage(String origin) {
         this.origin = origin;

src/main/java/com/corundumstudio/socketio/parser/DecoderException.java

@@ -1,3 +1,18 @@
+/**
+ * Copyright 2012 Nikita Koksharov
+ *
+ * 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.
+ */
 package com.corundumstudio.socketio.parser;
 
 public class DecoderException extends RuntimeException {

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

@@ -1,3 +1,18 @@
+/**
+ * Copyright 2012 Nikita Koksharov
+ *
+ * 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.
+ */
 package com.corundumstudio.socketio.transport;
 
 import java.net.SocketAddress;

src/test/java/com/corundumstudio/socketio/PacketHandlerTest.java

@@ -1,3 +1,18 @@
+/**
+ * Copyright 2012 Nikita Koksharov
+ *
+ * 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.
+ */
 package com.corundumstudio.socketio;
 
 import java.util.ArrayList;
@@ -102,7 +117,7 @@ private void testHandler(final AtomicInteger invocations,
         Assert.assertEquals(packets.size(), invocations.get());
     }
 
-    @Test
+    //@Test
     public void testDecodePerf() throws Exception {
         PacketListener listener = new PacketListener(null, null, null) {
             @Override