|警告|传输连接至:tcp://ip:port 失败:org.apache.activemq.transport.InactivityIOException:

2024-10-02 10:33:52 发布

您现在位置:Python中文网/ 问答频道 /正文

| WARN  | Transport Connection to: tcp://ip:port failed: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long | org.apache.activemq.broker.TransportConnection.Transport | AmqpInactivityMonitor Async Task: java.util.concurrent.ThreadPoolExecutor$Worker@7e641927[State = -1, empty queue]

我正试图从java[publisher]向活动mq发送一条消息,该消息正在活动mq中排队。 订户代码是用python编写的[使用此库python qpid proton 0.31.0]。当没有向活动mq发送请求时,订阅服务器保持活动状态。但当请求发送到活动mq时,“活动持久主题订阅者”中的客户端在处理请求的某个时间后进入“脱机持久主题订阅者”。当在pycharm中运行相同的代码时,可以正常工作,但在exe上可以看到此问题 python接收器代码如下所示:-

P1 = Receiver(url, subscriptionname)
        from proton.reactor import Container
        Container(P1).run()


class Receiver(MessagingHandler):
super(Receiver, self).__init__()
    def __init__(self, url, subscriptionname):
        self.url = Url(url)
        self.stopping = False
        self.messages_actually_received = 0
        self.subscriptionName = subscriptionname

    def on_start(self, event):
        durable = DurableSubscription()
        event.container.container_id = "client"
        connection = event.container.connect(self.url)
        event.container.create_receiver(connection , self.url.path, name=self.subscriptionName, options=durable)
        

     def on_message(self, event):
        if self.stopping:
            return
        
        self.messages_actually_received += 1
        if event.message.body == 'message':
               pass

Tags: 代码orgselfeventurlmessageapachecontainer

热门问题