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

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

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

Message.setReTransmitted介绍

[英]Set 1 or 0 to T bit field of header
[中]将1或0设置为标头的T位字段

代码示例

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

  1. /**
  2. *
  3. * @param msg
  4. */
  5. public PushNotificationAnswerImpl(Message msg) {
  6. super(msg);
  7. msg.setRequest(false);
  8. msg.setReTransmitted(false); // just in case. answers never have T flag set
  9. super.longMessageName = "Push-Notificaton-Answer";
  10. super.shortMessageName = "PNA";
  11. }

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

  1. /**
  2. *
  3. * @param msg
  4. */
  5. public SubscribeNotificationsAnswerImpl(Message msg) {
  6. super(msg);
  7. msg.setRequest(false);
  8. msg.setReTransmitted(false); // just in case. answers never have T flag set
  9. super.longMessageName = "Subscribe-Notification-Answer";
  10. super.shortMessageName = "SNA";
  11. }

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

  1. public ProfileUpdateAnswerImpl(Message msg) {
  2. super(msg);
  3. msg.setRequest(false);
  4. msg.setReTransmitted(false); // just in case. answers never have T flag set
  5. super.longMessageName = "Profile-Update-Answer";
  6. super.shortMessageName = "PUA";
  7. }

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

  1. /**
  2. *
  3. * @param msg
  4. */
  5. public UserDataAnswerImpl(Message msg) {
  6. super(msg);
  7. msg.setRequest(false);
  8. msg.setReTransmitted(false); // just in case. answers never have T flag set
  9. super.longMessageName = "User-Data-Answer";
  10. super.shortMessageName = "UDA";
  11. }

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

  1. /**
  2. *
  3. * @param msg
  4. */
  5. public UserDataAnswerImpl(Message msg) {
  6. super(msg);
  7. msg.setRequest(false);
  8. msg.setReTransmitted(false); // just in case. answers never have T flag set
  9. super.longMessageName = "User-Data-Answer";
  10. super.shortMessageName = "UDA";
  11. }

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

  1. /**
  2. *
  3. * @param msg
  4. */
  5. public PushNotificationAnswerImpl(Message msg) {
  6. super(msg);
  7. msg.setRequest(false);
  8. msg.setReTransmitted(false); // just in case. answers never have T flag set
  9. super.longMessageName = "Push-Notificaton-Answer";
  10. super.shortMessageName = "PNA";
  11. }

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

  1. public ProfileUpdateAnswerImpl(Message msg) {
  2. super(msg);
  3. msg.setRequest(false);
  4. msg.setReTransmitted(false); // just in case. answers never have T flag set
  5. super.longMessageName = "Profile-Update-Answer";
  6. super.shortMessageName = "PUA";
  7. }

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

  1. /**
  2. *
  3. * @param msg
  4. */
  5. public SubscribeNotificationsAnswerImpl(Message msg) {
  6. super(msg);
  7. msg.setRequest(false);
  8. msg.setReTransmitted(false); // just in case. answers never have T flag set
  9. super.longMessageName = "Subscribe-Notification-Answer";
  10. super.shortMessageName = "SNA";
  11. }

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

  1. private Message createShMessage(DiameterHeader diameterHeader, DiameterAvp[] avps, int _commandCode) throws IllegalArgumentException {
  2. // List<DiameterAvp> list = (List<DiameterAvp>) this.avpList.clone();
  3. boolean isRequest = diameterHeader == null;
  4. Message msg = null;
  5. if (!isRequest) {
  6. Message raw = createMessage(diameterHeader, avps,0);
  7. raw.setProxiable(diameterHeader.isProxiable());
  8. raw.setRequest(false);
  9. raw.setReTransmitted(false); // just in case. answers never have T flag set
  10. msg = raw;
  11. }
  12. else {
  13. Message raw = createMessage(null, avps,_commandCode);
  14. raw.setProxiable(true);
  15. raw.setRequest(true);
  16. msg = raw;
  17. }
  18. return msg;
  19. }

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

  1. private GxCreditControlMessage createGxCreditControlRequest(final DiameterHeader diameterHeader, final DiameterAvp[] avps) throws IllegalArgumentException {
  2. boolean isRequest = false;
  3. if (diameterHeader == null) {
  4. isRequest = true;
  5. }
  6. GxCreditControlMessage msg = null;
  7. if (!isRequest) {
  8. final Message raw = createGxMessage(diameterHeader, avps, GxCreditControlRequest.commandCode);
  9. raw.setProxiable(true);
  10. raw.setRequest(false);
  11. raw.setReTransmitted(false); // just in case. answers never have T flag set
  12. msg = new GxCreditControlAnswerImpl(raw);
  13. } else {
  14. final Message raw = createGxMessage(null, avps, GxCreditControlRequest.commandCode);
  15. raw.setProxiable(true);
  16. raw.setRequest(true);
  17. msg = new GxCreditControlRequestImpl(raw);
  18. }
  19. return msg;
  20. }

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

  1. private GxReAuthMessage createGxReAuthRequest(final DiameterHeader diameterHeader, final DiameterAvp[] avps) throws IllegalArgumentException {
  2. boolean isRequest = false;
  3. if (diameterHeader == null) {
  4. isRequest = true;
  5. }
  6. GxReAuthMessage msg = null;
  7. if (!isRequest) {
  8. final Message raw = createGxMessage(diameterHeader, avps, GxReAuthAnswer.commandCode);
  9. raw.setProxiable(true);
  10. raw.setRequest(false);
  11. raw.setReTransmitted(false); // just in case. answers never have T flag set
  12. msg = new GxReAuthAnswerImpl(raw);
  13. } else {
  14. final Message raw = createGxMessage(null, avps, GxReAuthRequest.commandCode);
  15. raw.setProxiable(true);
  16. raw.setRequest(true);
  17. msg = new GxReAuthRequestImpl(raw);
  18. }
  19. return msg;
  20. }

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

  1. private RoCreditControlMessage createRoCreditControlRequest(DiameterHeader diameterHeader, DiameterAvp[] avps) throws IllegalArgumentException {
  2. // List<DiameterAvp> list = (List<DiameterAvp>) this.avpList.clone();
  3. boolean isRequest = diameterHeader == null;
  4. RoCreditControlMessage msg = null;
  5. if (!isRequest) {
  6. Message raw = createMessage(diameterHeader, avps);
  7. raw.setProxiable(diameterHeader.isProxiable());
  8. raw.setRequest(false);
  9. raw.setReTransmitted(false); // just in case. answers never have T flag set
  10. msg = new RoCreditControlAnswerImpl(raw);
  11. } else {
  12. Message raw = createMessage(null, avps);
  13. raw.setProxiable(true);
  14. raw.setRequest(true);
  15. msg = new RoCreditControlRequestImpl(raw);
  16. }
  17. return msg;
  18. }

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

  1. private RoCreditControlMessage createRoCreditControlRequest(DiameterHeader diameterHeader, DiameterAvp[] avps) throws IllegalArgumentException {
  2. // List<DiameterAvp> list = (List<DiameterAvp>) this.avpList.clone();
  3. boolean isRequest = diameterHeader == null;
  4. RoCreditControlMessage msg = null;
  5. if (!isRequest) {
  6. Message raw = createMessage(diameterHeader, avps);
  7. raw.setProxiable(diameterHeader.isProxiable());
  8. raw.setRequest(false);
  9. raw.setReTransmitted(false); // just in case. answers never have T flag set
  10. msg = new RoCreditControlAnswerImpl(raw);
  11. } else {
  12. Message raw = createMessage(null, avps);
  13. raw.setProxiable(true);
  14. raw.setRequest(true);
  15. msg = new RoCreditControlRequestImpl(raw);
  16. }
  17. return msg;
  18. }

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

  1. protected RfAccountingMessage createRfAccountingMessage(DiameterHeader diameterHeader, DiameterAvp[] avps) throws IllegalArgumentException {
  2. // List<DiameterAvp> list = (List<DiameterAvp>) this.avpList.clone();
  3. boolean isRequest = diameterHeader == null;
  4. RfAccountingMessage msg = null;
  5. if (!isRequest) {
  6. Message raw = createMessage(diameterHeader, avps);
  7. raw.setProxiable(diameterHeader.isProxiable());
  8. raw.setRequest(false);
  9. raw.setReTransmitted(false); // just in case. answers never have T flag set
  10. msg = new RfAccountingAnswerImpl(raw);
  11. } else {
  12. Message raw = createMessage(null, avps);
  13. raw.setProxiable(true);
  14. raw.setRequest(true);
  15. msg = new RfAccountingRequestImpl(raw);
  16. }
  17. return msg;
  18. }

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

  1. private CreditControlMessage createCreditControlMessage(DiameterHeader diameterHeader, DiameterAvp[] avps) throws IllegalArgumentException {
  2. //List<DiameterAvp> list = (List<DiameterAvp>) this.avpList.clone();
  3. boolean isRequest = diameterHeader == null;
  4. CreditControlMessage msg = null;
  5. if(!isRequest) {
  6. Message raw = createMessage(diameterHeader, avps);
  7. raw.setProxiable(diameterHeader.isProxiable());
  8. raw.setRequest(false);
  9. raw.setReTransmitted(false); // just in case. answers never have T flag set
  10. msg = new CreditControlAnswerImpl(raw);
  11. }
  12. else {
  13. Message raw = createMessage(null, avps);
  14. raw.setProxiable(true);
  15. raw.setRequest(true);
  16. msg = new CreditControlRequestImpl(raw);
  17. }
  18. return msg;
  19. }

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

  1. private CreditControlMessage createCreditControlMessage(DiameterHeader diameterHeader, DiameterAvp[] avps) throws IllegalArgumentException {
  2. //List<DiameterAvp> list = (List<DiameterAvp>) this.avpList.clone();
  3. boolean isRequest = diameterHeader == null;
  4. CreditControlMessage msg = null;
  5. if(!isRequest) {
  6. Message raw = createMessage(diameterHeader, avps);
  7. raw.setProxiable(diameterHeader.isProxiable());
  8. raw.setRequest(false);
  9. raw.setReTransmitted(false); // just in case. answers never have T flag set
  10. msg = new CreditControlAnswerImpl(raw);
  11. }
  12. else {
  13. Message raw = createMessage(null, avps);
  14. raw.setProxiable(true);
  15. raw.setRequest(true);
  16. msg = new CreditControlRequestImpl(raw);
  17. }
  18. return msg;
  19. }

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

  1. @Override
  2. public GqSessionTerminationAnswer createGqSessionTerminationAnswer(GqSessionTerminationRequest str) {
  3. Message raw = createMessage(str.getHeader(), new DiameterAvp[] {});
  4. raw.setRequest(false); // this should be different ...
  5. raw.setReTransmitted(false); // just in case. answers never have T flag set
  6. GqSessionTerminationAnswerImpl sta = new GqSessionTerminationAnswerImpl(raw);
  7. sta.getGenericData().getAvps().removeAvp(DiameterAvpCodes.DESTINATION_HOST);
  8. sta.getGenericData().getAvps().removeAvp(DiameterAvpCodes.DESTINATION_REALM);
  9. sta.getGenericData().getAvps().removeAvp(DiameterAvpCodes.ORIGIN_HOST);
  10. sta.getGenericData().getAvps().removeAvp(DiameterAvpCodes.ORIGIN_REALM);
  11. sta.setSessionId(str.getSessionId());
  12. addOrigin(sta);
  13. return sta;
  14. }

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

  1. @Override
  2. public GqAAAnswer createGqAAAnswer(GqAARequest aar) {
  3. Message raw = createMessage(aar.getHeader(), new DiameterAvp[] {});
  4. raw.setRequest(false); // this should be different ...
  5. raw.setReTransmitted(false); // just in case. answers never have T flag set
  6. GqAAAnswerImpl aaa = new GqAAAnswerImpl(raw);
  7. aaa.getGenericData().getAvps().removeAvp(DiameterAvpCodes.DESTINATION_HOST);
  8. aaa.getGenericData().getAvps().removeAvp(DiameterAvpCodes.DESTINATION_REALM);
  9. aaa.getGenericData().getAvps().removeAvp(DiameterAvpCodes.ORIGIN_HOST);
  10. aaa.getGenericData().getAvps().removeAvp(DiameterAvpCodes.ORIGIN_REALM);
  11. aaa.setSessionId(aar.getSessionId());
  12. addOrigin(aaa);
  13. return aaa;
  14. }

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

  1. @Override
  2. public GqReAuthAnswer createGqReAuthAnswer(GqReAuthRequest rar) {
  3. Message raw = createMessage(rar.getHeader(), new DiameterAvp[] {});
  4. raw.setRequest(false); // this should be different ...
  5. raw.setReTransmitted(false); // just in case. answers never have T flag set
  6. GqReAuthAnswerImpl raa = new GqReAuthAnswerImpl(raw);
  7. raa.getGenericData().getAvps().removeAvp(DiameterAvpCodes.DESTINATION_HOST);
  8. raa.getGenericData().getAvps().removeAvp(DiameterAvpCodes.DESTINATION_REALM);
  9. raa.getGenericData().getAvps().removeAvp(DiameterAvpCodes.ORIGIN_HOST);
  10. raa.getGenericData().getAvps().removeAvp(DiameterAvpCodes.ORIGIN_REALM);
  11. raa.setSessionId(rar.getSessionId());
  12. addOrigin(raa);
  13. return raa;
  14. }

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

  1. @Override
  2. public GqAbortSessionAnswer createGqAbortSessionAnswer(GqAbortSessionRequest asr) {
  3. Message raw = createMessage(asr.getHeader(), new DiameterAvp[] {});
  4. raw.setRequest(false); // this should be different ...
  5. raw.setReTransmitted(false); // just in case. answers never have T flag set
  6. GqAbortSessionAnswerImpl asa = new GqAbortSessionAnswerImpl(raw);
  7. asa.getGenericData().getAvps().removeAvp(DiameterAvpCodes.DESTINATION_HOST);
  8. asa.getGenericData().getAvps().removeAvp(DiameterAvpCodes.DESTINATION_REALM);
  9. asa.getGenericData().getAvps().removeAvp(DiameterAvpCodes.ORIGIN_HOST);
  10. asa.getGenericData().getAvps().removeAvp(DiameterAvpCodes.ORIGIN_REALM);
  11. asa.setSessionId(asr.getSessionId());
  12. addOrigin(asa);
  13. return asa;
  14. }

相关文章