View Javadoc

1   /**
2    * Copyright 2005-2015 The Kuali Foundation
3    *
4    * Licensed under the Educational Community License, Version 2.0 (the "License");
5    * you may not use this file except in compliance with the License.
6    * You may obtain a copy of the License at
7    *
8    * http://www.opensource.org/licenses/ecl2.php
9    *
10   * Unless required by applicable law or agreed to in writing, software
11   * distributed under the License is distributed on an "AS IS" BASIS,
12   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13   * See the License for the specific language governing permissions and
14   * limitations under the License.
15   */
16  package org.kuali.rice.kcb.service.impl;
17  
18  import java.util.ArrayList;
19  import java.util.Collection;
20  import java.util.HashMap;
21  import java.util.HashSet;
22  import java.util.Set;
23  import java.util.Map.Entry;
24  
25  import org.apache.commons.lang.StringUtils;
26  import org.apache.log4j.Logger;
27  import org.kuali.rice.core.api.exception.RiceIllegalArgumentException;
28  import org.kuali.rice.kcb.bo.MessageDelivery;
29  import org.kuali.rice.kcb.deliverer.MessageDeliverer;
30  import org.kuali.rice.kcb.deliverer.impl.AOLInstantMessageDeliverer;
31  import org.kuali.rice.kcb.deliverer.impl.EmailMessageDeliverer;
32  import org.kuali.rice.kcb.deliverer.impl.MockMessageDeliverer;
33  import org.kuali.rice.kcb.deliverer.impl.SMSMessageDeliverer;
34  import org.kuali.rice.kcb.service.MessageDelivererRegistryService;
35  
36  /**
37   * MessageDelivererRegistryService implementation - for now we use a HashMap to do this registration, in the future we'll use resource loading.
38   * @author Kuali Rice Team (rice.collab@kuali.org)
39   */
40  public class MessageDelivererRegistryServiceImpl implements MessageDelivererRegistryService {
41      private static Logger LOG = Logger.getLogger(MessageDelivererRegistryServiceImpl.class);
42  
43      // holds information about the registered deliverer types
44      private HashMap<String, Class<? extends MessageDeliverer>> messageDelivererTypes;
45  
46      /**
47       * Constructs an instance of the MessageDelivererRegistryServiceImpl class and sets up the 
48       * registered MessageDeliverers in the system. These are the hardcoded message deliverers 
49       * that we support out of the box.
50       * 
51       * TODO: we'll need to implement a plugin registry discovery mechanism long term.
52       */
53      public MessageDelivererRegistryServiceImpl() {
54          //KEWActionListMessageDeliverer kewActionList = new KEWActionListMessageDeliverer();
55          EmailMessageDeliverer email = new EmailMessageDeliverer();
56          SMSMessageDeliverer sms = new SMSMessageDeliverer();
57          AOLInstantMessageDeliverer aim = new AOLInstantMessageDeliverer();
58          MockMessageDeliverer mock = new MockMessageDeliverer();
59  
60          messageDelivererTypes = new HashMap<String, Class<? extends MessageDeliverer>>(4);
61          //messageDelivererTypes.put(kewActionList.getName(), kewActionList.getClass());
62          messageDelivererTypes.put(email.getName().toLowerCase(), email.getClass());
63          messageDelivererTypes.put(sms.getName().toLowerCase(), sms.getClass());
64          messageDelivererTypes.put(aim.getName().toLowerCase(), aim.getClass());
65          messageDelivererTypes.put(mock.getName().toLowerCase(), mock.getClass());
66      }
67  
68      /**
69       * @see org.kuali.rice.kcb.service.MessageDelivererRegistryService#getAllDelivererTypes()
70       */
71      public Collection<String> getAllDelivererTypes() {
72          Collection<MessageDeliverer> deliverers = getAllDeliverers();
73          Set<String> types = new HashSet<String>(deliverers.size());
74          for (MessageDeliverer deliverer: deliverers) {
75              types.add(deliverer.getName().toLowerCase());
76          }
77          return types;
78      }
79  
80      /**
81       * Implements by constructing instances of each registered class and adding to an ArrayList that
82       * gets passed back to the calling method.
83       * @see MessageDelivererRegistryService#getAllDelivererTypes()
84       */
85      public Collection<MessageDeliverer> getAllDeliverers() {
86          ArrayList<MessageDeliverer>  delivererTypes = new ArrayList<MessageDeliverer>();
87  
88          Set<Entry<String, Class<? extends MessageDeliverer>>> registeredTypes = messageDelivererTypes.entrySet();
89  
90          // iterate over each type and add an instance of each to the returning ArrayList
91          for(Entry<String, Class<? extends MessageDeliverer>> entry: registeredTypes ) {
92              try {
93                  delivererTypes.add(entry.getValue().newInstance());
94              } catch (InstantiationException e) {
95                  LOG.error(e.getStackTrace());
96              } catch (IllegalAccessException e) {
97                  LOG.error(e.getStackTrace());
98              }
99          }
100 
101         return delivererTypes;
102     }
103 
104     /**
105      * Implements by calling getDelivererByName for the delivery type name within the messageDelivery object.
106      * @see MessageDelivererRegistryService#getDeliverer(MessageDelivery)
107      */
108     public MessageDeliverer getDeliverer(MessageDelivery messageDelivery) {
109         if (messageDelivery == null) {
110             throw new RiceIllegalArgumentException("messageDelivery is null");
111         }
112 
113         MessageDeliverer nmd = getDelivererByName(messageDelivery.getDelivererTypeName());
114         if (nmd == null) {
115             LOG.error("The message deliverer type ('" + messageDelivery.getDelivererTypeName() + "') " +
116                       "associated with message delivery id='" + messageDelivery.getId() + "' was not found in the message deliverer registry.  This deliverer " +
117                       "plugin is not in the system.");
118         }
119         return nmd;
120     }
121 
122     /**
123      * Implements by doing a key lookup in the hashmap that acts as the deliverer plugin registry.  The deliverer name is the key in the hashmap for 
124      * all registered deliverers.
125      * @see MessageDelivererRegistryService#getDelivererByName(String)
126      */
127     public MessageDeliverer getDelivererByName(String messageDelivererName) {
128         if (StringUtils.isBlank(messageDelivererName)) {
129             throw new RiceIllegalArgumentException("messageDelivererName is null or blank");
130         }
131 
132         Class<? extends MessageDeliverer> clazz = messageDelivererTypes.get(messageDelivererName.toLowerCase());
133 
134         if(clazz == null) {
135             LOG.error("The message deliverer type ('" + messageDelivererName + "') " +
136                       " was not found in the message deliverer registry.  This deliverer " +
137                       "plugin is not in the system.");
138             return null;
139         }
140 
141         MessageDeliverer messageDeliverer = null;
142         try {
143             messageDeliverer = clazz.newInstance();
144         } catch (InstantiationException e) {
145             LOG.error(e.getStackTrace());
146         } catch (IllegalAccessException e) {
147             LOG.error(e.getStackTrace());
148         }
149 
150         return messageDeliverer;
151     }
152 }