| 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
目前没有回答
相关问题 更多 >
编程相关推荐