Java Action类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.openbaton.catalogue.nfvo.Action类的典型用法代码示例。如果您正苦于以下问题：Java Action类的具体用法？Java Action怎么用？Java Action使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

Action类属于org.openbaton.catalogue.nfvo包，在下文中一共展示了Action类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: setStatus

import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
/**
 * Handles the callback by the NFVO when the deploy is finished (or failed)
 *
 * @param evt OpenbatonEvent, payload of the POST
 * @param id occi Identifier of the stack, set in deployAndProvision
 * @throws SDKException
 */
@RequestMapping(value = "{id}", method = RequestMethod.POST, consumes = MediaType.APPLICATION_JSON_VALUE)
@ResponseStatus(HttpStatus.OK)
public void setStatus(@RequestBody OpenbatonEvent evt, @PathVariable("id") String id) throws SDKException {
    Stack stack = stacks.get(id);
    log.debug("Received event for nsr " + stack.getNsrId() + " with occiId " + id);

    if (evt.getAction().equals(Action.INSTANTIATE_FINISH)) {
        log.debug("Instantiate finished");
        stack.setVirtualNFRs(obManager.statusOfNSR(stack.getNsrId()));
        stack.setStatus("CREATE_COMPLETE");
    } else if (evt.getAction().equals(Action.ERROR)) {
        log.debug("Error on instantiate");
        stack.setStatus("CREATE_FAILED");
    }

    log.debug("Deleting listening-events");
    nfvoRequestor.getEventAgent().delete(stack.getReceivedEndpointCreation().getId());
    nfvoRequestor.getEventAgent().delete(stack.getReceivedEndpointError().getId());
}

开发者ID:MobileCloudNetworking，项目名称:OpenBaton-OCCI，代码行数:27，代码来源:OcciControler.java

示例2: activate

import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
/**
 * Activates autoscaling for the passed NSR
 *
 * @param msg : NSR in payload to add for autoscaling
 */
@RequestMapping(
  value = "INSTANTIATE_FINISH",
  method = RequestMethod.POST,
  consumes = MediaType.APPLICATION_JSON_VALUE,
  produces = MediaType.APPLICATION_JSON_VALUE
)
@ResponseStatus(HttpStatus.CREATED)
public void activate(@RequestBody String msg)
    throws NotFoundException, VimException, SDKException {
  log.trace("msg=" + msg);
  JsonParser jsonParser = new JsonParser();
  JsonObject json = jsonParser.parse(msg).getAsJsonObject();
  Gson mapper = new GsonBuilder().create();
  Action action = mapper.fromJson(json.get("action"), Action.class);
  log.trace("ACTION=" + action);
  NetworkServiceRecord nsr = mapper.fromJson(json.get("payload"), NetworkServiceRecord.class);
  log.trace("NSR=" + nsr);
  elasticityManagement.activate(nsr.getProjectId(), nsr.getId());
}

开发者ID:openbaton，项目名称:autoscaling-engine，代码行数:25，代码来源:RestElasticityManagementInterface.java

示例3: deactivate

import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
/**
 * Deactivates autoscaling for the passed NSR
 *
 * @param msg : NSR in payload to add for autoscaling
 */
@RequestMapping(
  value = "RELEASE_RESOURCES_FINISH",
  method = RequestMethod.POST,
  consumes = MediaType.APPLICATION_JSON_VALUE,
  produces = MediaType.APPLICATION_JSON_VALUE
)
@ResponseStatus(HttpStatus.CREATED)
public void deactivate(@RequestBody String msg) throws NotFoundException {
  log.trace("msg=" + msg);
  JsonParser jsonParser = new JsonParser();
  JsonObject json = jsonParser.parse(msg).getAsJsonObject();
  Gson mapper = new GsonBuilder().create();
  Action action = mapper.fromJson(json.get("action"), Action.class);
  log.trace("ACTION=" + action);
  NetworkServiceRecord nsr = mapper.fromJson(json.get("payload"), NetworkServiceRecord.class);
  log.trace("NSR=" + nsr);
  for (VirtualNetworkFunctionRecord vnfr : nsr.getVnfr()) {
    elasticityManagement.deactivate(nsr.getProjectId(), nsr.getId(), vnfr);
  }
}

开发者ID:openbaton，项目名称:autoscaling-engine，代码行数:26，代码来源:RestElasticityManagementInterface.java

示例4: stop

import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
/**
 * Stops autoscaling for the passed NSR
 *
 * @param msg : NSR in payload to add for autoscaling
 */
@RequestMapping(
  value = "ERROR",
  method = RequestMethod.POST,
  consumes = MediaType.APPLICATION_JSON_VALUE,
  produces = MediaType.APPLICATION_JSON_VALUE
)
@ResponseStatus(HttpStatus.CREATED)
public void stop(@RequestBody String msg) throws NotFoundException {
  log.trace("msg=" + msg);
  JsonParser jsonParser = new JsonParser();
  JsonObject json = jsonParser.parse(msg).getAsJsonObject();
  Gson mapper = new GsonBuilder().create();
  Action action = mapper.fromJson(json.get("action"), Action.class);
  log.trace("ACTION=" + action);
  //        try {
  //            NetworkServiceRecord nsr = mapper.fromJson(json.get("payload"), NetworkServiceRecord.class);
  //            log.debug("NSR=" + nsr);
  //            elasticityManagement.deactivate(nsr);
  //        } catch (NullPointerException e) {
  //            VirtualNetworkFunctionRecord vnfr = mapper.fromJson(json.get("payload"), VirtualNetworkFunctionRecord.class);
  //            log.debug("vnfr=" + vnfr);
  //            elasticityManagement.deactivate(vnfr);
  //        }
}

开发者ID:openbaton，项目名称:autoscaling-engine，代码行数:30，代码来源:RestElasticityManagementInterface.java

示例5: stop

import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
/**
 * Stops autoscaling for the passed NSR
 *
 * @param msg : NSR in payload to add for autoscaling
 */
@RequestMapping(
  value = "ERROR",
  method = RequestMethod.POST,
  consumes = MediaType.APPLICATION_JSON_VALUE,
  produces = MediaType.APPLICATION_JSON_VALUE
)
@ResponseStatus(HttpStatus.CREATED)
public void stop(@RequestBody String msg) throws NotFoundException {
  log.debug("========================");
  log.debug("msg=" + msg);
  JsonParser jsonParser = new JsonParser();
  JsonObject json = jsonParser.parse(msg).getAsJsonObject();
  Gson mapper = new GsonBuilder().create();
  Action action = mapper.fromJson(json.get("action"), Action.class);
  log.debug("ACTION=" + action);
  //        try {
  //            NetworkServiceRecord nsr = mapper.fromJson(json.get("payload"), NetworkServiceRecord.class);
  //            log.debug("NSR=" + nsr);
  //            elasticityManagement.deactivate(nsr);
  //        } catch (NullPointerException e) {
  //            VirtualNetworkFunctionRecord vnfr = mapper.fromJson(json.get("payload"), VirtualNetworkFunctionRecord.class);
  //            log.debug("vnfr=" + vnfr);
  //            elasticityManagement.deactivate(vnfr);
  //        }
}

开发者ID:openbaton，项目名称:autoscaling-engine，代码行数:31，代码来源:RestDetectionInterface.java

示例6: OrVnfmInstantiateMessage

import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
public OrVnfmInstantiateMessage(
    VirtualNetworkFunctionDescriptor vnfd,
    VNFDeploymentFlavour vnfdf,
    String vnfInstanceName,
    Set<VirtualLinkRecord> vlrs,
    Map<String, String> extension,
    Map<String, Collection<BaseVimInstance>> vimInstances,
    Set<Key> keys,
    VNFPackage vnfPackage) {
  this.vnfd = vnfd;
  this.keys = keys;
  this.vnfdf = vnfdf;
  this.vnfInstanceName = vnfInstanceName;
  this.vlrs = vlrs;
  this.extension = extension;
  this.vimInstances = vimInstances;
  this.action = Action.INSTANTIATE;
  this.vnfPackage = vnfPackage;
}

开发者ID:openbaton，项目名称:NFVO，代码行数:20，代码来源:OrVnfmInstantiateMessage.java

示例7: sendStart

import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
private void sendStart(VirtualNetworkFunctionRecord virtualNetworkFunctionRecord)
    throws NotFoundException, BadFormatException, ExecutionException, InterruptedException {
  VnfmSender vnfmSender;
  vnfmSender =
      this.getVnfmSender(
          vnfmRegister.getVnfm(virtualNetworkFunctionRecord.getEndpoint()).getEndpointType());
  log.info(
      "Calling START to: "
          + virtualNetworkFunctionRecord.getName()
          + " because it has 0 dependencies");
  log.trace(
      "VNFR ("
          + virtualNetworkFunctionRecord.getId()
          + ") hibernate version is = "
          + virtualNetworkFunctionRecord.getHbVersion());
  /*vnfmSender.sendCommand(
  new OrVnfmGenericMessage(virtualNetworkFunctionRecord, Action.START),
  vnfmRegister.getVnfm(virtualNetworkFunctionRecord.getEndpoint()));*/
  vnfStateHandler.executeAction(
      vnfmSender.sendCommand(
          new OrVnfmStartStopMessage(virtualNetworkFunctionRecord, null, Action.START),
          vnfmRegister.getVnfm(virtualNetworkFunctionRecord.getEndpoint())));
}

开发者ID:openbaton，项目名称:NFVO，代码行数:24，代码来源:InstantiateTask.java

示例8: OrVnfmInstantiateMessage

import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
public OrVnfmInstantiateMessage(
    VirtualNetworkFunctionDescriptor vnfd,
    VNFDeploymentFlavour vnfdf,
    String vnfInstanceName,
    Set<VirtualLinkRecord> vlrs,
    Map<String, String> extension,
    Map<String, Collection<VimInstance>> vimInstances,
    Set<Key> keys,
    VNFPackage vnfPackage) {
  this.vnfd = vnfd;
  this.keys = keys;
  this.vnfdf = vnfdf;
  this.vnfInstanceName = vnfInstanceName;
  this.vlrs = vlrs;
  this.extension = extension;
  this.vimInstances = vimInstances;
  this.action = Action.INSTANTIATE;
  this.vnfPackage = vnfPackage;
}

开发者ID:openbaton，项目名称:openbaton-libs，代码行数:20，代码来源:OrVnfmInstantiateMessage.java

示例9: configureSubTask

import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
@Override
public void configureSubTask(Profile.Section currentSection) {
  this.setTimeout(Integer.parseInt(currentSection.get("timeout", "5")));

  String action = currentSection.get("action");
  if (action == null) {
    try {
      throw new IntegrationTestException("action for NetworkServiceRecordWait not set");
    } catch (IntegrationTestException e) {
      e.printStackTrace();
      log.error(e.getMessage());
      System.exit(42);
    }
  }
  this.setAction(Action.valueOf(action));
}

开发者ID:openbaton，项目名称:integration-tests，代码行数:17，代码来源:NetworkServiceRecordWait.java

示例10: grantLifecycleOperation

import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
private OrVnfmGrantLifecycleOperationMessage grantLifecycleOperation() throws VnfmSdkException {
  NFVMessage response;
  try {
    response =
        vnfmHelper.sendAndReceive(
            VnfmUtils.getNfvMessage(Action.GRANT_OPERATION, virtualNetworkFunctionRecord));
  } catch (Exception e) {
    throw new VnfmSdkException("Not able to grant operation", e, virtualNetworkFunctionRecord);
  }
  if (response != null) {
    if (response.getAction().ordinal() == Action.ERROR.ordinal()) {
      throw new VnfmSdkException(
          "Not able to grant operation because: "
              + ((OrVnfmErrorMessage) response).getMessage(),
          ((OrVnfmErrorMessage) response).getVnfr());
    }
    OrVnfmGrantLifecycleOperationMessage orVnfmGrantLifecycleOperationMessage =
        (OrVnfmGrantLifecycleOperationMessage) response;

    return orVnfmGrantLifecycleOperationMessage;
  }
  return null;
}

开发者ID:openbaton，项目名称:openbaton-libs，代码行数:24，代码来源:AbstractVnfm.java

示例11: scale

import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
@Override
public VirtualNetworkFunctionRecord scale(
    Action scaleInOrOut,
    VirtualNetworkFunctionRecord virtualNetworkFunctionRecord,
    VNFComponent component,
    Object scripts,
    VNFRecordDependency dependency)
    throws Exception {
  log.info(
      scaleInOrOut.name()
          + " on VNFR "
          + virtualNetworkFunctionRecord.getName()
          + " with id "
          + virtualNetworkFunctionRecord.getId());
  Thread.sleep((int) (Math.random() * 500) + 1000);
  return virtualNetworkFunctionRecord;
}

开发者ID:openbaton，项目名称:dummy-vnfm-amqp，代码行数:18，代码来源:DummyAMQPVNFManager.java

示例12: subscribe

import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
private String subscribe(Action action) throws SDKException, FileNotFoundException {
  log.debug("Subscribing to all NSR Events with Action " + action);
  EventEndpoint eventEndpoint = new EventEndpoint();
  eventEndpoint.setName("Subscription:" + action);
  eventEndpoint.setEndpoint(
      "http://"
          + autoScalingProperties.getServer().getIp()
          + ":"
          + autoScalingProperties.getServer().getPort()
          + "/elasticity-management/"
          + action);
  eventEndpoint.setEvent(action);
  eventEndpoint.setType(EndpointType.REST);
  return nfvoRequestor.getEventAgent().create(eventEndpoint).getId();
}

开发者ID:openbaton，项目名称:autoscaling-engine，代码行数:16，代码来源:Application.java

示例13: OrVnfmStartStopMessage

import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
public OrVnfmStartStopMessage(
    VirtualNetworkFunctionRecord virtualNetworkFunctionRecord,
    VNFCInstance vnfcInstance,
    Action action) {
  this.virtualNetworkFunctionRecord = virtualNetworkFunctionRecord;
  this.vnfcInstance = vnfcInstance;
  this.action = action;
}

开发者ID:openbaton，项目名称:NFVO，代码行数:9，代码来源:OrVnfmStartStopMessage.java

示例14: toString

import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
@Override
public String toString() {
  return "OrVnfmErrorMessage{"
      + "action='"
      + Action.ERROR
      + '\''
      + "message='"
      + message
      + '\''
      + ", vnfr="
      + vnfr
      + '}';
}

开发者ID:openbaton，项目名称:NFVO，代码行数:14，代码来源:OrVnfmErrorMessage.java

示例15: VnfmOrStartStopMessage

import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
public VnfmOrStartStopMessage(
    VirtualNetworkFunctionRecord virtualNetworkFunctionRecord,
    VNFCInstance vnfcInstance,
    Action action) {
  this.virtualNetworkFunctionRecord = virtualNetworkFunctionRecord;
  this.vnfcInstance = vnfcInstance;
  this.action = action;
}

开发者ID:openbaton，项目名称:NFVO，代码行数:9，代码来源:VnfmOrStartStopMessage.java

示例16: VnfmOrGrantLifecycleOperationMessage

import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
public VnfmOrGrantLifecycleOperationMessage(
    VirtualNetworkFunctionDescriptor virtualNetworkFunctionDescriptor,
    Set<VirtualDeploymentUnit> vduSet,
    String deploymentFlavourKey) {
  this.virtualNetworkFunctionDescriptor = virtualNetworkFunctionDescriptor;
  this.vduSet = vduSet;
  this.deploymentFlavourKey = deploymentFlavourKey;
  this.action = Action.ALLOCATE_RESOURCES;
}

开发者ID:openbaton，项目名称:NFVO，代码行数:10，代码来源:VnfmOrGrantLifecycleOperationMessage.java

示例17: checkRequest

import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
private boolean checkRequest(String message) {
  JsonElement jsonElement = mapper.fromJson(message, JsonElement.class);

  String actionReceived = jsonElement.getAsJsonObject().get("action").getAsString();
  //log.debug("Action received: " + actionReceived);
  action = Action.valueOf(actionReceived);
  payload = jsonElement.getAsJsonObject().get("payload").toString();
  //log.debug("Payload received: "+payload);
  if (actionReceived.equals(ee.getEvent().toString())) return true;
  else log.error("Received wrong action: " + actionReceived);
  return false;
}

开发者ID:openbaton，项目名称:integration-tests，代码行数:13，代码来源:RestWaiter.java

示例18: getAvailableEvents

import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
@RequestMapping(
  value = "/actions",
  method = RequestMethod.GET,
  produces = MediaType.APPLICATION_JSON_VALUE
)
public Action[] getAvailableEvents() {
  return Action.values();
}

开发者ID:openbaton，项目名称:NFVO，代码行数:9，代码来源:RestEvent.java

示例19: sendStart

import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
private void sendStart(VirtualNetworkFunctionRecord virtualNetworkFunctionRecord)
    throws NotFoundException, BadFormatException, ExecutionException, InterruptedException {
  VnfmSender vnfmSender;
  vnfmSender =
      this.getVnfmSender(
          vnfmRegister.getVnfm(virtualNetworkFunctionRecord.getEndpoint()).getEndpointType());
  /*vnfmSender.sendCommand(
  new OrVnfmGenericMessage(virtualNetworkFunctionRecord, Action.START),
  vnfmRegister.getVnfm(virtualNetworkFunctionRecord.getEndpoint()));*/
  vnfStateHandler.executeAction(
      vnfmSender.sendCommand(
          new OrVnfmStartStopMessage(virtualNetworkFunctionRecord, null, Action.START),
          vnfmRegister.getVnfm(virtualNetworkFunctionRecord.getEndpoint())));
}

开发者ID:openbaton，项目名称:NFVO，代码行数:15，代码来源:StartTask.java

示例20: sendStart

import org.openbaton.catalogue.nfvo.Action; //导入依赖的package包/类
private void sendStart(VirtualNetworkFunctionRecord virtualNetworkFunctionRecord)
    throws NotFoundException, BadFormatException, ExecutionException, InterruptedException {
  VnfmSender vnfmSender;
  log.info("Calling START to: " + virtualNetworkFunctionRecord.getName() + " after MODIFY");
  vnfmSender =
      this.getVnfmSender(
          vnfmRegister.getVnfm(virtualNetworkFunctionRecord.getEndpoint()).getEndpointType());
  /*vnfmSender.sendCommand(
  new OrVnfmGenericMessage(virtualNetworkFunctionRecord, Action.START),
  vnfmRegister.getVnfm(virtualNetworkFunctionRecord.getEndpoint()));*/
  vnfStateHandler.executeAction(
      vnfmSender.sendCommand(
          new OrVnfmStartStopMessage(virtualNetworkFunctionRecord, null, Action.START),
          vnfmRegister.getVnfm(virtualNetworkFunctionRecord.getEndpoint())));
}

开发者ID:openbaton，项目名称:NFVO，代码行数:16，代码来源:ModifyTask.java

注：本文中的org.openbaton.catalogue.nfvo.Action类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。