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 import javax.jms.ConnectionFactory;
  13 import javax.jms.Queue;
  14 import javax.jms.Connection;
  15 import javax.jms.Session;
  16 import javax.jms.MessageProducer;
  17 import javax.jms.TextMessage;
  18 @Singleton
  19 @Startup
  20 public class Scheduler {
  21     @Resource(mappedName="jms/ConnectionFactory")
  22     private ConnectionFactory connectionFactory;
  23     @Resource(mappedName="jms/Queuex")
  24     private Queue queue;    
  25     
  26     @Resource
  27     private TimerService timerService;
  28 
  29     @PostConstruct
  30     private void postConstruct() {    
  31         TimerConfig config = new TimerConfig("OneMinutePassed", false);
  32         ScheduleExpression se = new ScheduleExpression();
  33         se.minute("*");
  34         se.hour("*");
  35         timerService.createCalendarTimer(se, config);
  36     }
  37 
  38     public String addSchedule(String second,String minute,String hour,String info){
  39         TimerConfig config = new TimerConfig(info, false);
  40         ScheduleExpression se = new ScheduleExpression();
  41         se.second(second);
  42         se.minute(minute);
  43         se.hour(hour);
  44         timerService.createCalendarTimer(se, config);        
  45         return "Added " + info;
  46     }    
  47     
  48     @Schedule(minute="*/5", hour="*")
  49     private void eachFiveMinutes(){
  50         System.out.println("Called each five minute");
  51     }    
  52 
  53     @Timeout
  54     public void timeout(Timer timer) {
  55         if ("OneMinutePassed".equals(timer.getInfo())) {    
  56             System.out.println("OneMinutePassed !!!");
  57             /*for(Timer t : timerService.getTimers() ){
  58                 System.out.println(">>> "+ t.getInfo() );
  59             }*/
  60         }else{
  61             System.out.println("!!! "+ timer.getInfo() );
  62             // send jms message
  63             try{
  64                 Connection connection = connectionFactory.createConnection();
  65                 Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
  66                 MessageProducer mp = session.createProducer(queue);
  67                 TextMessage message = session.createTextMessage();
  68                 message.setText( timer.getInfo().toString() );
  69                 mp.send(message);
  70                 mp.close();
  71                 session.close();
  72                 connection.close();                
  73             }catch(Exception ex){ ex.printStackTrace(); }
  74         }        
  75     }    
  76 }

   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 import javax.ejb.MessageDriven;
   2 import javax.jms.Message;
   3 import javax.jms.TextMessage;
   4 import javax.persistence.PersistenceContext;
   5 import javax.persistence.EntityManager;
   6 @MessageDriven(mappedName="jms/Queuex")
   7 public class TestMDB{
   8     @PersistenceContext(unitName="puMysql")
   9     EntityManager em;
  10     
  11     public void onMessage(Message inMessage) {
  12         try{
  13             String text = ( (TextMessage) inMessage).getText() ;
  14             System.out.println( text );     
  15             MessageEntity me = new MessageEntity();
  16             me.setMessage( text  );
  17             me.setCreationDate( new java.util.Date() );
  18             em.persist(me);
  19         }catch(Exception ex){
  20             ex.printStackTrace();
  21         }
  22     }
  23 }

   1 import java.util.Date;
   2 import javax.persistence.Id;
   3 import javax.persistence.Entity;
   4 import javax.persistence.Column;
   5 import javax.persistence.GeneratedValue;
   6 import javax.persistence.GenerationType;
   7 import javax.persistence.TemporalType;
   8 import javax.persistence.Temporal;
   9 @Entity
  10 public class MessageEntity{
  11     @Id
  12     @GeneratedValue(strategy = GenerationType.IDENTITY) 
  13     private long id;
  14     @Column
  15     @Temporal(TemporalType.TIMESTAMP) 
  16     private Date creationDate;
  17     @Column
  18     private String message;
  19     
  20     public long getId(){return this.id;}
  21     public void setId(long id){ this.id=id;}
  22 
  23     public Date getCreationDate(){return this.creationDate;}
  24     public void setCreationDate(Date creationDate){ this.creationDate=creationDate;}
  25     
  26     public String getMessage(){return this.message;}
  27     public void setMessage(String message){ this.message=message;}        
  28 }

   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 }