【问题标题】:qpid how to configure receiverqpid如何配置接收器
【发布时间】:2016-10-17 13:02:34
【问题描述】:

我正在使用 Apache Qpid,我查看了示例,但在任何地方都找不到如何配置接收器,使其不会关闭连接并检查队列中是否有任何新消息.

【问题讨论】:

  • 你在使用 default_container 吗?消息处理程序?然后接收器不会关闭,直到你这样做。当您有新消息时,您应该使用 on_message 接收它。
  • @MertKoksal 我使用了示例示例,在那里他们描述了MessageConsumerConnectionFactory,它是打开的,在1000 ms 超时之后关闭

标签: java messaging qpid


【解决方案1】:

您似乎正在使用 Qpid JMS 客户端。它非常基本的示例,实际上只是显示了 JMS 中可用的各种组件,而不是代表性应用程序(因为这完全取决于您想要做什么),有一个简单的接收器,可以设置为执行同步 recieve() 调用超时,这样它就会等待很长时间来等待新消息(由示例的其他位发送),如果在超时内没有任何消息到达,则表示事情已经完成然后退出。

如果您想等待消息,您有多种选择,例如重复调用接收而不是像示例那样退出,调用具有更大超时的接收以避免它很快超时,或者甚至调用接收没有超时所有这样它都会在返回之前等待下一条消息所需的时间。或者,您可以为使用者注册一个异步 MessageListener,以便在消息到达时调用该侦听器。

您可以查阅任何 JMS 教程以获取有关这些概念的更多详细信息。

【讨论】:

    猜你喜欢
    • 2017-03-28
    • 1970-01-01
    • 2021-08-17
    • 2019-11-15
    • 1970-01-01
    • 2019-05-14
    • 1970-01-01
    • 2017-03-09
    • 1970-01-01
    相关资源
    最近更新 更多