[jboss-cvs] jboss-mail/src/calendar/calendarejb/src/java/org/jboss/mail/calendar/mdb ...

[Aron Sogor]

  User: asogor  
  Date: 06/07/13 23:52:17

  Modified:    src/calendar/calendarejb/src/java/org/jboss/mail/calendar/mdb 
                        MailResposeHandlerMDB.java
  Log:
  Start adding PLAN and SCHEDULE mail alias support
  
  Revision  Changes    Path
  1.4       +35 -16    jboss-mail/src/calendar/calendarejb/src/java/org/jboss/mail/calendar/mdb/MailResposeHandlerMDB.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: MailResposeHandlerMDB.java
  ===================================================================
  RCS file: /cvsroot/jboss/jboss-mail/src/calendar/calendarejb/src/java/org/jboss/mail/calendar/mdb/MailResposeHandlerMDB.java,v
  retrieving revision 1.3
  retrieving revision 1.4
  diff -u -b -r1.3 -r1.4
  --- MailResposeHandlerMDB.java	6 Jul 2006 23:11:43 -0000	1.3
  +++ MailResposeHandlerMDB.java	14 Jul 2006 03:52:17 -0000	1.4
  @@ -13,17 +13,20 @@
   
   import org.jboss.mail.calendar.data.Invite;
   import org.jboss.mail.calendar.data.User;
  -import org.jboss.mail.calendar.eventbus.MailResponse;
  +import org.jboss.mail.calendar.eventbus.mail.MailRequest;
  +import org.jboss.mail.calendar.eventbus.mail.PlanEvent;
  +import org.jboss.mail.calendar.eventbus.mail.ScheduleEvent;
  +import org.jboss.mail.calendar.eventbus.mail.StatusChange;
   import org.jboss.mail.calendar.interfaces.AddressManagerLocal;
   import org.jboss.mail.calendar.interfaces.AddressManagerUtil;
   import org.jboss.mail.calendar.interfaces.ScheduleManagerLocal;
   import org.jboss.mail.calendar.interfaces.ScheduleManagerUtil;
   
   /**
  - * Maile event response Handler takes
  + * Mail event response Handler takes
    * 
    * @author Aron Sogor
  - * @version $Revision: 1.3 $
  + * @version $Revision: 1.4 $
    * 
    * @ejb.bean name="/ejb/reporting/MailResposeHandlerMDB"
    *           acknowledge-mode="Auto-acknowledge"
  @@ -40,35 +43,51 @@
   public class MailResposeHandlerMDB extends BaseUserNotificationMDB {
   
       public void onMessage(Message aMessage) {
  -        MailResponse response = null;
  +        MailRequest response = null;
           try {
  -            response = (MailResponse) ((ObjectMessage) aMessage).getObject();
  +            response = (MailRequest) ((ObjectMessage) aMessage).getObject();
  +            if(response instanceof ScheduleEvent)
  +            	processScheduleEvent((ScheduleEvent)response);
  +            if(response instanceof PlanEvent)
  +            	processPlanEvent((PlanEvent)response);
  +            if(response instanceof StatusChange)
  +            	processStatusChange((StatusChange)response);
               log.info("Received user response + " + response);
           } catch (JMSException ex) {
               log.error("Problem getting message in : "
                       + MailResposeHandlerMDB.class.getName(), ex);
               return;
           }
  +    }
  +
  +    public void ejbRemove() throws EJBException {
  +
  +    }
  +
  +    public void processScheduleEvent(ScheduleEvent event){
  +    	
  +    }
  +
  +    public void processPlanEvent(PlanEvent event){
  +    	
  +    }
  +    
  +    public void processStatusChange(StatusChange event){
           try {
               AddressManagerLocal addLocal = AddressManagerUtil.getLocalHome()
                       .create();
               ScheduleManagerLocal schLocal = ScheduleManagerUtil.getLocalHome()
               .create();
  -            User user = addLocal.getUserByEmailAddress(response.getActor());
  -            Invite[] invites = schLocal.listInvites(new String[] { response
  +            User user = addLocal.getUserByEmailAddress(event.getActor());
  +            Invite[] invites = schLocal.listInvites(new String[] { event
                       .getEventGUID() }, user.getUserName());
               for (int i = 0; i < invites.length; i++) {
  -                invites[i].setStatus(response.getAction());
  +                invites[i].setStatus(event.getAction());
                   schLocal.updateInvite(invites[i], user.getUserName());
               }
           } catch (Exception e) {
  -            log.error("Failed to update event:" + response.getEventGUID() + " status:"
  -                    + " for user:" + response.getActor() ,e);
  -        }
  +            log.error("Failed to update event:" + event.getEventGUID() + " status:"
  +                    + " for user:" + event.getActor() ,e);
       }
  -
  -    public void ejbRemove() throws EJBException {
  -
       }
  -
   }