Get the reply reliability to use for reply mesages on a replyTo destination

@return the reply reliability
772465
protected Reliability getReplyReliability() {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(this, tc, "getReplyReliability");
        Reliability result = null;
        if (replyReliabilityByte != -1) {
            result = Reliability.getReliability(replyReliabilityByte);
        }
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(this, tc, "getReplyReliability", result);
        return result;
    }
1362803
public String getPerformanceStats() {
        int total = totalQuery.get();
        int hit = cacheHit.get();
        int weakRef = weakRefLost.get();
        int failure = loadFailure.get();
        int miss = total-hit-weakRef;

        return MessageFormat.format("total={0} hit={1}% lostRef={2}% failure={3}% miss={4}%",
                total,hit,weakRef,failure,miss);
    }
622911
public PersistentTranId getPersistentTranId()
    {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.entry(this, tc, "getPersistentTranId");

        PersistentTranId ptid = null;

        if (_currentTran != null)
        {
            ptid = _currentTran.getPersistentTranId();
        }

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.exit(this, tc, "getPersistentTranId", "return="+ptid);
        return ptid;
    }
496943
@Override
    public final void setReplyReliability(Reliability value) {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(this, tc, "setReplyReliability", value);
        if (value != null) {
            /* Get the int value of the Reliability instance and set it in the field */
            getApi().setField(JsApiAccess.REPLYRELIABILITY_VALUE, value.toByte());
        }
        else {
            if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
                SibTr.exit(this, tc, "setReplyReliability", "NullPointerException");
            throw new NullPointerException();
        }
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(this, tc, "setReplyReliability");
    }
991863
@Override
    public Reliability getReliability()
    {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(this, tc, "getReliability");

        if (msgReliability == null)
        {
            JsMessage localMsg = getJSMessage(true);
            msgReliability = localMsg.getReliability();
        }

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(this, tc, "getReliability", msgReliability);

        return msgReliability;
    }
1154114
public String getValidationMethodName() {
        if (isValidated() == false) {
            throw new IllegalStateException();
        }
        if (getValidation().equals("notNull") ||
                getValidation().equals("notEmpty") ||
                getValidation().equals("notBlank")) {
            return "JodaBeanUtils." + getValidation();
        }
        return getValidation();  // method in bean or static
    }
361599
public List<MessageDestinationRefType<WebAppType<T>>> getAllMessageDestinationRef()
   {
      List<MessageDestinationRefType<WebAppType<T>>> list = new ArrayList<MessageDestinationRefType<WebAppType<T>>>();
      List<Node> nodeList = childNode.get("message-destination-ref");
      for(Node node: nodeList)
      {
         MessageDestinationRefType<WebAppType<T>>  type = new MessageDestinationRefTypeImpl<WebAppType<T>>(this, "message-destination-ref", childNode, node);
         list.add(type);
      }
      return list;
   }
487748
public ClusteredLockManagerConfigurationBuilder reliability(Reliability reliability) {
      attributes.attribute(ClusteredLockManagerConfiguration.RELIABILITY).set(reliability);
      return this;
   }
1248749
def get_replies_to(self, msg):
        
        mid = msg.get_message_id()
        msg_hash = self.get_messages()
        for m in msg_hash.keys():
            if m.get_message_id() == mid:
                return msg_hash[m]
        return None
979950
private Message pollPrefetchQueue() {
        final Message message = this.prefetchedMessages.poll();
        if (message != null) {
            // message lastReceivedOffset should be up-to-date upon each poll - as recreateLink will depend on this
            this.lastReceivedMessage = message;
            this.sendFlow(1);
        }

        return message;
    }
961977
protected synchronized void compareReply(List<Long> processIds) {
        Object[] replyIds = replyProcessIds.toArray();
        for (Object replyId : replyIds) {
            if (processIds.contains((Long) replyId) == false) { // 判断reply id是否在当前processId列表中
                // 因为存在并发问题，如在执行Listener事件的同时，可能触发了process的创建，这时新建的processId会进入到reply队列中
                // 此时接受到的processIds变量为上一个版本的内容，所以会删除新建的process，导致整个通道被挂住
                if (CollectionUtils.isEmpty(processIds) == false) {
                    Long processId = processIds.get(0);
                    if (processId > (Long) replyId) { // 如果当前最小的processId都大于replyId, processId都是递增创建的
                        processTermined((Long) replyId); // 调用一下删除操作
                    }
                }
            }
        }
    }
740017
public SIBUuid8 getReplyingMeUuid() {
    byte[] b = (byte[])jmo.getField(TrmFirstContactAccess.BODY_MEBRIDGEREPLY_REPLYINGMEUUID);
    if (b != null)
      return new SIBUuid8(b);
    return null;
  }
1148980
protected void setReplyReliability(Reliability replyReliability) {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(this, tc, "setReplyReliability", replyReliability);
        this.replyReliabilityByte = replyReliability.toByte();
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(this, tc, "setReplyReliability");
    }
1095021
public CounterManagerConfigurationBuilder reliability(Reliability reliability) {
      attributes.attribute(CounterManagerConfiguration.RELIABILITY).set(reliability);
      return this;
   }
1010444
public void setReplyTo(String replyTo) {
        try {
            this.replyTo = new EndpointReference(new URI(replyTo));
        } catch (URISyntaxException e) {
            throw new CitrusRuntimeException("Invalid replyTo uri", e);
        }
    }
81929
public java.util.List<SendMessageBatchResultEntry> getSuccessful() {
        if (successful == null) {
            successful = new com.amazonaws.internal.SdkInternalList<SendMessageBatchResultEntry>();
        }
        return successful;
    }
209444
public static ReplyDetailWarpper getDummyTextReplyDetailWarpper() {
        ReplyDetail replyDetail = new ReplyDetail();
        replyDetail.setDescription("欢迎订阅javatech，这是微信公众平台开发模式的一个尝试，更多详情请见 https://github.com/usc/wechat-mp-sdk \n" +
                "Welcome subscribe javatech, this is an attempt to development model of wechat management platform, please via https://github.com/usc/wechat-mp-sdk to see more details");

        return new ReplyDetailWarpper("text", Arrays.asList(replyDetail));
    }