ebarlas

package com.citrix.extadmin.job.data.async;

import com.citrix.extadmin.job.data.JobData;
import com.citrix.extadmin.job.data.JobDatabase;
import com.citrix.extadmin.job.data.JobStatus;
import com.citrix.store.Store;
import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;

ebarlas

    @Test
    public void testSSEHistory() throws Exception {
        long userKey = new AccountBuilder().addAdminUser().build().getFirstUserKey();

        Client client = ClientBuilder.newClient();
        Invocation.Builder sse = client
                .target(serviceRestUrl + "/jobs")
                .request()
                .accept(SseFeature.SERVER_SENT_EVENTS_TYPE)
                .header("userKey", String.valueOf(userKey));

ebarlas

    private static List<String> find(List<String> unordered, int from, int to) {
        if (from < unordered.size() / 2) {
            PriorityQueue<String> queue = new PriorityQueue<>(unordered);

            for (int i=0; i<from; i++) queue.remove();

            List<String> result = new ArrayList<>();
            for (int i=from; i<to; i++) {
                result.add(queue.remove());
            }

ebarlas

package com.citrix.extadmin.util;

import java.text.Collator;

public class FastCollator {

    private static final char[] CASEINS = new char[127];
    private static final char[] CASESEN = new char[127];

    private static final Collator collator = Collator.getInstance();

ebarlas

package com.citrix.extadmin.store;

import com.citrix.extadmin.util.JavaSerializer;
import com.citrix.store.Serializer;
import com.javamex.classmexer.MemoryUtil;
import gnu.trove.map.hash.TLongObjectHashMap;
import net.sf.ehcache.pool.sizeof.ReflectionSizeOf;
import org.nustaq.serialization.FSTConfiguration;
import org.nustaq.serialization.FSTObjectOutput;

ebarlas

package com.citrix.security.util;

import org.springframework.http.HttpRequest;
import org.springframework.http.client.ClientHttpRequestExecution;
import org.springframework.http.client.ClientHttpRequestInterceptor;
import org.springframework.http.client.ClientHttpResponse;

import java.io.IOException;
import javax.validation.constraints.NotNull;

ebarlas

private String utf8Encoded(String name) throws UnsupportedEncodingException {
    return new String(name.getBytes(ISO_8859_1), "UTF-8");
}

ebarlas

public class GameDev {
  public static void main(String[] args) {
    System.out.println("Hello world); 
  }
}

ebarlas

var light = new AtomicReference<>(TrafficLight.GREEN);
light.updateAndGet(TrafficLight::next);

ebarlas

import java.util.Random;

public class Main {

    public static void main(String[] args) {
        int len = 36;
        byte[] arr1 = new byte[len];
        byte[] arr2 = new byte[len];
        Random random = new Random();
        random.nextBytes(arr1);