0

我在我的项目中使用 WSO2 消息代理作为消息代理系统。为了获取队列浏览信息,我从AndesAdminServics WSDL生成了客户端,并尝试从我的 api调用 AndesAdminServicePortTypeProxy类的 browseQueue() 方法。生成的 browseQueue() 方法是

public org.wso2.carbon.andes.admin.internal.xsd.Message[] browseQueue(java.lang.String queueName, java.lang.Long nextMessageIdToRead, java.lang.Integer maxMsgCount) throws java.rmi.RemoteException{
    if (andesAdminServicePortType == null)
      _initAndesAdminServicePortTypeProxy();
    return andesAdminServicePortType.browseQueue(queueName, nextMessageIdToRead, maxMsgCount);
  }

browseQueue() 方法采用三个参数 - java.lang.String queueName、java.lang.Long nextMessageIdToRead、java.lang.Integer maxMsgCount

我了解参数 queueName,但我没有得到,参数 nextMessageIdToRead 和 maxMsgCount 代表什么。在browseQueue() 方法调用时,我应该传递什么作为参数。

4

1 回答 1

0

您可以参考实际的管理服务代码。那里包含更多信息 https://github.com/wso2/andes/blob/b721d5cccfd9896ec871610b7938ba96785b202c/modules/andes-core/management/common/src/main/java/org/wso2/andes/management/common/mbeans/QueueManagementInformation .java#L162

  1. name = "queueName", description = "浏览消息的队列名称"
  2. name = "lastMsgId", description = "从这里开始浏览消息"
  3. name = "maxMsgCount", description = "每个请求的最大消息数"
于 2016-07-08T12:13:43.093 回答