ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/messagemgr/MessageChannelFactory.java

   1 /**
   2  * Copyright 2017 BOCO Corporation.  CMCC Technologies Co., Ltd
   3  *
   4  * Licensed under the Apache 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.apache.org/licenses/LICENSE-2.0
   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.onap.vfc.nfvo.emsdriver.messagemgr;
  17
  18 import java.util.HashMap;
  19 import java.util.Map;
  20
  21 public class MessageChannelFactory {
  22
  23         public static Map<String, MessageChannel> map = new HashMap<String, MessageChannel>();
  24
  25         public synchronized static MessageChannel getMessageChannel(String key,Integer size){
  26                 if(map.get(key) != null){
  27                         return map.get(key);
  28                 }
  29                 MessageChannel mc = null;
  30                 if(size != null && size > 0){
  31                         mc = new MessageChannel(size);
  32                 }else{
  33                         mc = new MessageChannel();
  34                 }
  35
  36                 map.put(key, mc);
  37                 return mc;
  38         }
  39
  40         public synchronized static MessageChannel getMessageChannel(String key){
  41                 if(map.get(key) != null){
  42                         return map.get(key);
  43                 }
  44                 MessageChannel mc = new MessageChannel();
  45
  46                 map.put(key, mc);
  47                 return mc;
  48         }
  49
  50         public synchronized static boolean destroyMessageChannel(String key){
  51                 if(map.get(key) != null){
  52                         map.remove(key);
  53                         return true;
  54                 }
  55                 return false;
  56         }
  57
  58         public synchronized static void clean(){
  59                 map.clear();
  60         }
  61 }