gerrit.onap Code Review - ccsdk/features.git/blob

   1 package org.onap.ccsdk.features.lib.doorman.impl;
   2
   3 import java.util.Map;
   4 import org.onap.ccsdk.features.lib.doorman.MessageClassifier;
   5 import org.onap.ccsdk.features.lib.doorman.MessageInterceptor;
   6 import org.onap.ccsdk.features.lib.doorman.MessageInterceptorFactory;
   7 import org.onap.ccsdk.features.lib.doorman.MessageProcessor;
   8 import org.onap.ccsdk.features.lib.doorman.MessageQueueHandler;
   9 import org.onap.ccsdk.features.lib.doorman.dao.MessageDao;
  10 import org.onap.ccsdk.features.lib.rlock.LockHelper;
  11
  12 public class MessageInterceptorFactoryImpl implements MessageInterceptorFactory {
  13
  14         private MessageClassifier messageClassifier;
  15         private Map<String, MessageQueueHandler> handlerMap;
  16         private MessageProcessor messageProcessor;
  17         private MessageDao messageDao;
  18
  19         private LockHelper lockHelper;
  20         private int lockTimeout; // in seconds
  21
  22         @Override
  23         public MessageInterceptor create() {
  24                 MessageInterceptorImpl mi = new MessageInterceptorImpl();
  25                 mi.setMessageClassifier(messageClassifier);
  26                 mi.setHandlerMap(handlerMap);
  27                 mi.setMessageProcessor(messageProcessor);
  28                 mi.setMessageDao(messageDao);
  29                 mi.setLockHelper(lockHelper);
  30                 mi.setLockTimeout(lockTimeout);
  31                 return mi;
  32         }
  33
  34         public void setMessageDao(MessageDao messageDao) {
  35                 this.messageDao = messageDao;
  36         }
  37
  38         public void setLockHelper(LockHelper lockHelper) {
  39                 this.lockHelper = lockHelper;
  40         }
  41
  42         public void setLockTimeout(int lockTimeout) {
  43                 this.lockTimeout = lockTimeout;
  44         }
  45
  46         public void setMessageClassifier(MessageClassifier messageClassifier) {
  47                 this.messageClassifier = messageClassifier;
  48         }
  49
  50         public void setHandlerMap(Map<String, MessageQueueHandler> handlerMap) {
  51                 this.handlerMap = handlerMap;
  52         }
  53
  54         public void setMessageProcessor(MessageProcessor messageProcessor) {
  55                 this.messageProcessor = messageProcessor;
  56         }
  57 }