JEE

   1 package org.allowed.bitarus;
   2 import javax.ejb.Singleton;
   3 import javax.ejb.Schedule;
   4 import javax.ejb.ScheduleExpression;
   5 import javax.annotation.Resource;
   6 import javax.ejb.Timeout;
   7 import javax.ejb.TimerConfig;
   8 import javax.ejb.TimerService;
   9 import javax.ejb.Timer;
  10 import javax.annotation.PostConstruct;
  11 import javax.ejb.Startup;
  12 @Singleton
  13 @Startup
  14 public class Scheduler {
  15     @Resource
  16     private TimerService timerService;
  17 
  18     @PostConstruct
  19     private void postConstruct() {    
  20         TimerConfig config = new TimerConfig("OneMinutePassed", false);
  21         ScheduleExpression se = new ScheduleExpression();
  22         se.minute("*");
  23         se.hour("*");
  24         timerService.createCalendarTimer(se, config);
  25     }
  26 
  27     public String addSchedule(String second,String minute,String hour,String info){
  28         TimerConfig config = new TimerConfig(info, false);
  29         ScheduleExpression se = new ScheduleExpression();
  30         se.second(second);
  31         se.minute(minute);
  32         se.hour(hour);
  33         timerService.createCalendarTimer(se, config);        
  34         return "Added " + info;
  35     }    
  36     
  37     @Schedule(minute="*/5", hour="*")
  38     private void eachFiveMinutes(){
  39         System.out.println("Called each five minute");
  40     }    
  41 
  42     @Timeout
  43     public void timeout(Timer timer) {
  44         if ("OneMinutePassed".equals(timer.getInfo())) {    
  45             System.out.println("OneMinutePassed !!!");
  46             /*for(Timer t : timerService.getTimers() ){
  47                 System.out.println(">>> "+ t.getInfo() );
  48             }*/
  49         }else{
  50             System.out.println("!!! "+ timer.getInfo() );
  51         }        
  52     }    
  53 }

   1 package org.allowed.bitarus;
   2 import javax.ejb.Remote;
   3 
   4 @Remote
   5 public interface ScheduleRemote{
   6     String addSchedule(String second,String minute,String hour,String info);
   7 }

   1 package org.allowed.bitarus;
   2 import javax.ejb.Stateless;
   3 import javax.jws.WebMethod;
   4 import javax.jws.WebService;
   5 import javax.ejb.ScheduleExpression;
   6 import javax.annotation.Resource;
   7 import javax.ejb.TimerService;
   8 import javax.ejb.TimerConfig;
   9 import javax.ejb.EJB;
  10 @Stateless
  11 @WebService
  12 public class ScheduleWS implements ScheduleRemote{
  13     @Resource
  14     private TimerService timerService;    
  15     @EJB
  16     Scheduler sc;
  17     
  18     @WebMethod
  19     public String addSchedule(String second,String minute,String hour,String info){
  20         return sc.addSchedule(second, minute, hour, info);
  21     }
  22 }

   1 package org.allowed.bitarus;
   2 import com.sun.messaging.ConnectionConfiguration;
   3 import com.sun.messaging.ConnectionFactory;
   4 import com.sun.messaging.Queue;
   5 import javax.jms.Connection;
   6 import javax.jms.JMSException;
   7 import javax.jms.Message;
   8 import javax.jms.MessageProducer;
   9 import javax.jms.Session;
  10 
  11 public class JmsClient {
  12     
  13     public static void main( String[] args ) 
  14     {
  15         try{
  16             ConnectionFactory connFactory = new ConnectionFactory();
  17             connFactory.setProperty(ConnectionConfiguration.imqAddressList, "127.0.0.1:7676");
  18             Queue q = new Queue("Queuex"); // JNDI jms/queue physical dest name Queuex      
  19             Connection connection = connFactory.createConnection(); 
  20             Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); 
  21             MessageProducer producer = session.createProducer(q); 
  22             Message message = session.createTextMessage("Bitarus test message");
  23             producer.send(message);
  24             System.out.println("After send message");
  25         }catch(Exception ex){
  26             ex.printStackTrace();             
  27         }
  28         
  29         System.out.println("End");
  30         System.exit(0);
  31     }
  32 }