• Se define la interfaz IChainExecutionElement que establecerá el contrato que todas las implementaciones del servicio de traducción deberán cumplir. En este caso, se define un método principal doChain que recibirá el mensaje de entrada a procesar y devolverá un booleano dependiendo de si ha podido procesarlo (true) o no (false). De esta manera el servicio de ejecución de la cadena de receptores sabe si debe propagar el mensaje al siguiente receptor.

public interface IChainExecutionElement 
{
    public boolean doChain(TranslationChainMessage action) throws Exception;
}

• Mediante el escaneo dinámico del classpath que proporciona Spring cómo método de configuración mediante la anotación @ComponentScan, se pueden añadir diferentes implementaciones del servicio de traducción sin necesidad de modificar el código principal de la aplicación. En este caso todas la implementaciones disponibles se encuentran bajo el package indicado en dicha anotación, que será explorada durante la inicialización de este en busca de definiciones de beans. Lo que hace este mecanismo realmente flexible es la posibilidad de incluir estos componentes en varios módulos diferentes, incluso ubicados en ficheros jar distintos, y utilizar el escaneo dinámico para recuperarlos todos para su utilización.

@Configuration
@ComponentScan({"snippets.ioc.spring.cor"})
public class ChainOfResponsabilityConfig 
{
     
}

• A continuación se muestra un ejemplo de implementación de un componente de tipo receptor. Se puede ver la definición como componente de Spring mediante la anotación @Component, la inicialización del componente estableciendo qué palabras es capaz de traducir y el método doChain decide si es capaz de procesar el mensaje de entrada y de proporcionar un resultado si es el caso. También se puede observar como se indica al servicio ejecutor si ha sido capaz de procesar el mensaje devolviendo true o false.

@Component
public class EnglishMessageProcessor implements IChainExecutionElement 
{
    private Map translationMap;
     
    @PostConstruct
    private void setUp()
    {
        translationMap = ImmutableMap.builder()
                .put("Hello", "Hola") 
                .put("Goodbye", "Adios") 
                .put("Car", "Coche") 
                .put("House", "Casa")
                .build();
    }
     
    @Override
    public boolean doChain(TranslationChainMessage action) throws Exception 
    {
        // Sólo se procesará en caso que el idioma sea el esperado 
        // y se tenga la traducción para el mensaje recibido
        if(!"en".equals(action.getLanguage())
                || !translationMap.containsKey(action.getMessage())){
            return false;
        }
         
        action.setTranslation(translationMap.get(action.getMessage()));
        action.setProcessorName("EnglishMessageProcessor");
         
        return true;
    }
}

En el repositorio adjunto en los links de interés, se pueden consultar la implementación del resto de componentes realizados para el ejemplo, todos con una estructura similar.

• Para probar la implementación de ejemplo realizada, se ha diseñado un test muy simple en el que se pasan diferentes palabras a traducir en inglés o alemán y se comprueba el resultado y quien ha sido el responsable de la traducción.

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(classes={ChainOfResponsabilityConfig.class})
public class ChainOfResponsabilityTestCase 
{
    @Autowired
    private ChainExecutionService executionService;
     
    @Test
    public void translationTest() throws Exception
    {
        TranslationChainMessage message1 = new TranslationChainMessage();
        message1.setLanguage("en");
        message1.setMessage("Car");
        executionService.executeChain(message1);
        Assert.assertEquals("Coche", message1.getTranslation());
        Assert.assertEquals("EnglishMessageProcessor", message1.getProcessorName());
         
        TranslationChainMessage message2 = new TranslationChainMessage();
        message2.setLanguage("de");
        message2.setMessage("Auto");
        executionService.executeChain(message2);
        Assert.assertEquals("Coche", message2.getTranslation());
        Assert.assertEquals("GermanMessageProcessor", message2.getProcessorName());
         
        TranslationChainMessage message3 = new TranslationChainMessage();
        message3.setLanguage("en");
        message3.setMessage("Hello");
        executionService.executeChain(message3);
        Assert.assertEquals("Hola", message3.getTranslation());
        Assert.assertEquals("EnglishGreetingsMessageProcessor", message3.getProcessorName());
    }
}