SpringLifetimeExtension.java

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;

/**
 * {@link SpringLifetimeExtension} allows Spring DI for {@link cloud.orbit.actors.runtime.AbstractActor}.
 * Autowire mode can be set via <code>orbit.actors.autowireMode</code>.
 *
 * @author Johno Crawford (johno@sulake.com)
 */
@Component
public class SpringLifetimeExtension implements LifetimeExtension {

    @Autowired
    private AutowireCapableBeanFactory autowireCapableBeanFactory;

    @Value("${orbit.actors.autowireMode:" + AutowireCapableBeanFactory.AUTOWIRE_BY_NAME + "}")
    private int autowireMode;

    /*
    @Override
    public Task preActivation(AbstractActor abstractActor) {
        autowireCapableBeanFactory.autowireBeanProperties(abstractActor, autowireMode, false);
        autowireCapableBeanFactory.initializeBean(abstractActor, abstractActor.getClass().getName()); // bean post processors
        return Task.done();
    }
    */

    @Override
    @SuppressWarnings("unchecked")
    public <T> T newInstance(Class<T> concreteClass) {
        try {
            T abstractActor = concreteClass.newInstance();
            autowireCapableBeanFactory.autowireBeanProperties(abstractActor, autowireMode, false);
            return (T) autowireCapableBeanFactory.initializeBean(abstractActor, abstractActor.getClass().getName());
        } catch (Exception ex) {
            throw new UncheckedException(ex);
        }
    }
}