配置手册

jcpp-app-bootstrap/src/main/resources/app-service.yml

@@ -63,7 +63,7 @@ queue:
   type: "${QUEUE_TYPE:memory}"
   partitions:
     hash_function_name: "${QUEUE_PARTITIONS_HASH_FUNCTION_NAME:murmur3_128}" # murmur3_32, murmur3_128 or sha256
-  in-memory:
+  memory:
     queue-capacity: "${QUEUE_IN_MEMORY_QUEUE_CAPACITY:100000}"
     stats:
       print-interval-ms: "${QUEUE_IN_MEMORY_STATS_PRINT_INTERVAL_MS:10000}"

jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/memory/DefaultInMemoryStorage.java

@@ -19,7 +19,7 @@ import java.util.concurrent.LinkedBlockingQueue;
 public final class DefaultInMemoryStorage implements InMemoryStorage {
     private final ConcurrentHashMap<String, BlockingQueue<QueueMsg>> storage = new ConcurrentHashMap<>();
 
-    @Value("${queue.in-memory.queue-capacity:100000}")
+    @Value("${queue.memory.queue-capacity:100000}")
     private int queueCapacity;
 
     @Override

jcpp-infrastructure-queue/src/main/java/sanbing/jcpp/infrastructure/queue/provider/InMemoryAppQueueFactory.java

@@ -40,7 +40,7 @@ public class InMemoryAppQueueFactory implements AppQueueFactory {
         return new InMemoryQueueProducer<>(storage, topic);
     }
 
-    @Scheduled(fixedRateString = "${queue.in-memory.stats.print-interval-ms:60000}")
+    @Scheduled(fixedRateString = "${queue.memory.stats.print-interval-ms:60000}")
     private void printInMemoryStats() {
         storage.printStats();
     }