OSGi bundle were fixed. Some package reorganization.

pom.xml

@@ -98,37 +98,31 @@
   	<groupId>io.netty</groupId>
   	<artifactId>netty-buffer</artifactId>
   	<version>4.0.13.Final</version>
-  	<type>bundle</type>
   </dependency>
   <dependency>
   	<groupId>io.netty</groupId>
   	<artifactId>netty-common</artifactId>
   	<version>4.0.13.Final</version>
-  	<type>bundle</type>
   </dependency>
   <dependency>
   	<groupId>io.netty</groupId>
   	<artifactId>netty-transport</artifactId>
   	<version>4.0.13.Final</version>
-  	<type>bundle</type>
   </dependency>
   <dependency>
   	<groupId>io.netty</groupId>
   	<artifactId>netty-handler</artifactId>
   	<version>4.0.13.Final</version>
-  	<type>bundle</type>
   </dependency>
   <dependency>
   	<groupId>io.netty</groupId>
   	<artifactId>netty-codec-http</artifactId>
   	<version>4.0.13.Final</version>
-  	<type>bundle</type>
   </dependency>
   <dependency>
   	<groupId>io.netty</groupId>
   	<artifactId>netty-codec</artifactId>
   	<version>4.0.13.Final</version>
-  	<type>bundle</type>
   </dependency>
   
   <dependency>
@@ -160,10 +154,10 @@
   	<version>2.2.3</version>
   </dependency>
     <dependency>
-    	<groupId>org.apache.servicemix.bundles</groupId>
-    	<artifactId>org.apache.servicemix.bundles.jedis</artifactId>
-    	<version>2.2.1_1</version>
-    	<type>bundle</type>
+        <groupId>redis.clients</groupId>
+        <artifactId>jedis</artifactId>
+        <version>2.2.1</version>
+        <scope>provided</scope>
     </dependency>
  </dependencies>
 
@@ -272,15 +266,9 @@
                    <Embed-Dependency>netty-socketio;scope=compile</Embed-Dependency>
                    <Export-Package>
                     com.corundumstudio.socketio;version="${project.version}",
-                    com.corundumstudio.socketio.ack;version="${project.version}",
                     com.corundumstudio.socketio.annotation;version="${project.version}",
-                    com.corundumstudio.socketio.handler;version="${project.version}",
                     com.corundumstudio.socketio.listener;version="${project.version}",
-                    com.corundumstudio.socketio.messages;version="${project.version}",
-                    com.corundumstudio.socketio.misc;version="${project.version}",
-                    com.corundumstudio.socketio.namespace;version="${project.version}",
-                    com.corundumstudio.socketio.parser;version="${project.version}",
-                    com.corundumstudio.socketio.scheduler;version="${project.version}",                       
+                    com.corundumstudio.socketio.store;version="${project.version}",                       
                    </Export-Package>
                </instructions>
            </configuration>

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

@@ -25,6 +25,7 @@ import com.corundumstudio.socketio.misc.IterableCollection;
 import com.corundumstudio.socketio.namespace.Namespace;
 import com.corundumstudio.socketio.parser.Packet;
 import com.corundumstudio.socketio.parser.PacketType;
+import com.corundumstudio.socketio.store.StoreFactory;
 import com.corundumstudio.socketio.store.pubsub.DispatchMessage;
 import com.corundumstudio.socketio.store.pubsub.PubSubStore;
 

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

@@ -22,6 +22,7 @@ import java.io.InputStream;
 import com.corundumstudio.socketio.parser.JacksonJsonSupport;
 import com.corundumstudio.socketio.parser.JsonSupport;
 import com.corundumstudio.socketio.store.MemoryStoreFactory;
+import com.corundumstudio.socketio.store.StoreFactory;
 
 public class Configuration {
 

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

@@ -40,6 +40,7 @@ import com.corundumstudio.socketio.handler.AuthorizeHandler;
 import com.corundumstudio.socketio.handler.EncoderHandler;
 import com.corundumstudio.socketio.handler.HeartbeatHandler;
 import com.corundumstudio.socketio.handler.PacketHandler;
+import com.corundumstudio.socketio.handler.PacketListener;
 import com.corundumstudio.socketio.handler.ResourceHandler;
 import com.corundumstudio.socketio.handler.WrongUrlHandler;
 import com.corundumstudio.socketio.misc.CompositeIterable;
@@ -49,6 +50,7 @@ import com.corundumstudio.socketio.parser.Decoder;
 import com.corundumstudio.socketio.parser.Encoder;
 import com.corundumstudio.socketio.parser.JsonSupport;
 import com.corundumstudio.socketio.scheduler.CancelableScheduler;
+import com.corundumstudio.socketio.store.StoreFactory;
 import com.corundumstudio.socketio.transport.FlashPolicyHandler;
 import com.corundumstudio.socketio.transport.FlashSocketTransport;
 import com.corundumstudio.socketio.transport.MainBaseClient;

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

@@ -21,6 +21,7 @@ import java.util.List;
 import java.util.UUID;
 
 import com.corundumstudio.socketio.parser.Packet;
+import com.corundumstudio.socketio.store.Store;
 
 
 /**

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

@@ -24,7 +24,6 @@ import io.netty.util.CharsetUtil;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import com.corundumstudio.socketio.PacketListener;
 import com.corundumstudio.socketio.messages.PacketsMessage;
 import com.corundumstudio.socketio.namespace.Namespace;
 import com.corundumstudio.socketio.namespace.NamespacesHub;

src/main/java/com/corundumstudio/socketio/PacketListener.java → src/main/java/com/corundumstudio/socketio/handler/PacketListener.java

@@ -13,16 +13,15 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.corundumstudio.socketio;
+package com.corundumstudio.socketio.handler;
 
 import java.util.Collections;
 
+import com.corundumstudio.socketio.AckRequest;
 import com.corundumstudio.socketio.ack.AckManager;
-import com.corundumstudio.socketio.handler.HeartbeatHandler;
 import com.corundumstudio.socketio.namespace.Namespace;
 import com.corundumstudio.socketio.namespace.NamespacesHub;
 import com.corundumstudio.socketio.parser.Packet;
-import com.corundumstudio.socketio.store.pubsub.PubSubStore;
 import com.corundumstudio.socketio.transport.NamespaceClient;
 
 public class PacketListener {

src/main/java/com/corundumstudio/socketio/namespace/Namespace.java

@@ -30,13 +30,13 @@ import com.corundumstudio.socketio.AckRequest;
 import com.corundumstudio.socketio.BroadcastOperations;
 import com.corundumstudio.socketio.SocketIOClient;
 import com.corundumstudio.socketio.SocketIONamespace;
-import com.corundumstudio.socketio.StoreFactory;
 import com.corundumstudio.socketio.annotation.ScannerEngine;
 import com.corundumstudio.socketio.listener.ConnectListener;
 import com.corundumstudio.socketio.listener.DataListener;
 import com.corundumstudio.socketio.listener.DisconnectListener;
 import com.corundumstudio.socketio.parser.JsonSupport;
 import com.corundumstudio.socketio.parser.Packet;
+import com.corundumstudio.socketio.store.StoreFactory;
 import com.corundumstudio.socketio.store.pubsub.DispatchMessage;
 import com.corundumstudio.socketio.store.pubsub.JoinLeaveMessage;
 import com.corundumstudio.socketio.store.pubsub.PubSubStore;

src/main/java/com/corundumstudio/socketio/namespace/NamespacesHub.java

@@ -21,9 +21,9 @@ import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ConcurrentMap;
 
 import com.corundumstudio.socketio.SocketIOClient;
-import com.corundumstudio.socketio.StoreFactory;
 import com.corundumstudio.socketio.misc.CompositeIterable;
 import com.corundumstudio.socketio.parser.JsonSupport;
+import com.corundumstudio.socketio.store.StoreFactory;
 
 public class NamespacesHub {
 

src/main/java/com/corundumstudio/socketio/store/MemoryStore.java

@@ -18,8 +18,6 @@ package com.corundumstudio.socketio.store;
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
 
-import com.corundumstudio.socketio.Store;
-
 public class MemoryStore implements Store {
 
     private final Map<String, String> store = new ConcurrentHashMap<String, String>();

src/main/java/com/corundumstudio/socketio/store/MemoryStoreFactory.java

@@ -17,7 +17,6 @@ package com.corundumstudio.socketio.store;
 
 import java.util.UUID;
 
-import com.corundumstudio.socketio.Store;
 import com.corundumstudio.socketio.store.pubsub.BaseStoreFactory;
 import com.corundumstudio.socketio.store.pubsub.PubSubStore;
 

src/main/java/com/corundumstudio/socketio/store/RedisStore.java

@@ -19,19 +19,13 @@ import java.util.UUID;
 
 import redis.clients.jedis.Jedis;
 
-import com.corundumstudio.socketio.Store;
-
 public class RedisStore implements Store {
 
-    private Jedis client;
-
+    private final Jedis client;
     private final String sessionId;
 
-    public RedisStore(UUID sessionId) {
+    public RedisStore(UUID sessionId, Jedis client) {
         this.sessionId = sessionId.toString();
-    }
-
-    public void setClient(Jedis client) {
         this.client = client;
     }
 

src/main/java/com/corundumstudio/socketio/store/RedisStoreFactory.java

@@ -19,7 +19,6 @@ import java.util.UUID;
 
 import redis.clients.jedis.Jedis;
 
-import com.corundumstudio.socketio.Store;
 import com.corundumstudio.socketio.namespace.NamespacesHub;
 import com.corundumstudio.socketio.parser.JsonSupport;
 import com.corundumstudio.socketio.store.pubsub.BaseStoreFactory;
@@ -59,9 +58,7 @@ public class RedisStoreFactory extends BaseStoreFactory {
 
     @Override
     public Store create(UUID sessionId) {
-        RedisStore store = new RedisStore(sessionId);
-        store.setClient(redisClient);
-        return store;
+        return new RedisStore(sessionId, redisClient);
     }
 
     public PubSubStore getPubSubStore() {

src/main/java/com/corundumstudio/socketio/Store.java → src/main/java/com/corundumstudio/socketio/store/Store.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.corundumstudio.socketio;
+package com.corundumstudio.socketio.store;
 
 
 public interface Store {

src/main/java/com/corundumstudio/socketio/StoreFactory.java → src/main/java/com/corundumstudio/socketio/store/StoreFactory.java

@@ -13,10 +13,11 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.corundumstudio.socketio;
+package com.corundumstudio.socketio.store;
 
 import java.util.UUID;
 
+import com.corundumstudio.socketio.Disconnectable;
 import com.corundumstudio.socketio.namespace.NamespacesHub;
 import com.corundumstudio.socketio.parser.JsonSupport;
 import com.corundumstudio.socketio.store.pubsub.PubSubStore;

src/main/java/com/corundumstudio/socketio/store/pubsub/BaseStoreFactory.java

@@ -15,9 +15,9 @@
  */
 package com.corundumstudio.socketio.store.pubsub;
 
-import com.corundumstudio.socketio.StoreFactory;
 import com.corundumstudio.socketio.namespace.NamespacesHub;
 import com.corundumstudio.socketio.parser.JsonSupport;
+import com.corundumstudio.socketio.store.StoreFactory;
 import com.corundumstudio.socketio.transport.MainBaseClient;
 
 public abstract class BaseStoreFactory implements StoreFactory {

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

@@ -20,11 +20,11 @@ import io.netty.channel.ChannelHandler.Sharable;
 
 import com.corundumstudio.socketio.DisconnectableHub;
 import com.corundumstudio.socketio.SocketIOChannelInitializer;
-import com.corundumstudio.socketio.StoreFactory;
 import com.corundumstudio.socketio.Transport;
 import com.corundumstudio.socketio.ack.AckManager;
 import com.corundumstudio.socketio.handler.AuthorizeHandler;
 import com.corundumstudio.socketio.handler.HeartbeatHandler;
+import com.corundumstudio.socketio.store.StoreFactory;
 
 @Sharable
 public class FlashSocketTransport extends WebSocketTransport {

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

@@ -25,15 +25,15 @@ import java.util.UUID;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ConcurrentMap;
 
-import com.corundumstudio.socketio.Store;
 import com.corundumstudio.socketio.DisconnectableHub;
 import com.corundumstudio.socketio.SocketIOClient;
-import com.corundumstudio.socketio.StoreFactory;
 import com.corundumstudio.socketio.Transport;
 import com.corundumstudio.socketio.ack.AckManager;
 import com.corundumstudio.socketio.namespace.Namespace;
 import com.corundumstudio.socketio.parser.Packet;
 import com.corundumstudio.socketio.parser.PacketType;
+import com.corundumstudio.socketio.store.Store;
+import com.corundumstudio.socketio.store.StoreFactory;
 
 /**
  * Base class for main client.

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

@@ -21,11 +21,11 @@ import io.netty.channel.ChannelFuture;
 import java.util.UUID;
 
 import com.corundumstudio.socketio.DisconnectableHub;
-import com.corundumstudio.socketio.StoreFactory;
 import com.corundumstudio.socketio.Transport;
 import com.corundumstudio.socketio.ack.AckManager;
 import com.corundumstudio.socketio.messages.WebSocketPacketMessage;
 import com.corundumstudio.socketio.parser.Packet;
+import com.corundumstudio.socketio.store.StoreFactory;
 
 public class WebSocketClient extends MainBaseClient {
 

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

@@ -41,12 +41,12 @@ import org.slf4j.LoggerFactory;
 import com.corundumstudio.socketio.DisconnectableHub;
 import com.corundumstudio.socketio.SocketIOClient;
 import com.corundumstudio.socketio.SocketIOChannelInitializer;
-import com.corundumstudio.socketio.StoreFactory;
 import com.corundumstudio.socketio.Transport;
 import com.corundumstudio.socketio.ack.AckManager;
 import com.corundumstudio.socketio.handler.AuthorizeHandler;
 import com.corundumstudio.socketio.handler.HeartbeatHandler;
 import com.corundumstudio.socketio.messages.PacketsMessage;
+import com.corundumstudio.socketio.store.StoreFactory;
 
 @Sharable
 public class WebSocketTransport extends BaseTransport {

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

@@ -24,11 +24,11 @@ import java.util.UUID;
 import java.util.concurrent.ConcurrentLinkedQueue;
 
 import com.corundumstudio.socketio.DisconnectableHub;
-import com.corundumstudio.socketio.StoreFactory;
 import com.corundumstudio.socketio.Transport;
 import com.corundumstudio.socketio.ack.AckManager;
 import com.corundumstudio.socketio.messages.XHRSendPacketsMessage;
 import com.corundumstudio.socketio.parser.Packet;
+import com.corundumstudio.socketio.store.StoreFactory;
 
 public class XHRPollingClient extends MainBaseClient {
 

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

@@ -26,7 +26,6 @@ import junit.framework.Assert;
 import mockit.Mocked;
 
 import com.corundumstudio.socketio.Configuration;
-import com.corundumstudio.socketio.PacketListener;
 import com.corundumstudio.socketio.transport.NamespaceClient;
 
 import io.netty.buffer.ByteBuf;