Skip to content

Instantly share code, notes, and snippets.

2019-01-14 22:34:11,947 [redisson-3-8] DEBUG o.r.command.CommandAsyncService - acquired connection for command (EVAL) and params [if (redis.call('exists', KEYS[1]) == 0) then redis.call('hset', KEYS[1], ARGV[2], 1); redis.call('pexpire', KEYS[1], ARGV[1]); return nil; end; if (redis.call('hexists', KEYS[1], ARGV[2]) == 1) then redis.call('hincrby', KEYS[1], ARGV[2], 1); redis.call('pexpire', KEYS[1], ARGV[1]); return nil; end; return redis.call('pttl', KEYS[1]);, 1, {capabilities-actual}:ahYJV0+f0oYzVzuq62uJ6w:lock, 5000, c878e3d1-0b6e-4ba8-87b2-911ec04c70f9:79:d65ad528778ef5f294378165df990b99] from slot NodeSource [slot=null, addr=null, redisClient=null, redirect=null, entry=MasterSlaveEntry [masterEntry=[freeSubscribeConnectionsAmount=0, freeSubscribeConnectionsCounter=48, freeConnectionsAmount=30, freeConnectionsCounter=62, freezed=false, freezeReason=null, client=[addr=redis://aws-eu-central-1-portal.2.dblayer.com:17553], nodeType=MASTER, firstFail=0]]] using node aws-eu-central-1-portal.2.dblayer.com/52
{
"description": "description",
"name": [
{
"en-CA": "caaaaaaaaaaa",
"en-CB": "cbbbbbbbbbbb"
}
],
"slug": "/super/duper/slug",
"status": "active",
package org.springframework.cloud.sleuth.zipkin;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.consul.discovery.ConsulDiscoveryClient;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpMethod;
import org.springframework.http.MediaType;
import org.springframework.http.RequestEntity;
package org.springframework.cloud.sleuth.zipkin;
import org.springframework.cloud.consul.discovery.ConsulDiscoveryClient;
import org.springframework.cloud.sleuth.metric.SpanMetricReporter;
import org.springframework.web.client.RestTemplate;
import zipkin.Span;
import zipkin.reporter.AsyncReporter;
import java.io.Closeable;
import java.io.Flushable;
import org.openjdk.jmh.annotations.*;
import org.openjdk.jmh.infra.Blackhole;
import java.io.Serializable;
import java.util.Random;
import java.util.concurrent.TimeUnit;
@State(Scope.Benchmark)
public class MyBenchmark {
import java.util.*;
/**
* Created by asemelit on 22.03.2016.
*/
public class CollectionPlayground {
public static void main(String[] args) {
// Map<String,Integer> testMap = new HashMap<>();
// testMap.put("a", 1);
// testMap.put("b", 1);
@bashnesnos
bashnesnos / TarantoolConnection16Pool.java
Created December 21, 2015 15:01
TarantoolConnection16Pool
import org.tarantool.TarantoolConnection16;
import org.tarantool.TarantoolConnection16Impl;
import org.tarantool.TarantoolGenericConnection16;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.TimeUnit;