jbcpollak

@Configuration
public class FutureFactoryConfiguration {

    ActorSystem system = ActorSystem.create();
    
    @Resource(name="geocodingService")
    private GeocodingService geocodingService;
    
    @Bean(name="executionContext")
    public ExecutionContext getExecutionContext() {

jbcpollak

public class AddressGeocodingFutureFactoryTest extends FutureFactoryTestBase {

    @Test
    public void testFuture() throws Exception {
        
        GeocodingService geocodingService = mock(GeocodingService.class);
        
        GeocodingFutureFactory gff = new GeocodingFutureFactory();
        
        gff.setExecutionContext(ec);

jbcpollak

public class FutureFactoryTestBase {

    protected ExecutionContext ec;
    
    @Before
    public void setup() {
        Config config = ConfigFactory.load();
        ActorSystem system = ActorSystem.create("test", config);
        
        ec = system.dispatchers().lookup("akka.test.calling-thread-dispatcher");

jbcpollak

@Setter
public class AddressGeocodingFutureFactory extends AbstractFutureFactory<Address> {

    private GeocodingService geocoder;

    @Override
    public Future<Address> makeFuture(final Address address) {
        return Futures.future(new Callable<Address>() {
            public Profile call() throws Exception {

jbcpollak

package com.assuredlabor.services.concurrent;

import lombok.Setter;
import scala.concurrent.ExecutionContext;

@Setter
public abstract class AbstractFutureFactory<T> implements FutureFactory<T> {

    protected ExecutionContext executionContext;
}

jbcpollak

        <dependency>
            <groupId>com.typesafe.akka</groupId>
            <artifactId>akka-actor_2.10</artifactId>
            <version>2.2.3</version>
        </dependency>
        <dependency>
            <groupId>com.typesafe.akka</groupId>
            <artifactId>akka-testkit_2.10</artifactId>
            <version>2.2.3</version>
            <scope>test</scope>

jbcpollak

#!/bin/sh


# ANDROID_NOTIFICATION is in the format DEVICE_ID/NOTIFICATION_ID/EVENT_TYPE/EVENT_CONTENTS
NOTIFICATION_TYPE="`echo $ANDROID_NOTIFICATION | sed 's/.*\/.*\/\(.*\)\/.*/\1/'`"
NOTIFICATION_DATA="`echo $ANDROID_NOTIFICATION | sed 's/.*\///'`"

if [ "x$NOTIFICATION_TYPE" == "xRING" ]; then
  TEXT_TO_SAY="Call from"
elif [ "x$NOTIFICATION_TYPE" == "xSMS" ]; then