client1.log

Role: producer
20:39:15.381 [main] DEBUG i.n.u.i.l.InternalLoggerFactory - Using SLF4J as the default logging framework
20:39:15.384 [main] DEBUG i.n.c.MultithreadEventLoopGroup - -Dio.netty.eventLoopThreads: 4
20:39:15.392 [main] DEBUG i.n.util.internal.PlatformDependent0 - java.nio.Buffer.address: available
20:39:15.392 [main] DEBUG i.n.util.internal.PlatformDependent0 - sun.misc.Unsafe.theUnsafe: available
20:39:15.393 [main] DEBUG i.n.util.internal.PlatformDependent0 - sun.misc.Unsafe.copyMemory: available
20:39:15.393 [main] DEBUG i.n.util.internal.PlatformDependent0 - java.nio.Bits.unaligned: true
20:39:15.462 [main] DEBUG i.n.util.internal.PlatformDependent - UID: 1000
20:39:15.463 [main] DEBUG i.n.util.internal.PlatformDependent - Java version: 8
20:39:15.463 [main] DEBUG i.n.util.internal.PlatformDependent - -Dio.netty.noUnsafe: false
20:39:15.463 [main] DEBUG i.n.util.internal.PlatformDependent - sun.misc.Unsafe: available
20:39:15.464 [main] DEBUG i.n.util.internal.PlatformDependent - -Dio.netty.noJavassist: false
20:39:15.465 [main] DEBUG i.n.util.internal.PlatformDependent - Javassist: unavailable
20:39:15.466 [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.
20:39:15.467 [main] DEBUG i.n.util.internal.PlatformDependent - -Dio.netty.tmpdir: /tmp (java.io.tmpdir)
20:39:15.467 [main] DEBUG i.n.util.internal.PlatformDependent - -Dio.netty.bitMode: 64 (sun.arch.data.model)
20:39:15.468 [main] DEBUG i.n.util.internal.PlatformDependent - -Dio.netty.noPreferDirect: false
20:39:15.482 [main] DEBUG io.netty.channel.nio.NioEventLoop - -Dio.netty.noKeySetOptimization: false
20:39:15.483 [main] DEBUG io.netty.channel.nio.NioEventLoop - -Dio.netty.selectorAutoRebuildThreshold: 512
20:39:15.622 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.numHeapArenas: 2
20:39:15.622 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.numDirectArenas: 2
20:39:15.622 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.pageSize: 8192
20:39:15.622 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.maxOrder: 11
20:39:15.622 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.chunkSize: 16777216
20:39:15.622 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.tinyCacheSize: 512
20:39:15.622 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.smallCacheSize: 256
20:39:15.622 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.normalCacheSize: 64
20:39:15.622 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.maxCachedBufferCapacity: 32768
20:39:15.622 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.cacheTrimInterval: 8192
20:39:15.655 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - Registering session: attempt 1
20:39:15.656 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - Sending RegisterRequest[client=911407ad-c9bc-490c-b475-4cf95dba7605]
20:39:15.657 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5000
20:39:15.682 [copycat-client-2] DEBUG i.n.util.internal.ThreadLocalRandom - -Dio.netty.initialSeedUniquifier: 0xb9ecfd7bca37d18a
20:39:15.693 [copycat-client-2] DEBUG i.n.channel.ChannelOutboundBuffer - -Dio.netty.threadLocalDirectBufferSize: 65536
20:39:15.694 [copycat-client-2] DEBUG io.netty.util.Recycler - -Dio.netty.recycler.maxCapacity.default: 262144
20:39:15.704 [copycat-client-2] DEBUG io.netty.buffer.ByteBufUtil - -Dio.netty.allocator.type: unpooled
20:39:15.737 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5000
20:39:15.748 [copycat-client-2] DEBUG io.netty.util.ResourceLeakDetector - -Dio.netty.leakDetectionLevel: simple
20:39:15.812 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - Received RegisterResponse[status=OK, session=69, 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]]
20:39:15.816 [copycat-client-2] DEBUG i.a.c.client.DefaultCopycatClient - State changed: CONNECTED
20:39:15.818 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Sending KeepAliveRequest[session=69, commandSequence=0, eventIndex=69]
Client started!
Role: producer
20:39:15.857 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Sending CommandRequest[session=69, sequence=1, command=io.atomix.manager.GetResource@3e98af45]
20:39:15.858 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5000
20:39:15.859 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5002
20:39:15.859 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5002
20:39:15.862 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5000
20:39:15.907 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Received CommandResponse[status=OK, index=71, result=71]
Starting producer
20:39:15.929 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Sending CommandRequest[session=69, sequence=2, command=InstanceCommand[resource=71, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Submit@c8abe1b, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
20:39:15.932 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Sending CommandRequest[session=69, sequence=3, command=InstanceCommand[resource=71, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Submit@3132aaeb, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
20:39:15.932 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Sending CommandRequest[session=69, sequence=4, command=InstanceCommand[resource=71, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Submit@65dca5cd, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
20:39:15.934 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Sending CommandRequest[session=69, sequence=5, command=InstanceCommand[resource=71, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Submit@2f9cd570, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
20:39:15.935 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Sending CommandRequest[session=69, sequence=6, command=InstanceCommand[resource=71, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Submit@24dc3103, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
20:39:15.936 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Sending CommandRequest[session=69, sequence=7, command=InstanceCommand[resource=71, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Submit@9db281, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
20:39:15.938 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Sending CommandRequest[session=69, sequence=8, command=InstanceCommand[resource=71, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Submit@6f9d92, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
20:39:15.940 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Sending CommandRequest[session=69, sequence=9, command=InstanceCommand[resource=71, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Submit@4911efba, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
20:39:15.943 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Sending CommandRequest[session=69, sequence=10, command=InstanceCommand[resource=71, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Submit@c008bb2, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
20:39:15.949 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Sending CommandRequest[session=69, sequence=11, command=InstanceCommand[resource=71, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Submit@61642909, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
20:39:16.002 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Received CommandResponse[status=OK, index=74, result=null]
20:39:16.005 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Received CommandResponse[status=OK, index=75, result=null]
20:39:16.005 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Received CommandResponse[status=OK, index=76, result=null]
20:39:16.005 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Received CommandResponse[status=OK, index=77, result=null]
20:39:16.008 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Received CommandResponse[status=OK, index=78, result=null]
20:39:16.009 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Received CommandResponse[status=OK, index=79, result=null]
20:39:16.011 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Received CommandResponse[status=OK, index=80, result=null]
20:39:16.012 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Received CommandResponse[status=OK, index=81, result=null]
20:39:16.013 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Received CommandResponse[status=OK, index=82, result=null]
20:39:16.493 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Received PublishRequest[session=69, eventIndex=85, previousIndex=69, events=[Event[event=ack, message=InstanceEvent[resource=71, message=1]]]]
20:39:16.535 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Received PublishRequest[session=69, eventIndex=86, previousIndex=85, events=[Event[event=ack, message=InstanceEvent[resource=71, message=2]]]]
20:39:16.560 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Received PublishRequest[session=69, eventIndex=87, previousIndex=86, events=[Event[event=ack, message=InstanceEvent[resource=71, message=3]]]]
20:39:16.579 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Received PublishRequest[session=69, eventIndex=88, previousIndex=87, events=[Event[event=ack, message=InstanceEvent[resource=71, message=4]]]]
20:39:16.601 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Received PublishRequest[session=69, eventIndex=89, previousIndex=88, events=[Event[event=ack, message=InstanceEvent[resource=71, message=5]]]]
20:39:16.615 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5001
20:39:16.616 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5001
20:39:17.336 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
20:39:18.338 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Sending CommandRequest[session=69, sequence=2, command=InstanceCommand[resource=71, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Submit@c8abe1b, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
20:39:18.338 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
20:39:19.338 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Sending CommandRequest[session=69, sequence=2, command=InstanceCommand[resource=71, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Submit@c8abe1b, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
20:39:19.339 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
20:39:21.340 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Sending CommandRequest[session=69, sequence=2, command=InstanceCommand[resource=71, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Submit@c8abe1b, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
20:39:21.341 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
20:39:24.342 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Sending CommandRequest[session=69, sequence=2, command=InstanceCommand[resource=71, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Submit@c8abe1b, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
20:39:24.343 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
20:39:29.343 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Sending CommandRequest[session=69, sequence=2, command=InstanceCommand[resource=71, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Submit@c8abe1b, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
20:39:29.343 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
20:39:34.344 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Sending CommandRequest[session=69, sequence=2, command=InstanceCommand[resource=71, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Submit@c8abe1b, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
20:39:34.344 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
20:39:39.345 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Sending CommandRequest[session=69, sequence=2, command=InstanceCommand[resource=71, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Submit@c8abe1b, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
20:39:39.345 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
20:39:44.346 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Sending CommandRequest[session=69, sequence=2, command=InstanceCommand[resource=71, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Submit@c8abe1b, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
20:39:44.346 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
20:39:49.347 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 69 - Sending CommandRequest[session=69, sequence=2, command=InstanceCommand[resource=71, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Submit@c8abe1b, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
20:39:49.347 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster

client2.log

Role: consumer
20:39:08.280 [main] DEBUG i.n.u.i.l.InternalLoggerFactory - Using SLF4J as the default logging framework
20:39:08.285 [main] DEBUG i.n.c.MultithreadEventLoopGroup - -Dio.netty.eventLoopThreads: 4
20:39:08.293 [main] DEBUG i.n.util.internal.PlatformDependent0 - java.nio.Buffer.address: available
20:39:08.294 [main] DEBUG i.n.util.internal.PlatformDependent0 - sun.misc.Unsafe.theUnsafe: available
20:39:08.295 [main] DEBUG i.n.util.internal.PlatformDependent0 - sun.misc.Unsafe.copyMemory: available
20:39:08.296 [main] DEBUG i.n.util.internal.PlatformDependent0 - java.nio.Bits.unaligned: true
20:39:08.387 [main] DEBUG i.n.util.internal.PlatformDependent - UID: 1000
20:39:08.387 [main] DEBUG i.n.util.internal.PlatformDependent - Java version: 8
20:39:08.387 [main] DEBUG i.n.util.internal.PlatformDependent - -Dio.netty.noUnsafe: false
20:39:08.387 [main] DEBUG i.n.util.internal.PlatformDependent - sun.misc.Unsafe: available
20:39:08.388 [main] DEBUG i.n.util.internal.PlatformDependent - -Dio.netty.noJavassist: false
20:39:08.388 [main] DEBUG i.n.util.internal.PlatformDependent - Javassist: unavailable
20:39:08.388 [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.
20:39:08.388 [main] DEBUG i.n.util.internal.PlatformDependent - -Dio.netty.tmpdir: /tmp (java.io.tmpdir)
20:39:08.389 [main] DEBUG i.n.util.internal.PlatformDependent - -Dio.netty.bitMode: 64 (sun.arch.data.model)
20:39:08.389 [main] DEBUG i.n.util.internal.PlatformDependent - -Dio.netty.noPreferDirect: false
20:39:08.402 [main] DEBUG io.netty.channel.nio.NioEventLoop - -Dio.netty.noKeySetOptimization: false
20:39:08.402 [main] DEBUG io.netty.channel.nio.NioEventLoop - -Dio.netty.selectorAutoRebuildThreshold: 512
20:39:08.507 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.numHeapArenas: 2
20:39:08.507 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.numDirectArenas: 2
20:39:08.507 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.pageSize: 8192
20:39:08.507 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.maxOrder: 11
20:39:08.507 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.chunkSize: 16777216
20:39:08.507 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.tinyCacheSize: 512
20:39:08.507 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.smallCacheSize: 256
20:39:08.507 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.normalCacheSize: 64
20:39:08.507 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.maxCachedBufferCapacity: 32768
20:39:08.507 [main] DEBUG i.n.buffer.PooledByteBufAllocator - -Dio.netty.allocator.cacheTrimInterval: 8192
20:39:08.532 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - Registering session: attempt 1
20:39:08.534 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - Sending RegisterRequest[client=b53e7af5-392b-41fa-aae5-1dd0a458ef76]
20:39:08.535 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5000
20:39:08.548 [copycat-client-2] DEBUG i.n.util.internal.ThreadLocalRandom - -Dio.netty.initialSeedUniquifier: 0xef8bcfa630137f0c
20:39:08.560 [copycat-client-2] DEBUG i.n.channel.ChannelOutboundBuffer - -Dio.netty.threadLocalDirectBufferSize: 65536
20:39:08.561 [copycat-client-2] DEBUG io.netty.util.Recycler - -Dio.netty.recycler.maxCapacity.default: 262144
20:39:08.576 [copycat-client-2] DEBUG io.netty.buffer.ByteBufUtil - -Dio.netty.allocator.type: unpooled
20:39:08.598 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5000
20:39:08.611 [copycat-client-2] DEBUG io.netty.util.ResourceLeakDetector - -Dio.netty.leakDetectionLevel: simple
20:39:08.702 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - Received RegisterResponse[status=OK, session=52, 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]]
20:39:08.705 [copycat-client-2] DEBUG i.a.c.client.DefaultCopycatClient - State changed: CONNECTED
Client started!
Role: consumer
20:39:08.711 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Sending KeepAliveRequest[session=52, commandSequence=0, eventIndex=52]
20:39:08.726 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5002
20:39:08.729 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Sending CommandRequest[session=52, sequence=1, command=io.atomix.manager.GetResource@4408a7cc]
20:39:08.732 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5002
20:39:08.794 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Received CommandResponse[status=OK, index=54, result=54]
Starting consumer
20:39:08.808 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - 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]]
20:39:08.809 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Sending CommandRequest[session=52, sequence=2, command=InstanceCommand[resource=54, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Subscribe@42e82174, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
20:39:08.835 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Received CommandResponse[status=OK, index=56, result=null]
20:39:11.309 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Sending KeepAliveRequest[session=52, commandSequence=2, eventIndex=52]
20:39:11.324 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - 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]]
20:39:13.824 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Sending KeepAliveRequest[session=52, commandSequence=2, eventIndex=52]
20:39:13.843 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - 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]]
20:39:16.344 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Sending KeepAliveRequest[session=52, commandSequence=2, eventIndex=52]
20:39:16.364 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - 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]]
20:39:16.456 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Received PublishRequest[session=52, eventIndex=73, previousIndex=52, events=[Event[event=process, message=InstanceEvent[resource=54, message=Task ID: 0]]]]
Task: Task ID: 0
20:39:16.461 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Sending CommandRequest[session=52, sequence=3, command=InstanceCommand[resource=54, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@77efaaca, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
20:39:16.509 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Received CommandResponse[status=OK, index=85, result=Task ID: 1]
Task: Task ID: 1
20:39:16.511 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Sending CommandRequest[session=52, sequence=4, command=InstanceCommand[resource=54, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@75f1de50, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
20:39:16.540 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Received CommandResponse[status=OK, index=86, result=Task ID: 2]
Task: Task ID: 2
20:39:16.541 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Sending CommandRequest[session=52, sequence=5, command=InstanceCommand[resource=54, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@1dec561a, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
20:39:16.564 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Received CommandResponse[status=OK, index=87, result=Task ID: 3]
Task: Task ID: 3
20:39:16.564 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Sending CommandRequest[session=52, sequence=6, command=InstanceCommand[resource=54, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@6f27221b, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
20:39:16.582 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Received CommandResponse[status=OK, index=88, result=Task ID: 4]
Task: Task ID: 4
20:39:16.583 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Sending CommandRequest[session=52, sequence=7, command=InstanceCommand[resource=54, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@178a6b18, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
20:39:16.605 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Received CommandResponse[status=OK, index=89, result=Task ID: 5]
Task: Task ID: 5
20:39:16.605 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Sending CommandRequest[session=52, sequence=8, command=InstanceCommand[resource=54, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@6cf224e7, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
20:39:17.190 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5001
20:39:17.192 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5001
20:39:17.818 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5000
20:39:17.821 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5000
20:39:18.576 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
20:39:18.865 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Sending KeepAliveRequest[session=52, commandSequence=7, eventIndex=73]
20:39:18.865 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
20:39:18.865 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Sending KeepAliveRequest[session=52, commandSequence=7, eventIndex=73]
20:39:18.865 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5002
20:39:18.867 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5002
20:39:18.893 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - 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]]
20:39:19.577 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Sending CommandRequest[session=52, sequence=8, command=InstanceCommand[resource=54, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@6cf224e7, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
20:39:19.579 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5001
20:39:19.581 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5001
20:39:20.319 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5002
20:39:20.322 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5002
20:39:20.922 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5000
20:39:20.924 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5000
20:39:21.393 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Sending KeepAliveRequest[session=52, commandSequence=7, eventIndex=73]
20:39:21.415 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - 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]]
20:39:21.675 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
20:39:22.675 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Sending CommandRequest[session=52, sequence=8, command=InstanceCommand[resource=54, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@6cf224e7, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
20:39:22.676 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
20:39:23.916 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Sending KeepAliveRequest[session=52, commandSequence=7, eventIndex=73]
20:39:23.916 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Failed to connect to the cluster
20:39:23.916 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Sending KeepAliveRequest[session=52, commandSequence=7, eventIndex=73]
20:39:23.916 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5002
20:39:23.918 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5002
20:39:23.955 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - 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]]
20:39:24.676 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Sending CommandRequest[session=52, sequence=8, command=InstanceCommand[resource=54, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@6cf224e7, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
20:39:24.683 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5000
20:39:24.685 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5000
20:39:24.711 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Received CommandResponse[status=OK, index=119, result=Task ID: 6]
Task: Task ID: 6
20:39:24.713 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Sending CommandRequest[session=52, sequence=9, command=InstanceCommand[resource=54, command=ResourceCommand[command=io.atomix.messaging.state.TaskQueueCommands$Ack@17b551d5, consistency=LINEARIZABLE], consistency=LINEARIZABLE]]
20:39:25.436 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Connecting to localhost/127.0.0.1:5001
20:39:25.437 [copycat-client-2] DEBUG i.a.c.client.util.ClientConnection - Setting up connection to localhost/127.0.0.1:5001
20:39:25.474 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Received CommandResponse[status=OK, index=124, result=null]
20:39:26.456 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Sending KeepAliveRequest[session=52, commandSequence=9, eventIndex=73]
20:39:26.469 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - 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]]
20:39:28.970 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Sending KeepAliveRequest[session=52, commandSequence=9, eventIndex=73]
20:39:28.989 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - 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]]
20:39:31.490 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Sending KeepAliveRequest[session=52, commandSequence=9, eventIndex=73]
20:39:31.507 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - 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]]
20:39:34.012 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Sending KeepAliveRequest[session=52, commandSequence=9, eventIndex=73]
20:39:34.031 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - 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]]
20:39:36.532 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Sending KeepAliveRequest[session=52, commandSequence=9, eventIndex=73]
20:39:36.546 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - 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]]
20:39:39.047 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Sending KeepAliveRequest[session=52, commandSequence=9, eventIndex=73]
20:39:39.086 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - 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]]
20:39:41.587 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Sending KeepAliveRequest[session=52, commandSequence=9, eventIndex=73]
20:39:41.603 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - 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]]
20:39:44.105 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Sending KeepAliveRequest[session=52, commandSequence=9, eventIndex=73]
20:39:44.135 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - 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]]
20:39:46.642 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Sending KeepAliveRequest[session=52, commandSequence=9, eventIndex=73]
20:39:46.664 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - 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]]
20:39:49.165 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Sending KeepAliveRequest[session=52, commandSequence=9, eventIndex=73]
20:39:49.181 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - 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]]
20:39:51.682 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - Sending KeepAliveRequest[session=52, commandSequence=9, eventIndex=73]
20:39:51.703 [copycat-client-2] DEBUG i.a.c.client.session.ClientSession - 52 - 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]]