5e0acf4da90648e08598c7f48c8925d9f7f58d02
[vfc/nfvo/catalog.git] /
1 /**\r
2  * Copyright 2016 [ZTE] and others.\r
3  *\r
4  * Licensed under the Apache License, Version 2.0 (the "License");\r
5  * you may not use this file except in compliance with the License.\r
6  * You may obtain a copy of the License at\r
7  *\r
8  *     http://www.apache.org/licenses/LICENSE-2.0\r
9  *\r
10  * Unless required by applicable law or agreed to in writing, software\r
11  * distributed under the License is distributed on an "AS IS" BASIS,\r
12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
13  * See the License for the specific language governing permissions and\r
14  * limitations under the License.\r
15  */\r
16 package org.openo.commontosca.catalog.externalservice.msb;\r
17 \r
18 \r
19 import org.glassfish.jersey.client.ClientConfig;\r
20 import org.openo.commontosca.catalog.common.Config;\r
21 import org.slf4j.Logger;\r
22 import org.slf4j.LoggerFactory;\r
23 \r
24 import com.eclipsesource.jaxrs.consumer.ConsumerFactory;\r
25 \r
26 /**\r
27  * @author 10159474\r
28  *\r
29  */\r
30 public class MicroserviceBusConsumer {\r
31     private static final Logger LOG = LoggerFactory.getLogger(MicroserviceBusConsumer.class);\r
32 \r
33     public static boolean registerService(ServiceRegisterEntity entity) {\r
34         ClientConfig config = new ClientConfig();\r
35         try {\r
36             MicroserviceBusRest resourceserviceproxy = ConsumerFactory.createConsumer(\r
37                     Config.getConfigration().getMsbServerAddr(),config, MicroserviceBusRest.class);\r
38             resourceserviceproxy.registerServce("false", entity);\r
39         } catch (Exception e) {\r
40             LOG.error("microservice register failed!" + e.getMessage());\r
41             return false;\r
42         }\r
43         return true;\r
44     }\r
45 }\r