johnou

using System;
using System.Collections.Generic;
using System.IO;
using System.IO.Pipes;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace PipeDream

johnou

Index: transport/src/main/java/io/netty/channel/DefaultChannelPromise.java
IDEA additional info:
Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
<+>UTF-8
===================================================================
--- transport/src/main/java/io/netty/channel/DefaultChannelPromise.java	(date 1476448287000)
+++ transport/src/main/java/io/netty/channel/DefaultChannelPromise.java	(revision )
@@ -20,6 +20,8 @@
 import io.netty.util.concurrent.EventExecutor;
 import io.netty.util.concurrent.Future;

johnou

import cloud.orbit.actors.extensions.LifetimeExtension;
import cloud.orbit.actors.runtime.AbstractActor;
import cloud.orbit.concurrent.Task;
import cloud.orbit.exception.UncheckedException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.beans.factory.config.AutowireCapableBeanFactory;
import org.springframework.stereotype.Component;

/**

johnou

import cloud.orbit.actors.Actor;
import cloud.orbit.actors.Remindable;
import cloud.orbit.actors.extensions.ActorClassFinder;
import cloud.orbit.actors.runtime.ReminderController;
import cloud.orbit.actors.runtime.ReminderControllerActor;
import cloud.orbit.actors.streams.simple.SimpleStream;
import cloud.orbit.actors.streams.simple.SimpleStreamActor;
import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.AnnotatedBeanDefinition;
import org.springframework.beans.factory.annotation.Autowired;

johnou

import org.springframework.dao.EmptyResultDataAccessException;
import org.springframework.jdbc.core.support.JdbcDaoSupport;
import org.springframework.stereotype.Repository;

/**
 * @author Johno Crawford ([email protected])
 */
@Repository
public class JdbcOrbitStateDao extends JdbcDaoSupport implements OrbitStateDao {

johnou

import cloud.orbit.actors.extensions.AbstractStorageExtension;
import cloud.orbit.actors.extensions.json.ActorReferenceModule;
import cloud.orbit.actors.runtime.DefaultDescriptorFactory;
import cloud.orbit.actors.runtime.RemoteReference;
import cloud.orbit.concurrent.Task;
import cloud.orbit.exception.UncheckedException;
import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

johnou

https://www.gpg4win.org/

Keywords

windows no tty intellij
pgp secret key not available

Environment variables

GNUPGHOME=C:\Users\Username\AppData\Roaming\gnupg

johnou

<project name="NettyProject" default="dist" basedir=".">
<property name="build-destination" value="build" />
<property name="input-artifact" value="netty-all-4.0.34.Final-SNAPSHOT.jar" />
<property name="shaded-artifact" value="netty-all-4.0.34.Final-shaded.jar" />
<target name="dist">
    <delete dir="${build-destination}" />
    <get src="https://storage.googleapis.com/google-code-archive-downloads/v2/code.google.com/jarjar/jarjar-1.4.jar" dest="jarjar-1.4.jar"/>
    <taskdef name="jarjar" classname="com.tonicsystems.jarjar.JarJarTask" classpath="jarjar-1.4.jar"/>
    <jarjar jarfile="${build-destination}/${shaded-artifact}">
          <zipfileset src="${input-artifact}" excludes="META-INF/**"/>

johnou

    public PurgeResult send(String user, String password, Collection<String> urls) throws PurgeException {

        JsonObject payload = createPurgePayload(urls);

        Response response = null;
        try {
            Client client = ClientBuilder.newClient();
            client.register(HttpAuthenticationFeature.basic(user, password));
            WebTarget target = client.target("https://api.ccu.akamai.com");
            WebTarget resource = target.path("/ccu/v2/queues/default");