From fd5764d30dfa8bcc066dc2359ea1e82773fc5ba7 Mon Sep 17 00:00:00 2001
From: Andrea Cavalli <andrea@cavallium.it>
Date: Fri, 20 Oct 2023 17:52:02 +0200
Subject: [PATCH] queue manager name

---
 pom.xml                                                    | 2 +-
 .../java/it/cavallium/filequeue/LMDBQueueToConsumer.java   | 7 ++++++-
 .../cavallium/filequeue/MemorySegmentQueueToConsumer.java  | 7 ++++++-
 src/main/java/it/cavallium/filequeue/QueueToConsumer.java  | 6 +++++-
 .../it/cavallium/filequeue/SimpleQueueMemorySegment.java   | 2 +-
 5 files changed, 19 insertions(+), 5 deletions(-)

diff --git a/pom.xml b/pom.xml
index 0a869a2..697f42b 100644
--- a/pom.xml
+++ b/pom.xml
@@ -4,7 +4,7 @@
     <groupId>it.cavallium</groupId>
     <artifactId>filequeue</artifactId>
     <name>file queue project</name>
-    <version>3.1.9</version>
+    <version>3.1.10</version>
     <packaging>jar</packaging>
     <description>Light weight, high performance, simple, reliable and persistent queue</description>
     <modelVersion>4.0.0</modelVersion>
diff --git a/src/main/java/it/cavallium/filequeue/LMDBQueueToConsumer.java b/src/main/java/it/cavallium/filequeue/LMDBQueueToConsumer.java
index e9d4c06..7aad744 100644
--- a/src/main/java/it/cavallium/filequeue/LMDBQueueToConsumer.java
+++ b/src/main/java/it/cavallium/filequeue/LMDBQueueToConsumer.java
@@ -17,7 +17,12 @@ public final class LMDBQueueToConsumer<T> implements IQueueToConsumer<T> {
 			QueueConsumer<T> consumer) {
 		this.env = LMDBEnvManager.ofPath(file);
 		this.queueLMDB = new SimpleQueueLMDB<>(env, dbName, serializer, deserializer);
-		this.queue = new QueueToConsumer<>(queueLMDB, consumer);
+		this.queue = new QueueToConsumer<>(queueLMDB, consumer) {
+			@Override
+			protected String getQueueManagerName() {
+				return super.getQueueManagerName() + "-" + dbName;
+			}
+		};
 	}
 
 	@Override
diff --git a/src/main/java/it/cavallium/filequeue/MemorySegmentQueueToConsumer.java b/src/main/java/it/cavallium/filequeue/MemorySegmentQueueToConsumer.java
index 9bdff63..2d3f1de 100644
--- a/src/main/java/it/cavallium/filequeue/MemorySegmentQueueToConsumer.java
+++ b/src/main/java/it/cavallium/filequeue/MemorySegmentQueueToConsumer.java
@@ -27,7 +27,12 @@ public final class MemorySegmentQueueToConsumer<T> implements IQueueToConsumer<T
 		} catch (IOException e) {
 			throw new UncheckedIOException(e);
 		}
-		this.queue = new QueueToConsumer<>(queueMemorySegment, consumer);
+		this.queue = new QueueToConsumer<>(queueMemorySegment, consumer) {
+			@Override
+			protected String getQueueManagerName() {
+				return super.getQueueManagerName() + "-" + dbName;
+			}
+		};
 	}
 
 	@Override
diff --git a/src/main/java/it/cavallium/filequeue/QueueToConsumer.java b/src/main/java/it/cavallium/filequeue/QueueToConsumer.java
index d6cb442..1d40472 100644
--- a/src/main/java/it/cavallium/filequeue/QueueToConsumer.java
+++ b/src/main/java/it/cavallium/filequeue/QueueToConsumer.java
@@ -24,10 +24,14 @@ class QueueToConsumer<T> implements IQueueToConsumer<T> {
 		this.afterAddQueued = new AtomicLong(queue.size());
 	}
 
+	protected String getQueueManagerName() {
+		return "queue-manager";
+	}
+
 	public synchronized void startQueue() {
 		if (manager == null) {
 			this.manager = new Manager();
-			manager.setName("queue-manager");
+			manager.setName(getQueueManagerName());
 			manager.start();
 		}
 	}
diff --git a/src/main/java/it/cavallium/filequeue/SimpleQueueMemorySegment.java b/src/main/java/it/cavallium/filequeue/SimpleQueueMemorySegment.java
index ba73452..40c036d 100644
--- a/src/main/java/it/cavallium/filequeue/SimpleQueueMemorySegment.java
+++ b/src/main/java/it/cavallium/filequeue/SimpleQueueMemorySegment.java
@@ -142,7 +142,7 @@ public class SimpleQueueMemorySegment<T> implements SimpleQueue<T>, Closeable {
 
 	@Override
 	public int size() {
-		return 0;
+		return this.queueSegments.stream().mapToInt(SimpleQueueMemorySegmentFixedSize::size).sum();
 	}
 
 	@Override