revert extra log on poll InMemoryTbQueueConsumer

4 years ago · b2fa263027
1 changed files with 0 additions and 3 deletions
--- a/common/queue/src/main/java/org/thingsboard/server/queue/memory/InMemoryTbQueueConsumer.java
+++ b/common/queue/src/main/java/org/thingsboard/server/queue/memory/InMemoryTbQueueConsumer.java
@ -64,9 +64,6 @@ public class InMemoryTbQueueConsumer<T extends TbQueueMsg> implements TbQueueCon

    @Override
    public List<T> poll(long durationInMillis) {
-        if (topic.contains("main")){
-            log.warn("poll {} {}", topic, durationInMillis);
-        }
        if (subscribed) {
            @SuppressWarnings("unchecked")
            List<T> messages = partitions