Add wso2bpel-ext code
[vfc/nfvo/wfengine.git] / wso2bpel-ext / wso2bpel-core / wso2bpel-mgr / src / main / java / org / openo / carbon / bpel / externalservice / msb / MicroserviceBusConsumer.java
1 /**
2  * Copyright 2016 [ZTE] and others.
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.openo.carbon.bpel.externalservice.msb;
17
18 import com.eclipsesource.jaxrs.consumer.ConsumerFactory;
19
20 import org.glassfish.jersey.client.ClientConfig;
21 import org.openo.carbon.bpel.common.Config;
22 import org.openo.carbon.bpel.externalservice.entity.ServiceRegisterEntity;
23 import org.slf4j.Logger;
24 import org.slf4j.LoggerFactory;
25
26
27
28
29 public class MicroserviceBusConsumer {
30   private static final Logger LOG = LoggerFactory.getLogger(MicroserviceBusConsumer.class);
31
32   /**
33    * @param entity service entity
34    * @return register service to msb success return true, else return false.
35    */
36   public static boolean registerService(ServiceRegisterEntity entity) {
37     ClientConfig config = new ClientConfig();
38     try {
39       MicroserviceBusRest resourceserviceproxy = ConsumerFactory.createConsumer(
40           Config.getConfigration().getMsbServerAddr(), config, MicroserviceBusRest.class);
41       resourceserviceproxy.registerServce("false", entity);
42     } catch (Exception error) {
43       LOG.error("microservice register failed!" + error.getMessage());
44       return false;
45     }
46     return true;
47   }
48 }