diff --git a/pom.xml b/pom.xml
index 0a869a2..697f42b 100644
--- a/pom.xml
+++ b/pom.xml
@@ -4,7 +4,7 @@
it.cavallium
filequeue
file queue project
- 3.1.9
+ 3.1.10
jar
Light weight, high performance, simple, reliable and persistent queue
4.0.0
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 implements IQueueToConsumer {
QueueConsumer 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 implements IQueueToConsumer(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 implements IQueueToConsumer {
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 implements SimpleQueue, Closeable {
@Override
public int size() {
- return 0;
+ return this.queueSegments.stream().mapToInt(SimpleQueueMemorySegmentFixedSize::size).sum();
}
@Override