Java by API/javax.ejb/Timeout

Материал из Java эксперт
Перейти к: навигация, поиск

javax.ejb.Timeout

   <source lang="java">
 

File: Employee.java import javax.persistence.Entity; import javax.persistence.EntityListeners; import javax.persistence.GeneratedValue; import javax.persistence.Id; import javax.persistence.PostRemove; @Entity public class Employee implements java.io.Serializable {

 private int id;
 private String firstName;
 private String lastName;
 @Id
 @GeneratedValue
 public int getId() {
   return id;
 }
 @PostRemove
 public void postRemove()
 {
    System.out.println("@PostRemove");
 }
 public void setId(int id) {
   this.id = id;
 }
 public String getFirstName() {
   return firstName;
 }
 public void setFirstName(String first) {
   this.firstName = first;
 }
 public String getLastName() {
   return lastName;
 }
 public void setLastName(String last) {
   this.lastName = last;
 }

}

File: EmployeeService.java import java.util.Date; import javax.annotation.Resource; import javax.ejb.Stateless; import javax.ejb.Timeout; @Stateless public class EmployeeService implements EmployeeServiceLocal, EmployeeServiceRemote {

 @Resource
 javax.ejb.TimerService timerService;
 public EmployeeService() {
 }
 public void doAction() {
   String item = "item 1";
   for (Object obj : timerService.getTimers()) {
     javax.ejb.Timer timer = (javax.ejb.Timer) obj;
     String scheduled = (String) timer.getInfo();
     if (scheduled.equals(item)) {
       timer.cancel();
     }
   }
   timerService.createTimer(new Date(System.currentTimeMillis() + 1000), item);
 }
 @Timeout
 public void maintenance(javax.ejb.Timer timer) {
   System.out.println("TIMEOUT METHOD CALLED");
   String scheduled = (String) timer.getInfo();
   System.out.println(scheduled);
 }

}

File: EmployeeServiceLocal.java

import java.util.Collection; import javax.ejb.Local; @Local public interface EmployeeServiceLocal {

   public void doAction();

}

File: EmployeeServiceRemote.java


import java.util.Collection; import javax.ejb.Remote; @Remote public interface EmployeeServiceRemote{

 public void doAction();  

}

File: jndi.properties java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory java.naming.factory.url.pkgs=org.jboss.naming:org.jnp.interfaces java.naming.provider.url=localhost:1099

File: Main.java import java.util.Date; import javax.naming.InitialContext;

public class Main {

 public static void main(String[] a) throws Exception {
   EmployeeServiceRemote service = null;
   // Context compEnv = (Context) new InitialContext().lookup("java:comp/env");
   // service = (HelloService)new InitialContext().lookup("java:comp/env/ejb/HelloService");
   service = (EmployeeServiceRemote) new InitialContext().lookup("EmployeeService/remote");
   
   


   service.doAction();
 }

}



 </source>