Mensajes

[JDK 1.7+]

No cites mis respuestas para no hacer muy largas las mismas. Pégame el StackTrace y las clases que tienes.

PD: Para que funcione CDI (inyeción de dependencias) tienes que crear un archivo beans.xml en el directorio WEB-INF/, en donde está el web.xml.

JDK 1.7+

Código (java) [Seleccionar] Expandir

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://xmlns.jcp.org/xml/ns/javaee"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/beans_1_1.xsd"
       version="1.1" bean-discovery-mode="all">
</beans>

Mi JDK es 1.6, será este el problema...


Muchas gracias.

Un saludo:

[UPDATE]

Código (=java) [Seleccionar] Expandir

@Inject private BeanLocal myEJB;

Para registrar un TimerService, simplemente haría:

Código (=java) [Seleccionar] Expandir


myEJB.start("identificadorTimer");

Y para cancelar un TimerService:

Código (=java) [Seleccionar] Expandir

myEJB.stop("identificadorTimer");

Nota: Yo le puse @Singleton porque quería que solo exista una instancia del EJB Timer. Funciona igual con EJB Stateless y Stateful.

UPDATE

De acuerdo a la especificación de EJB 3.1, si va a ser un EJB local solamente, se puede obviar la interface @Local. Solo basta ponerle al EJB @LocalBean para indicar que es un EJB local.

Código (=java) [Seleccionar] Expandir

@LocalBean
@Singleton
public class TimerBean {

Hola compañero, me está dando NullPointerException cuando en el proyecto web.


- Me creo el atributo del EJB

Código (=java) [Seleccionar] Expandir

@Inject private BeanLocal myEJB;


Pero cuando invoco al método start, ahí me da NullPointerException

Código (=java) [Seleccionar] Expandir


myEJB.start("identificadorTimer");


¿Cómo tendría que instanciar el EJB dentro de una clase del Proyecto Web para que no me de null?

Un saludo y muchas gracias de nuevo.

[@Resource]

Exactamente. Me captaste la idea 

Para invocar al método @Timeout no es necesario invocar nada. En el momento en que registras un TimerService, el método @Timeout se invocará automáticamente cuando expire el tiempo de espera.

Otra cosa. Un TimerService tiene que ser usado en un servidor de aplicaciones ya que, éste será inyectado por medio de @Resource por el contenedor del servidor. Además creo que para usar un EJB Timer es necesario especificar si es un Bean local o remoto por medio de sus interfaces. Te dejo un ejemplo:

Interface local:

Código (java) [Seleccionar] Expandir

import javax.ejb.Local;
import javax.ejb.Timer;

@Local
public interface BeanLocal {
public void start(String name);
public void execute(Timer timer);
public void stop(String name);
}

El EJB

Código (java) [Seleccionar] Expandir

import javax.annotation.Resource;
import javax.ejb.Singleton;
import javax.ejb.Timeout;
import javax.ejb.Timer;
import javax.ejb.TimerService;

@Singleton
public class TimerBean implements BeanLocal {

@Resource TimerService timer;

@Override
public void start(String name) {
boolean exists = false;
for(Timer temp : timer.getTimers()) {
if(temp.getInfo().equals(name))
exists = true;
}
if(!exists)
timer.createTimer(15000, 3000, name);
}

@Override @Timeout
public void execute(Timer timer) {
System.out.println("Método @Timeout invocado: "+timer.getInfo());
}

@Override
public void stop(String name) {
for(Timer temp : timer.getTimers()) {
if(temp.getInfo().equals(name))
temp.cancel();
}
}

}

Luego, donde uses el EJB Timer lo inyectas también:

Código (=java) [Seleccionar] Expandir

@Inject private BeanLocal myEJB;

Para registrar un TimerService, simplemente haría:

Código (=java) [Seleccionar] Expandir


myEJB.start("identificadorTimer");

Y para cancelar un TimerService:

Código (=java) [Seleccionar] Expandir

myEJB.stop("identificadorTimer");

Nota: Yo le puse @Singleton porque quería que solo exista una instancia del EJB Timer. Funciona igual con EJB Stateless y Stateful.

De acuerdo, muchísimas gracias. Mañana lo voy a probar a ver qué sucede.

Un saludo!!

[1.- Hacer la consulta en un Thread.]

Yo lo haría así:

1.- Hacer la consulta en un Thread.
2.- Haces la consulta.
3.- Registras el Timer a 20 segundos.
4.- En el método @Timeout cancelas el Thread y por consiguiente la consulta.

Vale gracias, hice los pasos:


1.- Hacer la consulta en un Thread.

Código (java) [Seleccionar] Expandir



public class ConsultaBBDD implements Runnable{

public void run() {
String datos = consultarBBDD();

}

public String consultarBBDD(){
return "datosBBDD";
}
}








2.- Haces la consulta.

Código (java) [Seleccionar] Expandir


public class ClasePrincipal {

public String obtenerDatos(){
Thread t = new Thread(new ConsultaBBDD());
t.start();

return "";
}

}





3.- Registras el Timer a 20 segundos.
4.- En el método @Timeout cancelas el Thread y por consiguiente la consulta.

Código (java) [Seleccionar] Expandir


import java.io.Serializable;
import javax.annotation.Resource;
import javax.ejb.Stateless;
import javax.ejb.Timeout;
import javax.ejb.Timer;
import javax.ejb.TimerService;


@Stateless
public class TimeoutRespuesta {

@Resource TimerService timer;

public void doSomething(Object obj) {
    timer.createTimer(20000, 20000, (Serializable) obj);
}

@Timeout void doOtherThing(Timer timer)  {
    Thread t = new Thread();
    t.stop();
}
}





¿Sería algo parecido a lo que puse?. Lo que me falta sería la invocación del EJB dentro de la ClasePrincipal, pero es que no sé exactamente cómo sería, ¿qué método suyo tendrían que invocar?.


Muchas gracias.

Saludos.

No te entiendo. ¿Dices que quieres controlar el timeout dinámicamente?

Si es así, puedes controlarlo cancelándolo y volviendo a crearlo. Por ejemplo:

Código (java) [Seleccionar] Expandir

public void startOrModifyTimer(long initialExpiration, long interval, String name){     
        for (Timer timer: timer.getTimers()) {
            if (timer.getInfo().equals(name)) {
                timer.cancel();
            }
        }
        TimerConfig config = new TimerConfig();
        config.setInfo(name);
        config.setPersistent(false);
        timerService.createIntervalTimer(initialExpiration, interval, config);
}

Hola, muchas gracias. Ésto es lo que quiero hacer, pongo un ejemplo:

Tengo un proyecto web en Java, ahora bien, tengo un método que hace una consulta a la base de datos, pues imagínate que se queda pillado el método y no devuelve nunca el resultado de la consulta, en vez de quedarse bloqueado, lo que quiero es mediante el timeout de un EJB, controlar y decir si se invoca el método y pasan 20 segundos y no se recibe respuesta que se salga del método y no se quede pillado ahí.


Saludos.

Cuando se utiliza un método timeout anotado con @timeout, la especificación nos dice que el método debe retornar void y sólo recibir como parámetro un objeto javax.ejb.TimerService o en su defecto, no debe recibir parámetros.

Para registrar un timeout podemos hacerlo de la siguiente manera (de acuerdo a la tercera forma):

Código (java) [Seleccionar] Expandir

createTimer(long duracionInicial, long duracionIntervalo, serializable objetoAsociado);

Así que puedes crearlo así:

Código (java) [Seleccionar] Expandir

@Resource TimerService timer; // opcional, aquí inyectamos al objeto TimerService

public void doSomething(Objeto obj) {
    timer.createTimer(15*60*1000, 15*60*1000, obj);
}

Lo que se ha hecho es crear un TimerService cuya primera véz de ejecución será un timeout de 15 minutos y el intérvalo entre ejecuciones será de 15 minutos también. Así mismo, hemos asociado al TimerService un objeto que debe implementar Serializable.

Bien, ahora el método que se ejecutará luego del registro del TimerService será:

Código (java) [Seleccionar] Expandir

@timeout doOtherThing(Timer timer)  {
    Objeto obj = (Objeto) timer.getInfo();
    // hacer otras cosas...
}

El método getInfo() retorna el objeto asociado al TimerService. Si al momento de crear el TimerService en lugar de un objeto se declara null, el valor devuelto será null también.

Ahora, si estoy en lo correcto, podemos cancelar un TimerService. Por ejemplo si en lugar de un objeto le hemos asociado un nombre, podríamos detenerlo así:

Código (java) [Seleccionar] Expandir

public void stop(String timerName) {
    for(Object obj : timerService.getTimers()) {
        Timer t = (Timer)obj;
        if (t.getInfo().equals(timerName)) {
        t.cancel();
        }
    }
}

Pero si no hemos asociado un nombre, podemos detenerlos iterando el conjunto de TimerService:

Código (java) [Seleccionar] Expandir

public void stop() { 
        List<Timer> timers = timerService.getTimers(); 
        if (timers != null) 
        { 
            for(Timer t : timers) {
                t.cancel();
            }
        } 
}

Salu2.

PD: Usa las etiquetas Geshi para colocar código.

Muchas gracias por tu ayuda, pero tengo algunas dudas de implementación.

Si quisiera controlar el timeout de un método como el anterior, ¿sería algo así?

Código (java) [Seleccionar] Expandir



import java.io.Serializable;
import javax.annotation.Resource;
import javax.ejb.Stateless;
import javax.ejb.Timeout;
import javax.ejb.Timer;
import javax.ejb.TimerService;


@Stateless
public class TimeoutRespuesta {


@Resource TimerService timer;

public void doSomething(Object obj) {
    timer.createTimer(1000, 1000, (Serializable) obj);
}

@Timeout void doOtherThing(Timer timer)  {
    Object obj = (Object) timer.getInfo();

}

public int sum(int i){
return i;
}

}



Código (java) [Seleccionar] Expandir


import timeout.TimeoutRespuesta;


public class Suma {

public static void main(String[] args) {


int res = (new TimeoutRespuesta()).sum(sumar(1,2));

System.out.println(res);

}

public static int sumar(int a, int b){
return a+b;
}
}





Gracias.

[import javax.ejb.Stateless;import javax.ejb.Timeout; @Statelesspublic class TimeoutRespuesta { @Timeout public int sumador(int resultado){ return resultado; }}]

Hola qué tal, estoy intentando controlar un TimeOut mediante un EJB.


Ésta es la clase que tiene mi EJB:

import javax.ejb.Stateless;
import javax.ejb.Timeout;

@Stateless
public class TimeoutRespuesta {
   

    @Timeout
    public int sumador(int resultado){

        return resultado;

    }
}



Exporto el EJB mediante un .jar, me creo un proyecto Java y me creo una clase de pruebas:


public class Suma {

    public static void main(String[] args) {
       
       
        int res = (new TimeoutRespuesta()).sumador(sumar(1,2));
       
        System.out.println(res);
       
    }

    public static int sumar(int a, int b){
       
        return a+b;
    }
}


Aunque es un ejemplo muy sencillo, pero mi idea es controlar el Timeout mediante EJB, si fuese un método más complejo que no deje la aplicación bloqueada, que salte el Timeout del EJB y salga del método.

¿Estaría bien así?.

¿Cuál es el tiempo por defecto del Timeout del EJB?.


Un saludo y muchas gracias.

Hola a todos, estoy intentando descargar videos de www.joost.com pero los programas que me bajé no consiguieron bajarme videos de esa página web. ¿Alguien sabe cómo descargar videos de esa página web?.

Saludos.

Hola a todos, resulta que quiero bajarme videos de yahoo me metí en google y me bajé varios programas recomendados, pero con ninguno conseguí bajarme videos de yahoo. ¿Alguien sabe de algún programa que sepa que funcione para bajar videos de yahoo?.

Saludos y muchas gracias.