Update task queue examples.

examples/task-queue-consumer/src/main/java/io/atomix/examples/taskqueue/TaskQueueConsumerExample.java

@@ -19,7 +19,8 @@
 import io.atomix.AtomixClient;
 import io.atomix.catalyst.transport.Address;
 import io.atomix.catalyst.transport.NettyTransport;
-import io.atomix.messaging.DistributedTaskQueue;
+import io.atomix.group.DistributedGroup;
+import io.atomix.group.LocalMember;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -54,13 +55,16 @@ public static void main(String[] args) throws Exception {
     // Open the client. Once this operation completes resources can be created and managed.
     atomix.open().join();
 
-    // Create a task queue resource.
-    @SuppressWarnings("unchecked")
-    DistributedTaskQueue<String> queue = atomix.<String>getTaskQueue("tasks").get();
+    // Create a group resource.
+    DistributedGroup group = atomix.getGroup("tasks").get();
+
+    // Join the group.
+    LocalMember member = group.join().get();
 
     // Register a callback to be called when a message is received.
-    queue.consumer(task -> {
+    member.tasks().consumer("tasks").onTask(task -> {
       System.out.println("Received " + task);
+      task.ack();
     });
 
     // Block while the replica is open.

examples/task-queue-producer/src/main/java/io/atomix/examples/taskqueue/TaskQueueProducerExample.java

@@ -19,7 +19,8 @@
 import io.atomix.AtomixClient;
 import io.atomix.catalyst.transport.Address;
 import io.atomix.catalyst.transport.NettyTransport;
-import io.atomix.messaging.DistributedTaskQueue;
+import io.atomix.group.DistributedGroup;
+import io.atomix.group.task.TaskProducer;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -56,12 +57,11 @@ public static void main(String[] args) throws Exception {
     atomix.open().join();
 
     // Create a task queue resource.
-    @SuppressWarnings("unchecked")
-    DistributedTaskQueue<String> queue = atomix.<String>getTaskQueue("tasks").get().async();
+    DistributedGroup group = atomix.getGroup("tasks").get();
 
     // Register a callback to be called when a message is received.
     for (int i = 0; i < 100; i++) {
-      submitTasks(queue);
+      submitTasks(group.tasks().producer("tasks"));
     }
 
     // Block while the replica is open.
@@ -73,7 +73,7 @@ public static void main(String[] args) throws Exception {
   /**
    * Recursively submits tasks to the queue.
    */
-  private static void submitTasks(DistributedTaskQueue<String> queue) {
+  private static void submitTasks(TaskProducer<String> queue) {
     queue.submit(UUID.randomUUID().toString()).whenComplete((result, error) -> submitTasks(queue));
   }
 

groups/src/main/java/io/atomix/group/election/internal/GroupElection.java

@@ -19,7 +19,7 @@
 import io.atomix.catalyst.util.Listener;
 import io.atomix.catalyst.util.Listeners;
 import io.atomix.group.Member;
-import io.atomix.group.MembershipGroup;
+import io.atomix.group.internal.MembershipGroup;
 import io.atomix.group.election.Election;
 import io.atomix.group.election.Term;
 

groups/src/main/java/io/atomix/group/internal/AbstractGroupMember.java

@@ -18,7 +18,6 @@
 import io.atomix.catalyst.transport.Address;
 import io.atomix.catalyst.util.Assert;
 import io.atomix.group.Member;
-import io.atomix.group.MembershipGroup;
 import io.atomix.group.messaging.internal.AbstractMessageClient;
 import io.atomix.group.task.internal.AbstractTaskClient;
 

groups/src/main/java/io/atomix/group/internal/GroupMember.java

@@ -16,7 +16,6 @@
 package io.atomix.group.internal;
 
 import io.atomix.group.Member;
-import io.atomix.group.MembershipGroup;
 import io.atomix.group.messaging.internal.ConnectionManager;
 import io.atomix.group.messaging.internal.MemberMessageClient;
 import io.atomix.group.task.internal.MemberTaskClient;

groups/src/main/java/io/atomix/group/internal/LocalGroupMember.java

@@ -16,7 +16,6 @@
 package io.atomix.group.internal;
 
 import io.atomix.group.LocalMember;
-import io.atomix.group.MembershipGroup;
 import io.atomix.group.messaging.internal.ConnectionManager;
 import io.atomix.group.messaging.internal.MemberMessageService;
 import io.atomix.group.task.internal.MemberTaskQueue;

groups/src/main/java/io/atomix/group/MembershipGroup.java → groups/src/main/java/io/atomix/group/internal/MembershipGroup.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License
  */
-package io.atomix.group;
+package io.atomix.group.internal;
 
 import io.atomix.catalyst.transport.Address;
 import io.atomix.catalyst.transport.Server;
@@ -24,9 +24,11 @@
 import io.atomix.copycat.Command;
 import io.atomix.copycat.Query;
 import io.atomix.copycat.client.CopycatClient;
+import io.atomix.group.DistributedGroup;
+import io.atomix.group.LocalMember;
+import io.atomix.group.Member;
 import io.atomix.group.election.Election;
 import io.atomix.group.election.internal.GroupElection;
-import io.atomix.group.internal.*;
 import io.atomix.group.messaging.MessageClient;
 import io.atomix.group.messaging.internal.ConnectionManager;
 import io.atomix.group.messaging.internal.GroupMessage;

groups/src/main/java/io/atomix/group/util/DistributedGroupFactory.java

@@ -18,7 +18,7 @@
 import io.atomix.catalyst.serializer.SerializableTypeResolver;
 import io.atomix.copycat.client.CopycatClient;
 import io.atomix.group.DistributedGroup;
-import io.atomix.group.MembershipGroup;
+import io.atomix.group.internal.MembershipGroup;
 import io.atomix.group.internal.GroupCommands;
 import io.atomix.group.internal.GroupState;
 import io.atomix.resource.ResourceFactory;