castorm

package es.castorm.akka;

import static com.typesafe.config.ConfigFactory.defaultReference;
import static com.typesafe.config.ConfigFactory.parseMap;
import static es.castorm.akka.AkkaConfigPropertySourceAdapter.getConfigMap;

import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;

castorm

package es.castorm.akka;

import static es.castorm.akka.AkkaConfigPropertySource.PROPERTY_SOURCE_NAME;
import static java.util.Collections.emptyMap;
import static java.util.Collections.unmodifiableList;
import static java.util.Collections.unmodifiableMap;
import static java.util.Comparator.comparing;
import static java.util.stream.Collectors.toMap;
import static java.util.stream.StreamSupport.stream;
import static org.springframework.core.env.StandardEnvironment.SYSTEM_ENVIRONMENT_PROPERTY_SOURCE_NAME;

castorm

package es.castorm.akka;

import java.util.Map.Entry;

import org.springframework.core.env.EnumerablePropertySource;

import com.typesafe.config.Config;

public class AkkaConfigPropertySource extends EnumerablePropertySource<Config> {

castorm

package es.castorm.akka.spring;

import static java.lang.Integer.MAX_VALUE;
import static java.util.Optional.ofNullable;
import static java.util.stream.Collectors.toSet;
import static java.util.stream.StreamSupport.stream;

import java.util.Collections;
import java.util.HashSet;
import java.util.Optional;

castorm

package es.castorm.akka.spring;

import org.springframework.context.ApplicationContext;
import org.springframework.stereotype.Component;

import akka.actor.Extension;
import akka.actor.IndirectActorProducer;
import akka.actor.Props;
import lombok.RequiredArgsConstructor;

castorm

package es.castorm.akka.spring;

import static java.lang.Integer.MAX_VALUE;

import java.util.concurrent.atomic.AtomicBoolean;
import java.util.function.Function;

import org.springframework.context.SmartLifecycle;
import org.springframework.context.event.ContextClosedEvent;
import org.springframework.context.event.EventListener;

castorm

package es.castorm.batch;

import es.castorm.batch.ThreadPoolProvider;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.actuate.metrics.CounterService;
import org.springframework.boot.actuate.metrics.GaugeService;
import org.springframework.stereotype.Component;
import rx.Subscription;
import rx.subjects.PublishSubject;

castorm

package es.castorm.batch;

import com.google.common.collect.ImmutableList;
import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import rx.Completable;
import rx.Observable;
import rx.Scheduler;
import rx.subjects.PublishSubject;

castorm

sudo /Applications/Install\ OS\ X\ Yosemite.app/Contents/Resources/createinstallmedia --volume /Volumes/Untitled --applicationpath /Applications/Install\ OS\ X\ Yosemite.app --nointeraction