Created
January 4, 2016 19:40
-
-
Save electrical/02dafd54c0a48a310455 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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]] |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment