do not handle rabiit size

Author: Yang Guo

platform-core/src/main/java/com/flow/platform/core/queue/RabbitQueue.java

@@ -54,8 +54,6 @@ public class RabbitQueue extends PlatformQueue<PriorityMessage> implements Conte
 
     private SimpleMessageListenerContainer container;
 
-    private volatile AtomicInteger size = new AtomicInteger(0);
-
     public RabbitQueue(ThreadPoolTaskExecutor executor, String host, int maxSize, int maxPriority, String queueName) {
         super(executor, maxSize, queueName);
         this.host = host;
@@ -98,7 +96,6 @@ public void resume() {
     @Override
     public void enqueue(PriorityMessage item) {
         template.send("", name, item);
-        size.incrementAndGet();
     }
 
     @Override
@@ -118,7 +115,7 @@ public boolean isRunning() {
 
     @Override
     public int size() {
-        return size.get();
+        return 0;
     }
 
     private void initRabbitMQ() throws URISyntaxException {
@@ -157,7 +154,6 @@ private class RabbitMessageListener implements MessageListener {
 
         @Override
         public void onMessage(Message message) {
-            size.decrementAndGet();
             listener.onQueueItem(new PriorityMessage(message));
         }
     }

platform-core/src/test/java/com/flow/platform/core/test/PlatformQueueTest.java

@@ -140,16 +140,6 @@ public void should_enqueue_for_rabbit_queue() throws Throwable {
         Assert.assertEquals(0, rabbitQueue.size());
         Assert.assertNotNull(result.getInstance());
         Assert.assertEquals("hello", new String(result.getInstance().getBody(), "UTF-8"));
-
-        // when: pause and enqueue again
-        rabbitQueue.pause();
-        rabbitQueue.enqueue(PriorityMessage.create("pause".getBytes(), 1));
-        Assert.assertEquals(1, rabbitQueue.size());
-
-        // then: resume
-        rabbitQueue.resume();
-        Thread.sleep(1000);
-        Assert.assertEquals(0, rabbitQueue.size());
     }
 
     @After

platform-queue/src/main/java/com/flow/platform/queue/PriorityQueueItem.java

@@ -16,13 +16,14 @@
 
 package com.flow.platform.queue;
 
+import java.io.Serializable;
 import java.util.Comparator;
 import java.util.Objects;
 
 /**
  * @author yang
  */
-public interface PriorityQueueItem extends Comparable<PriorityQueueItem> {
+public interface PriorityQueueItem extends Serializable, Comparable<PriorityQueueItem> {
 
     ItemComparator COMPARATOR = new ItemComparator();