Я использовал кэш Hazelcast для распределенной очереди и ItemListener для извлечения событий из очереди.Но после распечатки этого сообщения выборка из очереди прекращается.
2018-06-11 01: 26: 26,231 INFO [hz._hzInstance_1_dev.HealthMonitor] HealthMonitor: [xx.xx.xx.xx]: 6701 [dev] [3.7.2] процессоров = 4, phys.memory.total = 7,7 ГБ, Physical.memory.free = 643,4 М, swap.space.total = 2,0 Г, swap.space.free =1,2G, heap.memory.used = 2,1G, heap.memory.free = 673,2M, heap.memory.total = 2,7G, heap.memory.max = 2,7 Г, heap.memory.used / total = 75,82%heap.memory.used / max = 75,82%, minor.gc.count = 8020, minor.gc.time = 143849мс, major.gc.count = 11, major.gc.time = 6901мс, load.process = 0,00%,load.system = 0,00%, load.systemAverage = 0,00%, thread.count = 275, thread.peakCount = 281, cluster.timeDiff = 0, event.q.size = 0, executor.q.async.size = 0,executor.q.client.size = 0, executor.q.query.size = 0, executor.q.scheduled.size = 0, executor.q.io.size = 0, executor.q.system.size = 0,executor.q.operations.size = 0, executor.q.priorityOperation.size = 0, operations.completed.count = 8002555, executor.q.mapLoad.size = 0, executor.q.mapLoadAllKeys.size = 0, executor.q.cluster.size = 0, executor.q.response.size = 0, operations.running.count = 0, operations.pending.invocations.percentage = 0,00%, operations.pending.invocations.count = 1, proxy.count = 0, clientEndpoint.count = 1, connection.active.count = 2, client.connection.count = 1, connection.count = 1
Слушатель останавливаетсяполучение событий из очереди при добавлении событий все еще происходит.Как я могу понять, почему это происходит и почему выборка из очереди не работает?