Replace messaging module with DGroup features.

atomix · Mar 31, 2016 · 08b91e9 · 08b91e9
1 parent ee6a072
commit 08b91e9
Show file tree

Hide file tree

Showing 125 changed files with 145 additions and 1,212 deletions.
diff --git a/collections/src/main/java/io/atomix/collections/DistributedMap.java b/collections/src/main/java/io/atomix/collections/DistributedMap.java
@@ -15,7 +15,7 @@
  */
 package io.atomix.collections;
 
-import io.atomix.collections.state.MapCommands;
+import io.atomix.collections.internal.MapCommands;
 import io.atomix.collections.util.DistributedMapFactory;
 import io.atomix.copycat.client.CopycatClient;
 import io.atomix.resource.AbstractResource;

diff --git a/collections/src/main/java/io/atomix/collections/DistributedMultiMap.java b/collections/src/main/java/io/atomix/collections/DistributedMultiMap.java
@@ -15,7 +15,7 @@
  */
 package io.atomix.collections;
 
-import io.atomix.collections.state.MultiMapCommands;
+import io.atomix.collections.internal.MultiMapCommands;
 import io.atomix.collections.util.DistributedMultiMapFactory;
 import io.atomix.copycat.client.CopycatClient;
 import io.atomix.resource.AbstractResource;

diff --git a/collections/src/main/java/io/atomix/collections/DistributedQueue.java b/collections/src/main/java/io/atomix/collections/DistributedQueue.java
@@ -15,7 +15,7 @@
  */
 package io.atomix.collections;
 
-import io.atomix.collections.state.QueueCommands;
+import io.atomix.collections.internal.QueueCommands;
 import io.atomix.collections.util.DistributedQueueFactory;
 import io.atomix.copycat.client.CopycatClient;
 import io.atomix.resource.AbstractResource;

diff --git a/collections/src/main/java/io/atomix/collections/DistributedSet.java b/collections/src/main/java/io/atomix/collections/DistributedSet.java
@@ -15,7 +15,7 @@
  */
 package io.atomix.collections;
 
-import io.atomix.collections.state.SetCommands;
+import io.atomix.collections.internal.SetCommands;
 import io.atomix.collections.util.DistributedSetFactory;
 import io.atomix.copycat.client.CopycatClient;
 import io.atomix.resource.AbstractResource;

diff --git a/...atomix/collections/state/MapCommands.java → ...mix/collections/internal/MapCommands.java b/...atomix/collections/state/MapCommands.java → ...mix/collections/internal/MapCommands.java
@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.atomix.collections.state;
+package io.atomix.collections.internal;
 
 import io.atomix.catalyst.buffer.BufferInput;
 import io.atomix.catalyst.buffer.BufferOutput;

diff --git a/...io/atomix/collections/state/MapState.java → ...atomix/collections/internal/MapState.java b/...io/atomix/collections/state/MapState.java → ...atomix/collections/internal/MapState.java
@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.atomix.collections.state;
+package io.atomix.collections.internal;
 
 import io.atomix.catalyst.util.Assert;
 import io.atomix.catalyst.util.concurrent.Scheduled;

diff --git a/...x/collections/state/MultiMapCommands.java → ...ollections/internal/MultiMapCommands.java b/...x/collections/state/MultiMapCommands.java → ...ollections/internal/MultiMapCommands.java
@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.atomix.collections.state;
+package io.atomix.collections.internal;
 
 import io.atomix.catalyst.buffer.BufferInput;
 import io.atomix.catalyst.buffer.BufferOutput;

diff --git a/...omix/collections/state/MultiMapState.java → ...x/collections/internal/MultiMapState.java b/...omix/collections/state/MultiMapState.java → ...x/collections/internal/MultiMapState.java
@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.atomix.collections.state;
+package io.atomix.collections.internal;
 
 import io.atomix.catalyst.util.concurrent.Scheduled;
 import io.atomix.collections.DistributedMultiMap;

diff --git a/...omix/collections/state/QueueCommands.java → ...x/collections/internal/QueueCommands.java b/...omix/collections/state/QueueCommands.java → ...x/collections/internal/QueueCommands.java
@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.atomix.collections.state;
+package io.atomix.collections.internal;
 
 import io.atomix.catalyst.buffer.BufferInput;
 import io.atomix.catalyst.buffer.BufferOutput;

diff --git a/.../atomix/collections/state/QueueState.java → ...omix/collections/internal/QueueState.java b/.../atomix/collections/state/QueueState.java → ...omix/collections/internal/QueueState.java
@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.atomix.collections.state;
+package io.atomix.collections.internal;
 
 import io.atomix.copycat.server.Commit;
 import io.atomix.resource.ResourceStateMachine;

diff --git a/...atomix/collections/state/SetCommands.java → ...mix/collections/internal/SetCommands.java b/...atomix/collections/state/SetCommands.java → ...mix/collections/internal/SetCommands.java
@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.atomix.collections.state;
+package io.atomix.collections.internal;
 
 import io.atomix.catalyst.buffer.BufferInput;
 import io.atomix.catalyst.buffer.BufferOutput;

diff --git a/...io/atomix/collections/state/SetState.java → ...atomix/collections/internal/SetState.java b/...io/atomix/collections/state/SetState.java → ...atomix/collections/internal/SetState.java
@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.atomix.collections.state;
+package io.atomix.collections.internal;
 
 import io.atomix.catalyst.util.concurrent.Scheduled;
 import io.atomix.copycat.server.Commit;

diff --git a/collections/src/main/java/io/atomix/collections/util/DistributedMapFactory.java b/collections/src/main/java/io/atomix/collections/util/DistributedMapFactory.java
@@ -17,8 +17,8 @@
 
 import io.atomix.catalyst.serializer.SerializableTypeResolver;
 import io.atomix.collections.DistributedMap;
-import io.atomix.collections.state.MapCommands;
+import io.atomix.collections.internal.MapCommands;
-import io.atomix.collections.state.MapState;
+import io.atomix.collections.internal.MapState;
 import io.atomix.copycat.client.CopycatClient;
 import io.atomix.resource.ResourceFactory;
 import io.atomix.resource.ResourceStateMachine;

diff --git a/collections/src/main/java/io/atomix/collections/util/DistributedMultiMapFactory.java b/collections/src/main/java/io/atomix/collections/util/DistributedMultiMapFactory.java
@@ -17,8 +17,8 @@
 
 import io.atomix.catalyst.serializer.SerializableTypeResolver;
 import io.atomix.collections.DistributedMultiMap;
-import io.atomix.collections.state.MultiMapCommands;
+import io.atomix.collections.internal.MultiMapCommands;
-import io.atomix.collections.state.MultiMapState;
+import io.atomix.collections.internal.MultiMapState;
 import io.atomix.copycat.client.CopycatClient;
 import io.atomix.resource.ResourceFactory;
 import io.atomix.resource.ResourceStateMachine;

diff --git a/collections/src/main/java/io/atomix/collections/util/DistributedQueueFactory.java b/collections/src/main/java/io/atomix/collections/util/DistributedQueueFactory.java
@@ -17,8 +17,8 @@
 
 import io.atomix.catalyst.serializer.SerializableTypeResolver;
 import io.atomix.collections.DistributedQueue;
-import io.atomix.collections.state.QueueCommands;
+import io.atomix.collections.internal.QueueCommands;
-import io.atomix.collections.state.QueueState;
+import io.atomix.collections.internal.QueueState;
 import io.atomix.copycat.client.CopycatClient;
 import io.atomix.resource.ResourceFactory;
 import io.atomix.resource.ResourceStateMachine;

diff --git a/collections/src/main/java/io/atomix/collections/util/DistributedSetFactory.java b/collections/src/main/java/io/atomix/collections/util/DistributedSetFactory.java
@@ -17,8 +17,8 @@
 
 import io.atomix.catalyst.serializer.SerializableTypeResolver;
 import io.atomix.collections.DistributedSet;
-import io.atomix.collections.state.SetCommands;
+import io.atomix.collections.internal.SetCommands;
-import io.atomix.collections.state.SetState;
+import io.atomix.collections.internal.SetState;
 import io.atomix.copycat.client.CopycatClient;
 import io.atomix.resource.ResourceFactory;
 import io.atomix.resource.ResourceStateMachine;

diff --git a/concurrent/src/main/java/io/atomix/concurrent/DistributedLock.java b/concurrent/src/main/java/io/atomix/concurrent/DistributedLock.java
@@ -15,7 +15,7 @@
  */
 package io.atomix.concurrent;
 
-import io.atomix.concurrent.state.LockCommands;
+import io.atomix.concurrent.internal.LockCommands;
 import io.atomix.concurrent.util.DistributedLockFactory;
 import io.atomix.copycat.client.CopycatClient;
 import io.atomix.resource.AbstractResource;

diff --git a/...atomix/concurrent/state/LockCommands.java → ...mix/concurrent/internal/LockCommands.java b/...atomix/concurrent/state/LockCommands.java → ...mix/concurrent/internal/LockCommands.java
@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.atomix.concurrent.state;
+package io.atomix.concurrent.internal;
 
 import io.atomix.catalyst.buffer.BufferInput;
 import io.atomix.catalyst.buffer.BufferOutput;

diff --git a/...io/atomix/concurrent/state/LockState.java → ...atomix/concurrent/internal/LockState.java b/...io/atomix/concurrent/state/LockState.java → ...atomix/concurrent/internal/LockState.java
@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package io.atomix.concurrent.state;
+package io.atomix.concurrent.internal;
 
 import io.atomix.catalyst.util.concurrent.Scheduled;
 import io.atomix.copycat.server.Commit;

diff --git a/concurrent/src/main/java/io/atomix/concurrent/util/DistributedLockFactory.java b/concurrent/src/main/java/io/atomix/concurrent/util/DistributedLockFactory.java
@@ -17,8 +17,8 @@
 
 import io.atomix.catalyst.serializer.SerializableTypeResolver;
 import io.atomix.concurrent.DistributedLock;
-import io.atomix.concurrent.state.LockCommands;
+import io.atomix.concurrent.internal.LockCommands;
-import io.atomix.concurrent.state.LockState;
+import io.atomix.concurrent.internal.LockState;
 import io.atomix.copycat.client.CopycatClient;
 import io.atomix.resource.ResourceFactory;
 import io.atomix.resource.ResourceStateMachine;