De MorfeoWiki

Requisitos del sistema

Para ejecutar el correlador, es necesario tener instaldos los siguientes componentes en el sistema:

-JDK 1.6

-Maven 2.0.6 (o superior)

-Ant 1.7.0 o bien Eclipse(3.2 o superior)

Descarga y compilación

La descarga de la versión 0.5 del motor de correlación se realizará haciendo un checkout como se indica a continuación:

svn co https://svn.morfeo-project.org/svn/wasup/trunk/WP3/WasupCorrelator/     < triton-0.5
Una vez lo hemos descargado es necesario,compilar e instalar las dependencias del correlador con maven : 
cd triton-0.5
mvn install
El mismo proceder con la pasarela : 
cd triton-gateway-rest
mvn install

Una vez han sido compilados ambos proyectos se pueden generar los ficheros de proyecto para Eclipse(si queremos ejecutar el sistema desde este IDE):

mvn install eclipse:eclipse 

Ejecución del sistema

Para poder probar esta versión del motor de correlación es necesario instalar Apache ActiveMQ5.0 y ejecutarlo antes de poner en marcha el correlador. Al estar basado en Java necesita que se tenga instalada la máquina virtual. Sin embargo no es imprescindible (aunque sí recomendable por fines de depuración) el que se ejecute el BUS en la misma máquina que el correlador.

Para instalarlo es necesario descargar ActiveMQ de la página [http://activemq.apache.org] y descomprimirlo en la carpeta de trabajo que se desee. Una vez hecho esto, para iniciar ActiveMQ es necesario hacerlo a través del script de arranque:

• Windows: bin\activemq.bat
• Unix: bin/activemq

Una vez tenemos en marcha el BUS JMS, tenemos que lanzar las diferentes partes del sistema para que funcionen en conjunto, esto es, el motor del correlador(triton-engine) y la pasarela (triton-gateway-rest).

La aplicación esta preparada para subscribirse a canales del Bus JMS en local, si queremos acceder a un Broker remoto debemos cambiar este parámetro en ambos proyectos, modificando los siguientes ficheros :

Correlador(tritón-engine):

Modificamos en la clase com.s2grupo.triton.engine.Constants el atributo :

public static final String JMS_BROKER_URL = "tcp://localhost:61616";

Pasarela(tritón-gateway-rest):

Modificamos el archivo com.s2grupo.triton.gateway.application.properties cambiando el atributo :

activemq.url=tcp://localhost:61616

Ejecución con ant:

Esto lo podemos hacer utilizando ant de la siguiente forma :

cd triton-engine
ant start
cd triton-gateway-rest
ant start

Ambos proyectos se pueden parar de la siguiente forma :

cd triton-engine
ant stop
cd triton-gateway-rest
ant stop

Hay que tener en cuenta que en el momento de redactar este documento,los eventos procedentes de los mensajes JMS del Receptor de Datos de Wasup, están incluidos en el BODY del propio mensaje, por lo que el correlador no los procesará, ya que está preparado para trabajar con los campos incrustados en el HEADER.Por lo tanto se debe enviar el objeto aplanado en el header del mensaje de la forma : “event.eventType.eventTypeId = 1”

Ejecución con eclipse:

Una vez compilados los proyectos, se pueden importar desde el IDE Eclipse, (Import -> Existing Projects into Workspace..). Seleccionamos el directorio raiz triton-0.5 anteriormente creado y se importaran en nuestro directorio de trabajo.

Para ejecutar el sistema, debemos crear 2 perfiles de ejecucion a modo de Java Application: -para lanzar el triton-engine, la Main class es : com.s2grupo.triton.engine.Engine -para lanzar la pasarela (triton-gateway-rest), la Main class es : com.s2grupo.triton.gateway.main.Gateway

Customización para pruebas.

El motor del correlación está preparador para lanzar el correlador que está suscrito al topic donde vuelca los eventos el Receptor de Datos, este topic “CORRELATOR.BASIC_EVENT” será el punto de entrada de los eventos a correlar. Si queremos cambiar el nombre del topic debemos modificar el archivo de propiedades que se encuentra en el proyecto tritón-correlator-wasup bajo la ruta:-com.s2grupo.triton.correlator.wasup.model-aliases.properties

En el encontramos 2 topics en los cuales el correlador se suscribe en modo consumidor : CORRELATOR.BASIC_EVENT y CORRELATOR.BASIC_ALARM (no utilizado de momento) y 2 topics que utilizará en modo productor para enlazar con la pasarela: CORRELATOR.CORRELATED_EVENT y CORRELATOR.CORRELATED_ALARM

Los casos de uso parametrizados a modo de ejemplo en estos momentos son los siguientes : 
1.- La medida supera un determinado umbral fijo (800ºC)
2.- La medida es inferior a un determinado umbral fijo (500ºC)
3.- No se recibe medida del elemento con id 1 en un determinado intervalo de tiempo inactividad durante 1 hora.
Estos valores se pueden modificar accediendo al archivo de propiedades :
    -com.s2grupo.triton.correlator.wasup.configuration.properties :

maxTemperature=800minTemperature=500elementId=1inactiveMilis=3600000