org.jdiameter.api.Message.getCommandCode()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(11.9k)|赞(0)|评价(0)|浏览(236)

本文整理了Java中org.jdiameter.api.Message.getCommandCode()方法的一些代码示例，展示了Message.getCommandCode()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Message.getCommandCode()方法的具体详情如下：
包路径：org.jdiameter.api.Message
类名称：Message
方法名：getCommandCode

Message.getCommandCode介绍

暂无

代码示例

代码示例来源：origin: org.mobicents.diameter/jdiameter-impl

  1. @Override
  2. public int getCommandCode() {
  3.  return message.getCommandCode();
  4. }

代码示例来源：origin: org.mobicents.servers.diameter.resources/base-common-events

  1. public int getCommandCode() {
  2.  return this.msg.getCommandCode();
  3. }

代码示例来源：origin: org.mobicents.resources/mobicents-slee-ra-diameter-base-common-events

  1. public int getCommandCode() {
  2.  return this.msg.getCommandCode();
  3. }

代码示例来源：origin: org.mobicents.diameter/jdiameter-impl

  1. @Override
  2. public void validate(Message msg, boolean incoming) throws AvpNotAllowedException {
  3.  if (!enabled || !configured) {
  4.   return;
  5.  }
  6.  MessageRepresentationImpl rep = new MessageRepresentationImpl(msg.getCommandCode(), msg.getApplicationId(), msg.isRequest());
  7.  rep = (MessageRepresentationImpl) this.commandMap.get(rep);
  8.  if (rep == null) {
  9.   // no notion, lets leave it.
  10.   logger.warn("Validation could not be performed, command not defined!. Code={}, Application-Id={}, Req={}",
  11.     new Object[] { msg.getCommandCode(), msg.getApplicationId(), msg.isRequest() });
  12.   return;
  13.  }
  14.  rep.validate(msg, (incoming ? receiveValidationLevel : sendValidationLevel));
  15. }

代码示例来源：origin: org.mobicents.resources/mobicents-slee-ra-diameter-rf-ra

  1. /**
  2.  * 
  3.  * @param eventLookupFacility
  4.  * @param message
  5.  * @return
  6.  */
  7. public FireableEventType getEventId(EventLookupFacility eventLookupFacility, Message message) {
  8.  FireableEventType eventID = null;
  9.  // Error is always the same.
  10.  if (message.isError()) {
  11.   //eventID = getEventId(eventLookupFacility, ERROR_ANSWER);
  12.   //TODO: x?
  13.  }
  14.  else {
  15.   final int commandCode = message.getCommandCode();
  16.   final boolean isRequest = message.isRequest();
  17.   String eventName = eventNames.get(commandCode);
  18.   if(eventName != null) {
  19.    eventID = getEventId(eventLookupFacility, eventName + (isRequest ? "Request" : "Answer"));
  20.   }
  21.  }
  22.  return eventID;
  23. }

代码示例来源：origin: org.mobicents.resources/restcomm-slee-ra-diameter-cx-dx-ra

  1. private DiameterActivity createActivity(Message message) throws CreateActivityException {
  2.  DiameterActivity activity = activities.get(getActivityHandle(message.getSessionId()));
  3.  if(activity == null) {
  4.   if (message.isRequest()) {
  5.    if(message.getCommandCode() == PushProfileRequest.COMMAND_CODE || message.getCommandCode() == RegistrationTerminationRequest.COMMAND_CODE) {
  6.     return createCxDxClientSessionActivity((Request) message, false);
  7.    }
  8.    else {
  9.     return createCxDxServerSessionActivity((Request) message);
  10.    }
  11.   }
  12.   else {
  13.    throw new IllegalStateException("Got answer, there should already be activity.");
  14.   }
  15.  }
  16.  
  17.  return activity;
  18. }

代码示例来源：origin: org.mobicents.resources/restcomm-slee-ra-diameter-gx-ra

  1. /**
  2.  *
  3.  * @param eventLookupFacility
  4.  * @param message
  5.  * @return
  6.  */
  7. public FireableEventType getEventId(final EventLookupFacility eventLookupFacility, final Message message) {
  8.   FireableEventType eventID;
  9.   // Error is always the same.
  10.   if (message.isError()) {
  11.     eventID = getEventId(eventLookupFacility, ERROR_ANSWER);
  12.   } else {
  13.     final int commandCode = message.getCommandCode();
  14.     final boolean isRequest = message.isRequest();
  15.     final String eventName = eventNames.get(commandCode);
  16.     if (eventName != null) {
  17.       eventID = getEventId(eventLookupFacility, eventName + (isRequest ? "Request" : "Answer"));
  18.     } else {
  19.       eventID = getEventId(eventLookupFacility, EXTENSION_DIAMETER_MESSAGE);
  20.     }
  21.   }
  22.   return eventID;
  23. }

代码示例来源：origin: org.mobicents.resources/mobicents-slee-ra-diameter-s6a-ra

  1. /**
  2.  * 
  3.  * @param eventLookupFacility
  4.  * @param message
  5.  * @return
  6.  */
  7. public FireableEventType getEventId(EventLookupFacility eventLookupFacility, Message message) {
  8.   FireableEventType eventID = null;
  9.   // Error is always the same.
  10.   if (message.isError()) {
  11.     eventID = getEventId(eventLookupFacility, ERROR_ANSWER);
  12.   } else {
  13.     final int commandCode = message.getCommandCode();
  14.     final boolean isRequest = message.isRequest();
  15.     String eventName = eventNames.get(commandCode);
  16.     if (eventName != null) {
  17.       eventID = getEventId(eventLookupFacility, eventName + (isRequest ? "Request" : "Answer"));
  18.     } else {
  19.       eventID = getEventId(eventLookupFacility, EXTENSION_DIAMETER_MESSAGE);
  20.     }
  21.   }
  22.   return eventID;
  23. }

代码示例来源：origin: org.mobicents.resources/restcomm-slee-ra-diameter-gq-ra

  1. /**
  2.  * 
  3.  * @param eventLookupFacility
  4.  * @param message
  5.  * @return
  6.  */
  7. public FireableEventType getEventId(EventLookupFacility eventLookupFacility, Message message) {
  8.  FireableEventType eventID = null;
  9.  // Error is always the same.
  10.  if (message.isError()) {
  11.   eventID = getEventId(eventLookupFacility, ERROR_ANSWER);
  12.  }
  13.  else {
  14.   final int commandCode = message.getCommandCode();
  15.   final boolean isRequest = message.isRequest();
  16.   String eventName = eventNames.get(commandCode);
  17.   if (eventName != null) {
  18.    eventID = getEventId(eventLookupFacility, eventName + (isRequest ? "Request" : "Answer"));
  19.   }
  20.   else {
  21.    eventID = getEventId(eventLookupFacility, EXTENSION_DIAMETER_MESSAGE);
  22.   }
  23.  }
  24.  return eventID;
  25. }

代码示例来源：origin: org.mobicents.resources/mobicents-slee-ra-diameter-cca-common-ra

  1. /**
  2.  * 
  3.  * @param eventLookupFacility
  4.  * @param message
  5.  * @return
  6.  */
  7. public FireableEventType getEventId(EventLookupFacility eventLookupFacility, Message message) {
  8.  FireableEventType eventID = null;
  9.  // Error is always the same.
  10.  if (message.isError()) {
  11.   eventID = getEventId(eventLookupFacility, ERROR_ANSWER);
  12.  }
  13.  else {
  14.   final int commandCode = message.getCommandCode();
  15.   final boolean isRequest = message.isRequest();
  16.   String eventName = eventNames.get(commandCode);
  17.   if(eventName != null) {
  18.    eventID = getEventId(eventLookupFacility, eventName + (isRequest ? "Request" : "Answer"));
  19.   }
  20.   else {
  21.    eventID = getEventId(eventLookupFacility, EXTENSION_DIAMETER_MESSAGE);
  22.   }
  23.  }
  24.  return eventID;
  25. }

代码示例来源：origin: org.mobicents.resources/restcomm-slee-ra-diameter-cca-common-ra

  1. /**
  2.  * 
  3.  * @param eventLookupFacility
  4.  * @param message
  5.  * @return
  6.  */
  7. public FireableEventType getEventId(EventLookupFacility eventLookupFacility, Message message) {
  8.  FireableEventType eventID = null;
  9.  // Error is always the same.
  10.  if (message.isError()) {
  11.   eventID = getEventId(eventLookupFacility, ERROR_ANSWER);
  12.  }
  13.  else {
  14.   final int commandCode = message.getCommandCode();
  15.   final boolean isRequest = message.isRequest();
  16.   String eventName = eventNames.get(commandCode);
  17.   if(eventName != null) {
  18.    eventID = getEventId(eventLookupFacility, eventName + (isRequest ? "Request" : "Answer"));
  19.   }
  20.   else {
  21.    eventID = getEventId(eventLookupFacility, EXTENSION_DIAMETER_MESSAGE);
  22.   }
  23.  }
  24.  return eventID;
  25. }

代码示例来源：origin: org.mobicents.resources/restcomm-slee-ra-diameter-base-common-ra

  1. /**
  2.  * 
  3.  * @param eventLookupFacility
  4.  * @param message
  5.  * @return
  6.  */
  7. public FireableEventType getEventId(EventLookupFacility eventLookupFacility, Message message) {
  8.  FireableEventType eventID = null;
  9.  // Error is always the same.
  10.  if (message.isError()) {
  11.   eventID = getEventId(eventLookupFacility, ERROR_ANSWER);
  12.  }
  13.  else {
  14.   final int commandCode = message.getCommandCode();
  15.   final boolean isRequest = message.isRequest();
  16.   String eventName = eventNames.get(commandCode);
  17.   if(eventName != null) {
  18.    eventID = getEventId(eventLookupFacility, eventName + (isRequest ? "Request" : "Answer"));
  19.   }
  20.   else {
  21.    eventID = getEventId(eventLookupFacility, EXTENSION_DIAMETER_MESSAGE);
  22.   }
  23.  }
  24.  return eventID;
  25. }

代码示例来源：origin: org.mobicents.resources/restcomm-slee-ra-diameter-ro-ra

  1. /**
  2.  * 
  3.  * @param eventLookupFacility
  4.  * @param message
  5.  * @return
  6.  */
  7. public FireableEventType getEventId(EventLookupFacility eventLookupFacility, Message message) {
  8.  FireableEventType eventID = null;
  9.  // Error is always the same.
  10.  if (message.isError()) {
  11.   eventID = getEventId(eventLookupFacility, ERROR_ANSWER);
  12.  }
  13.  else {
  14.   final int commandCode = message.getCommandCode();
  15.   final boolean isRequest = message.isRequest();
  16.   String eventName = eventNames.get(commandCode);
  17.   if(eventName != null) {
  18.    eventID = getEventId(eventLookupFacility, eventName + (isRequest ? "Request" : "Answer"));
  19.   }
  20.   else {
  21.    eventID = getEventId(eventLookupFacility, EXTENSION_DIAMETER_MESSAGE);
  22.   }
  23.  }
  24.  return eventID;
  25. }

代码示例来源：origin: org.mobicents.resources/mobicents-slee-ra-diameter-ro-ra

  1. /**
  2.  * 
  3.  * @param eventLookupFacility
  4.  * @param message
  5.  * @return
  6.  */
  7. public FireableEventType getEventId(EventLookupFacility eventLookupFacility, Message message) {
  8.  FireableEventType eventID = null;
  9.  // Error is always the same.
  10.  if (message.isError()) {
  11.   eventID = getEventId(eventLookupFacility, ERROR_ANSWER);
  12.  }
  13.  else {
  14.   final int commandCode = message.getCommandCode();
  15.   final boolean isRequest = message.isRequest();
  16.   String eventName = eventNames.get(commandCode);
  17.   if(eventName != null) {
  18.    eventID = getEventId(eventLookupFacility, eventName + (isRequest ? "Request" : "Answer"));
  19.   }
  20.   else {
  21.    eventID = getEventId(eventLookupFacility, EXTENSION_DIAMETER_MESSAGE);
  22.   }
  23.  }
  24.  return eventID;
  25. }

代码示例来源：origin: org.mobicents.resources/mobicents-slee-ra-diameter-cca-ra

  1. /**
  2.  * Create Event object from a JDiameter message (request or answer)
  3.  * 
  4.  * @return a DiameterMessage object wrapping the request/answer
  5.  */
  6. private DiameterMessage createEvent(Message message) {
  7.  if (message == null) {
  8.   throw new NullPointerException("Message argument cannot be null while creating event.");
  9.  }
  10.  if (message.isError()) {
  11.   return new ErrorAnswerImpl(message);
  12.  }
  13.  switch (message.getCommandCode()) {
  14.  case CreditControlMessage.commandCode: // CCR/CCA
  15.   return message.isRequest() ? new CreditControlRequestImpl(message) : new CreditControlAnswerImpl(message);
  16.  default:
  17.   return new ExtensionDiameterMessageImpl(message);
  18.  }
  19. }

代码示例来源：origin: org.mobicents.resources/mobicents-slee-ra-diameter-s6a-ra

  1. private DiameterActivity createActivity(Message message) throws CreateActivityException {
  2.  DiameterActivity activity = activities.get(getActivityHandle(message.getSessionId()));
  3.  if (activity == null) {
  4.   if (message.isRequest()) {
  5.    switch(message.getCommandCode()) {
  6.     case UpdateLocationRequest.COMMAND_CODE:
  7.     case AuthenticationInformationRequest.COMMAND_CODE:
  8.     case PurgeUERequest.COMMAND_CODE:
  9.     case NotifyRequest.COMMAND_CODE:
  10.      return createS6aServerSessionActivity((Request) message);
  11.     case CancelLocationRequest.COMMAND_CODE:
  12.     case InsertSubscriberDataRequest.COMMAND_CODE:
  13.     case DeleteSubscriberDataRequest.COMMAND_CODE:
  14.     case ResetRequest.COMMAND_CODE:
  15.      return createS6aClientSessionActivity((Request) message);
  16.    }
  17.   }
  18.   else {
  19.    throw new IllegalStateException("Got answer, there should already be activity.");
  20.   }
  21.  }
  22.  return activity;
  23. }

代码示例来源：origin: org.mobicents.resources/mobicents-slee-ra-diameter-rf-ra

  1. /**
  2.  * Create Event object from a JDiameter message (request or answer)
  3.  * 
  4.  * @return a DiameterMessage object wrapping the request/answer
  5.  * @throws OperationNotSupportedException
  6.  */
  7. private DiameterMessage createEvent(Message message) {
  8.  if (message == null) {
  9.   throw new NullPointerException("Message argument cannot be null while creating event.");
  10.  }
  11.  int commandCode = message.getCommandCode();
  12.  if (message.isError()) {
  13.   return new ErrorAnswerImpl(message);
  14.  }
  15.  boolean isRequest = message.isRequest();
  16.  switch (commandCode) {
  17.  case RfAccountingAnswer.commandCode: // ACR/ACA
  18.   return isRequest ? new RfAccountingRequestImpl(message) : new RfAccountingAnswerImpl(message);
  19.  default:
  20.   return new ExtensionDiameterMessageImpl(message);
  21.  }
  22. }

代码示例来源：origin: org.mobicents.resources/mobicents-slee-ra-diameter-base-common-events

  1. public DiameterCommand getCommand() {
  2.  return new DiameterCommandImpl(this.message.getCommandCode(), this.message.getApplicationId(), this.getShortName(), this.getLongName(), this.message.isRequest(), this.message.isProxiable());
  3. }

代码示例来源：origin: org.mobicents.servers.diameter.resources/base-common-events

  1. public DiameterCommand getCommand() {
  2.  return new DiameterCommandImpl(this.message.getCommandCode(), this.message.getApplicationId(), this.getShortName(), this.getLongName(), this.message.isRequest(), this.message.isProxiable());
  3. }

代码示例来源：origin: org.mobicents.resources/restcomm-slee-ra-diameter-sh-client-ra

  1. /**
  2.  * This method is for internal use only, it creates activities for requests that 
  3.  * do not fall in certain app range or no activities were found <br>
  4.  * It should distinguish between initial requests, requests with different domains etc. 
  5.  * Answer for creating XXXServerSession or basic diameter activity lies in this method
  6.  * 
  7.  * @param message
  8.  * @return
  9.  */
  10. DiameterActivity createActivity(Message message) throws CreateActivityException {
  11.  DiameterActivity activity = activities.get(getActivityHandle(message.getSessionId()));
  12.  if (activity == null) {
  13.   //FIXME: baranowb: here we can receive only (valid) PNR, other message are errors?
  14.   if(message.getCommandCode() != PushNotificationRequestImpl.commandCode) {
  15.    throw new CreateActivityException("Cant create activity for unexpected message:\r\n" + message);
  16.   }
  17.   return (ShClientSubscriptionActivityImpl) this.createShClientSubscriptionActivity(new PushNotificationRequestImpl( message));
  18.  }
  19.  return activity;
  20. }

内容来源于网络，如有侵权，请联系作者删除！

Message

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com