client.log

Role: producer
18:30:04.781 [main] DEBUG i.n.u.i.l.InternalLoggerFactory - Using SLF4J as the default logging framework
18:30:04.828 [main] DEBUG i.n.c.MultithreadEventLoopGroup - -Dio.netty.eventLoopThreads: 4
18:30:04.864 [main] DEBUG i.n.util.internal.PlatformDependent0 - java.nio.Buffer.address: available
18:30:04.866 [main] DEBUG i.n.util.internal.PlatformDependent0 - sun.misc.Unsafe.theUnsafe: available
18:30:04.867 [main] DEBUG i.n.util.internal.PlatformDependent0 - sun.misc.Unsafe.copyMemory: available
18:30:04.868 [main] DEBUG i.n.util.internal.PlatformDependent0 - java.nio.Bits.unaligned: true
18:30:05.220 [main] DEBUG i.n.util.internal.PlatformDependent - UID: 1000
18:30:05.222 [main] DEBUG i.n.util.internal.PlatformDependent - Java version: 8
18:30:05.224 [main] DEBUG i.n.util.internal.PlatformDependent - -Dio.netty.noUnsafe: false
18:30:05.224 [main] DEBUG i.n.util.internal.PlatformDependent - sun.misc.Unsafe: available
18:30:05.225 [main] DEBUG i.n.util.internal.PlatformDependent - -Dio.netty.noJavassist: false
18:30:05.226 [main] DEBUG i.n.util.internal.PlatformDependent - Javassist: unavailable
18:30:05.226 [main] DEBUG i.n.util.internal.PlatformDependent - You don't have Javassist in your class path or you don't have enough permission to load dynamically generated classes.  Please check the configuration for better performance.
18:30:05.228 [main] DEBUG i.n.util.internal.PlatformDependent - -Dio.netty.tmpdir: /tmp (java.io.tmpdir)
18:30:05.228 [main] DEBUG i.n.util.internal.PlatformDependent - -Dio.netty.bitMode: 64 (sun.arch.data.model)
18:30:05.228 [main] DEBUG i.n.util.internal.PlatformDependent - -Dio.netty.noPreferDirect: false
18:30:05.285 [main] DEBUG io.netty.channel.nio.NioEventLoop - -Dio.netty.noKeySetOptimization: false
18:30:05.286 [main] DEBUG io.netty.channel.nio.NioEventLoop - -Dio.netty.selectorAutoRebuildThreshold: 512
18:30:05.728 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.numHeapArenas: 2
18:30:05.730 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.numDirectArenas: 2
18:30:05.731 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.pageSize: 8192
18:30:05.732 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.maxOrder: 11
18:30:05.732 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.chunkSize: 16777216
18:30:05.733 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.tinyCacheSize: 512
18:30:05.733 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.smallCacheSize: 256
18:30:05.734 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.normalCacheSize: 64
18:30:05.734 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.maxCachedBufferCapacity: 32768
18:30:05.735 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.cacheTrimInterval: 8192
18:30:05.834 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - Registering session: attempt 1
18:30:05.836 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - Sending RegisterRequest[client=27205da8-4e57-4e34-87be-fab6546d75b7]
18:30:05.837 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5000
18:30:05.873 [copycat-client-2] DEBUG i.n.util.internal.ThreadLocalRandom - -Dio.netty.initialSeedUniquifier: 0x5c9ac9e1583aee68
18:30:05.908 [copycat-client-2] DEBUG i.n.channel.ChannelOutboundBuffer - -Dio.netty.threadLocalDirectBufferSize: 65536
18:30:05.910 [copycat-client-2] DEBUG io.netty.util.Recycler - -Dio.netty.recycler.maxCapacity.default: 262144
18:30:05.928 [copycat-client-2] DEBUG io.netty.buffer.ByteBufUtil - -Dio.netty.allocator.type: unpooled
18:30:06.009 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5000
18:30:06.034 [copycat-client-2] DEBUG io.netty.util.ResourceLeakDetector - -Dio.netty.leakDetectionLevel: simple
18:30:06.441 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - Received RegisterResponse[status=OK, session=104, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:06.454 [copycat-client-2] DEBUG i.a.c.client.DefaultCopycatClient - State changed: CONNECTED
Client started!
Role: producer
18:30:06.496 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Sending KeepAliveRequest[session=104, commandSequence=0, eventIndex=104]
18:30:06.583 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5001
18:30:06.632 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5001
18:30:06.635 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Sending CommandRequest[session=104, sequence=1, command=io.atomix.manager.GetResource@3e98af45]
18:30:06.794 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received CommandResponse[status=OK, index=106, result=106]
18:30:06.873 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
Starting producer
18:30:06.880 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Sending CommandRequest[session=104, sequence=2, command=InstanceCommand[resource=106, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Submit@6967bba3, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:06.884 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Sending CommandRequest[session=104, sequence=3, command=InstanceCommand[resource=106, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Submit@24dc3103, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:06.886 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Sending CommandRequest[session=104, sequence=4, command=InstanceCommand[resource=106, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Submit@9db281, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:06.888 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Sending CommandRequest[session=104, sequence=5, command=InstanceCommand[resource=106, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Submit@6f9d92, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:06.891 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Sending CommandRequest[session=104, sequence=6, command=InstanceCommand[resource=106, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Submit@4911efba, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:06.900 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Sending CommandRequest[session=104, sequence=7, command=InstanceCommand[resource=106, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Submit@c008bb2, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:06.921 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Sending CommandRequest[session=104, sequence=8, command=InstanceCommand[resource=106, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Submit@61642909, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:06.942 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Sending CommandRequest[session=104, sequence=9, command=InstanceCommand[resource=106, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Submit@1d1bbbba, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:06.962 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Sending CommandRequest[session=104, sequence=10, command=InstanceCommand[resource=106, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Submit@5b31eb9c, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:06.996 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Sending CommandRequest[session=104, sequence=11, command=InstanceCommand[resource=106, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Submit@53e4a653, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:07.045 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received CommandResponse[status=OK, index=108, result=null]
18:30:07.122 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received CommandResponse[status=OK, index=109, result=null]
18:30:07.130 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received CommandResponse[status=OK, index=110, result=null]
18:30:07.138 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received CommandResponse[status=OK, index=111, result=null]
18:30:07.148 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received CommandResponse[status=OK, index=112, result=null]
18:30:07.158 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received CommandResponse[status=OK, index=113, result=null]
18:30:07.164 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received CommandResponse[status=OK, index=114, result=null]
18:30:07.194 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received CommandResponse[status=OK, index=116, result=null]
18:30:07.213 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received CommandResponse[status=OK, index=117, result=null]
18:30:07.217 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received CommandResponse[status=OK, index=118, result=null]
18:30:09.376 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Sending KeepAliveRequest[session=104, commandSequence=11, eventIndex=104]
18:30:09.457 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:09.597 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received PublishRequest[session=104, eventIndex=115, previousIndex=104, events=[Event[event=ack, message=InstanceEvent[resource=106, message=1]]]]
18:30:11.957 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Sending KeepAliveRequest[session=104, commandSequence=11, eventIndex=115]
18:30:11.975 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:14.475 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Sending KeepAliveRequest[session=104, commandSequence=11, eventIndex=115]
18:30:14.513 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:17.014 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Sending KeepAliveRequest[session=104, commandSequence=11, eventIndex=115]
18:30:17.027 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:17.050 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received PublishRequest[session=104, eventIndex=140, previousIndex=115, events=[Event[event=ack, message=InstanceEvent[resource=106, message=2]]]]
18:30:19.527 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Sending KeepAliveRequest[session=104, commandSequence=11, eventIndex=140]
18:30:19.556 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:22.057 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Sending KeepAliveRequest[session=104, commandSequence=11, eventIndex=140]
18:30:22.079 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:22.208 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received PublishRequest[session=104, eventIndex=158, previousIndex=140, events=[Event[event=ack, message=InstanceEvent[resource=106, message=3]]]]
18:30:24.580 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Sending KeepAliveRequest[session=104, commandSequence=11, eventIndex=158]
18:30:24.605 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:27.105 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Sending KeepAliveRequest[session=104, commandSequence=11, eventIndex=158]
18:30:27.129 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:29.630 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Sending KeepAliveRequest[session=104, commandSequence=11, eventIndex=158]
18:30:29.650 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:29.807 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received PublishRequest[session=104, eventIndex=180, previousIndex=158, events=[Event[event=ack, message=InstanceEvent[resource=106, message=4]]]]
18:30:32.151 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Sending KeepAliveRequest[session=104, commandSequence=11, eventIndex=180]
18:30:32.174 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:34.676 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Sending KeepAliveRequest[session=104, commandSequence=11, eventIndex=180]
18:30:34.691 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:34.809 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received PublishRequest[session=104, eventIndex=192, previousIndex=180, events=[Event[event=ack, message=InstanceEvent[resource=106, message=5]]]]
18:30:37.192 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Sending KeepAliveRequest[session=104, commandSequence=11, eventIndex=192]
18:30:37.209 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:39.710 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Sending KeepAliveRequest[session=104, commandSequence=11, eventIndex=192]
18:30:39.731 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:42.232 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Sending KeepAliveRequest[session=104, commandSequence=11, eventIndex=192]
18:30:42.263 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:42.301 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received PublishRequest[session=104, eventIndex=217, previousIndex=192, events=[Event[event=ack, message=InstanceEvent[resource=106, message=6]]]]
18:30:44.763 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Sending KeepAliveRequest[session=104, commandSequence=11, eventIndex=217]
18:30:44.789 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:47.290 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Sending KeepAliveRequest[session=104, commandSequence=11, eventIndex=217]
18:30:47.310 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:47.554 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received PublishRequest[session=104, eventIndex=231, previousIndex=217, events=[Event[event=ack, message=InstanceEvent[resource=106, message=7]]]]
18:30:49.811 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Sending KeepAliveRequest[session=104, commandSequence=11, eventIndex=231]
18:30:49.838 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:52.338 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Sending KeepAliveRequest[session=104, commandSequence=11, eventIndex=231]
18:30:52.353 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 104 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]

client2.log

Role: consumer
18:29:37.752 [main] DEBUG i.n.u.i.l.InternalLoggerFactory - Using SLF4J as the default logging framework
18:29:37.756 [main] DEBUG i.n.c.MultithreadEventLoopGroup - -Dio.netty.eventLoopThreads: 4
18:29:37.766 [main] DEBUG i.n.util.internal.PlatformDependent0 - java.nio.Buffer.address: available
18:29:37.767 [main] DEBUG i.n.util.internal.PlatformDependent0 - sun.misc.Unsafe.theUnsafe: available
18:29:37.769 [main] DEBUG i.n.util.internal.PlatformDependent0 - sun.misc.Unsafe.copyMemory: available
18:29:37.770 [main] DEBUG i.n.util.internal.PlatformDependent0 - java.nio.Bits.unaligned: true
18:29:37.859 [main] DEBUG i.n.util.internal.PlatformDependent - UID: 1000
18:29:37.860 [main] DEBUG i.n.util.internal.PlatformDependent - Java version: 8
18:29:37.860 [main] DEBUG i.n.util.internal.PlatformDependent - -Dio.netty.noUnsafe: false
18:29:37.860 [main] DEBUG i.n.util.internal.PlatformDependent - sun.misc.Unsafe: available
18:29:37.864 [main] DEBUG i.n.util.internal.PlatformDependent - -Dio.netty.noJavassist: false
18:29:37.866 [main] DEBUG i.n.util.internal.PlatformDependent - Javassist: unavailable
18:29:37.866 [main] DEBUG i.n.util.internal.PlatformDependent - You don't have Javassist in your class path or you don't have enough permission to load dynamically generated classes.  Please check the configuration for better performance.
18:29:37.866 [main] DEBUG i.n.util.internal.PlatformDependent - -Dio.netty.tmpdir: /tmp (java.io.tmpdir)
18:29:37.867 [main] DEBUG i.n.util.internal.PlatformDependent - -Dio.netty.bitMode: 64 (sun.arch.data.model)
18:29:37.867 [main] DEBUG i.n.util.internal.PlatformDependent - -Dio.netty.noPreferDirect: false
18:29:37.896 [main] DEBUG io.netty.channel.nio.NioEventLoop - -Dio.netty.noKeySetOptimization: false
18:29:37.898 [main] DEBUG io.netty.channel.nio.NioEventLoop - -Dio.netty.selectorAutoRebuildThreshold: 512
18:29:38.020 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.numHeapArenas: 2
18:29:38.021 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.numDirectArenas: 2
18:29:38.021 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.pageSize: 8192
18:29:38.021 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.maxOrder: 11
18:29:38.022 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.chunkSize: 16777216
18:29:38.022 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.tinyCacheSize: 512
18:29:38.023 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.smallCacheSize: 256
18:29:38.023 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.normalCacheSize: 64
18:29:38.023 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.maxCachedBufferCapacity: 32768
18:29:38.024 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.cacheTrimInterval: 8192
18:29:38.063 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - Registering session: attempt 1
18:29:38.064 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - Sending RegisterRequest[client=be247b0a-20f4-4f7d-b05e-02bb2b609903]
18:29:38.064 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5000
18:29:38.082 [copycat-client-2] DEBUG i.n.util.internal.ThreadLocalRandom - -Dio.netty.initialSeedUniquifier: 0xa9d52a644a520023
18:29:38.097 [copycat-client-2] DEBUG i.n.channel.ChannelOutboundBuffer - -Dio.netty.threadLocalDirectBufferSize: 65536
18:29:38.098 [copycat-client-2] DEBUG io.netty.util.Recycler - -Dio.netty.recycler.maxCapacity.default: 262144
18:29:38.109 [copycat-client-2] DEBUG io.netty.buffer.ByteBufUtil - -Dio.netty.allocator.type: unpooled
18:29:38.146 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5000
18:29:38.164 [copycat-client-2] DEBUG io.netty.util.ResourceLeakDetector - -Dio.netty.leakDetectionLevel: simple
18:29:38.300 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - Received RegisterResponse[status=OK, session=26, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:29:38.304 [copycat-client-2] DEBUG i.a.c.client.DefaultCopycatClient - State changed: CONNECTED
Client started!
Role: consumer
18:29:38.332 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=0, eventIndex=26]
18:29:38.362 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5000
18:29:38.371 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=1, command=io.atomix.manager.GetResource@7a859281]
18:29:38.372 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5000
18:29:38.396 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5002
18:29:38.399 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5002
18:29:38.435 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:29:38.445 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received CommandResponse[status=OK, index=31, result=31]
Starting consumer
18:29:38.458 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=2, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Subscribe@7dfbbde0, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:29:38.484 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received CommandResponse[status=OK, index=32, result=null]
18:29:40.937 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=2, eventIndex=26]
18:29:40.957 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:29:43.458 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=2, eventIndex=26]
18:29:43.479 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:29:43.615 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received PublishRequest[session=26, eventIndex=42, previousIndex=26, events=[Event[event=process, message=InstanceEvent[resource=31, message=Task ID: 0]]]]
Task: Task ID: 0
18:29:43.621 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=3, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@2ad5b17, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:29:44.154 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5001
18:29:44.159 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5001
18:29:44.819 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:29:45.820 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=3, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@2ad5b17, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:29:45.820 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:29:45.981 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=2, eventIndex=42]
18:29:45.981 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:29:45.981 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=2, eventIndex=42]
18:29:45.981 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5002
18:29:45.984 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5002
18:29:46.035 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:29:46.821 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=3, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@2ad5b17, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:29:46.822 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5002
18:29:46.823 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5002
18:29:47.420 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5000
18:29:47.423 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5000
18:29:48.103 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received CommandResponse[status=OK, index=71, result=Task ID: 1]
Task: Task ID: 1
18:29:48.104 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=4, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@45b02c6e, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:29:48.120 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received CommandResponse[status=OK, index=73, result=Task ID: 2]
Task: Task ID: 2
18:29:48.121 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=5, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@1a64d6b, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:29:48.144 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received CommandResponse[status=OK, index=74, result=Task ID: 3]
Task: Task ID: 3
18:29:48.145 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=6, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@7c0e84a4, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:29:48.170 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received CommandResponse[status=OK, index=75, result=Task ID: 4]
Task: Task ID: 4
18:29:48.171 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=7, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@60dc0e0b, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:29:48.203 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received CommandResponse[status=OK, index=76, result=Task ID: 5]
Task: Task ID: 5
18:29:48.204 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=8, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@244b9d22, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:29:48.225 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received CommandResponse[status=OK, index=77, result=Task ID: 6]
Task: Task ID: 6
18:29:48.226 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=9, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@17b551d5, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:29:48.248 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received CommandResponse[status=OK, index=78, result=Task ID: 7]
Task: Task ID: 7
18:29:48.249 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=10, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@1f96cc23, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:29:48.271 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received CommandResponse[status=OK, index=79, result=Task ID: 8]
Task: Task ID: 8
18:29:48.272 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=11, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@1f3a258c, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:29:48.291 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received CommandResponse[status=OK, index=80, result=Task ID: 9]
Task: Task ID: 9
18:29:48.292 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=12, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@676019c4, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:29:48.317 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received CommandResponse[status=OK, index=81, result=null]
18:29:48.538 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=12, eventIndex=42]
18:29:48.556 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:29:51.056 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=12, eventIndex=42]
18:29:51.072 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:29:53.573 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=12, eventIndex=42]
18:29:53.596 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:29:56.096 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=12, eventIndex=42]
18:29:56.108 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:29:58.608 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=12, eventIndex=42]
18:29:58.619 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:01.119 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=12, eventIndex=42]
18:30:01.132 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:03.632 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=12, eventIndex=42]
18:30:03.660 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:06.160 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=12, eventIndex=42]
18:30:06.187 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:06.962 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received PublishRequest[session=26, eventIndex=108, previousIndex=42, events=[Event[event=process, message=InstanceEvent[resource=31, message=Task ID: 0]]]]
Task: Task ID: 0
18:30:06.963 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=13, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@5a66d704, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:07.674 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5001
18:30:07.677 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5001
18:30:08.322 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:30:08.688 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=12, eventIndex=108]
18:30:08.689 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:30:08.689 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=12, eventIndex=108]
18:30:08.689 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5000
18:30:08.692 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5000
18:30:08.829 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:09.329 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=13, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@5a66d704, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:09.340 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5001
18:30:09.344 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5001
18:30:10.066 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5000
18:30:10.069 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5000
18:30:10.829 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5002
18:30:10.831 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5002
18:30:11.331 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=12, eventIndex=108]
18:30:11.384 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:11.423 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:30:12.426 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=13, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@5a66d704, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:12.427 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:30:13.885 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=12, eventIndex=108]
18:30:13.885 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:30:13.887 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=12, eventIndex=108]
18:30:13.889 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5002
18:30:13.892 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5002
18:30:13.930 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:14.427 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=13, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@5a66d704, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:14.430 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5000
18:30:14.434 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5000
18:30:14.480 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received CommandResponse[status=OK, index=138, result=Task ID: 1]
Task: Task ID: 1
18:30:14.482 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=14, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@73b8ffbf, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:15.184 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5001
18:30:15.188 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5001
18:30:15.802 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5002
18:30:15.812 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5002
18:30:16.420 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:30:16.431 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=13, eventIndex=108]
18:30:16.432 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:30:16.432 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=13, eventIndex=108]
18:30:16.432 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5000
18:30:16.437 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5000
18:30:16.474 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:17.421 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=14, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@73b8ffbf, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:17.424 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5000
18:30:17.427 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5000
18:30:18.179 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5002
18:30:18.188 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5002
18:30:18.931 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5001
18:30:18.933 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5001
18:30:18.975 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=13, eventIndex=108]
18:30:18.997 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:19.547 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received CommandResponse[status=OK, index=155, result=Task ID: 2]
Task: Task ID: 2
18:30:19.550 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=15, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@5a293240, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:20.184 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:30:21.185 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=15, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@5a293240, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:21.186 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:30:21.497 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=14, eventIndex=108]
18:30:21.499 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:30:21.501 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=14, eventIndex=108]
18:30:21.502 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5000
18:30:21.509 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5000
18:30:21.538 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:22.187 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=15, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@5a293240, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:22.190 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5001
18:30:22.193 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5001
18:30:22.816 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5000
18:30:22.819 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5000
18:30:23.571 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5002
18:30:23.573 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5002
18:30:24.040 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=14, eventIndex=108]
18:30:24.058 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:24.173 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:30:26.174 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=15, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@5a293240, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:26.176 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:30:26.558 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=14, eventIndex=108]
18:30:26.559 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:30:26.560 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=14, eventIndex=108]
18:30:26.560 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5001
18:30:26.562 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5001
18:30:26.598 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:29.099 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=14, eventIndex=108]
18:30:29.100 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5000
18:30:29.102 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5000
18:30:29.126 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:29.177 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=15, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@5a293240, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:29.199 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received CommandResponse[status=OK, index=179, result=Task ID: 3]
Task: Task ID: 3
18:30:29.200 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=16, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@369b10f6, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:29.853 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5002
18:30:29.854 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5002
18:30:30.422 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5001
18:30:30.423 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5001
18:30:31.059 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:30:31.626 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=15, eventIndex=108]
18:30:31.627 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:30:31.627 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=15, eventIndex=108]
18:30:31.627 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5000
18:30:31.634 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5000
18:30:31.660 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:32.060 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=16, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@369b10f6, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:32.063 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5000
18:30:32.071 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5000
18:30:32.170 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received CommandResponse[status=OK, index=190, result=Task ID: 4]
Task: Task ID: 4
18:30:32.171 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=17, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@26a549d, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:32.822 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5002
18:30:32.826 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5002
18:30:33.421 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5001
18:30:33.425 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5001
18:30:34.060 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:30:34.161 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=16, eventIndex=108]
18:30:34.161 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:30:34.162 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=16, eventIndex=108]
18:30:34.163 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5001
18:30:34.164 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5001
18:30:34.203 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:35.060 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=17, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@26a549d, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:35.061 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5000
18:30:35.063 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5000
18:30:35.813 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5001
18:30:35.817 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5001
18:30:36.552 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5002
18:30:36.554 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5002
18:30:36.703 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=16, eventIndex=108]
18:30:36.721 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:37.170 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:30:38.170 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=17, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@26a549d, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:38.171 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:30:39.222 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=16, eventIndex=108]
18:30:39.223 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:30:39.223 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=16, eventIndex=108]
18:30:39.224 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5000
18:30:39.231 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5000
18:30:39.264 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:40.171 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=17, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@26a549d, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:40.173 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5002
18:30:40.177 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5002
18:30:40.213 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received CommandResponse[status=OK, index=216, result=Task ID: 5]
Task: Task ID: 5
18:30:40.215 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=18, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@3aa21e7b, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:40.919 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5001
18:30:40.924 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5001
18:30:41.559 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5000
18:30:41.562 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5000
18:30:41.765 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=17, eventIndex=108]
18:30:41.773 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:42.315 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:30:43.316 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=18, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@3aa21e7b, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:43.316 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:30:44.274 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=17, eventIndex=108]
18:30:44.276 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:30:44.276 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=17, eventIndex=108]
18:30:44.276 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5001
18:30:44.277 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5001
18:30:44.317 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=18, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@3aa21e7b, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:44.318 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5000
18:30:44.320 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5000
18:30:44.362 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:44.777 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received CommandResponse[status=OK, index=229, result=Task ID: 6]
Task: Task ID: 6
18:30:44.779 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=19, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@290a805d, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:45.323 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5002
18:30:45.332 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5002
18:30:45.923 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5001
18:30:45.927 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5001
18:30:46.562 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:30:46.863 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=18, eventIndex=108]
18:30:46.868 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:30:46.869 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=18, eventIndex=108]
18:30:46.870 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5002
18:30:46.875 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5002
18:30:46.893 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:47.563 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=19, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@290a805d, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:47.567 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5000
18:30:47.569 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5000
18:30:48.320 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5001
18:30:48.323 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5001
18:30:49.050 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5002
18:30:49.053 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5002
18:30:49.394 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=18, eventIndex=108]
18:30:49.414 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:49.673 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:30:50.674 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=19, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@290a805d, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:50.675 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:30:51.915 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=18, eventIndex=108]
18:30:51.915 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:30:51.916 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=18, eventIndex=108]
18:30:51.916 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5000
18:30:51.917 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5000
18:30:51.953 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:52.676 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=19, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@290a805d, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:52.678 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5000
18:30:52.682 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5000
18:30:52.725 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received CommandResponse[status=OK, index=255, result=Task ID: 7]
Task: Task ID: 7
18:30:52.729 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=20, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@47f8292a, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:53.431 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5002
18:30:53.434 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5002
18:30:54.175 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5001
18:30:54.180 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5001
18:30:54.454 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=19, eventIndex=108]
18:30:54.478 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:54.801 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:30:55.802 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=20, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@47f8292a, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:55.804 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:30:56.805 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=20, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@47f8292a, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:56.806 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:30:56.979 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=19, eventIndex=108]
18:30:56.980 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
18:30:56.980 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=19, eventIndex=108]
18:30:56.981 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5000
18:30:56.982 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5000
18:30:57.003 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:58.807 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=20, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@47f8292a, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:58.810 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5001
18:30:58.812 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5001
18:30:58.849 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received CommandResponse[status=OK, index=268, result=Task ID: 8]
Task: Task ID: 8
18:30:58.850 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending CommandRequest[session=26, sequence=21, command=InstanceCommand[resource=31, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@17e653f4, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
18:30:59.504 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=20, eventIndex=108]
18:30:59.517 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:30:59.551 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5002
18:30:59.553 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5002
18:30:59.601 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received CommandResponse[status=OK, index=272, result=null]
18:31:02.019 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=21, eventIndex=108]
18:31:02.040 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:31:04.541 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=21, eventIndex=108]
18:31:04.556 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:31:07.056 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=21, eventIndex=108]
18:31:07.065 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:31:09.573 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=21, eventIndex=108]
18:31:09.594 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]
18:31:12.097 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Sending KeepAliveRequest[session=26, commandSequence=21, eventIndex=108]
18:31:12.109 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 26 - Received KeepAliveResponse[status=OK, leader=localhost/127.0.0.1:5000, members=[localhost/127.0.0.1:5001, localhost/127.0.0.1:5002, localhost/127.0.0.1:5000]]