連接到耐用消費者 - Qpid質子Python

我試圖讓Qpid Proton Python客戶端通過AMQP v1.0訂閱ActiveMQ代理作爲持久使用者。連接到耐用消費者 - Qpid質子Python

我可以創建持久訂閱，但不太明白如何在下次運行腳本時獲取相同訂閱。

每次運行後，ActiveMQ管理控制檯都會顯示已創建一個持久預訂，並且根據我的腳本輸入命名，但下一次運行只是創建另一個，而不是連接到之前創建的預定。

我想我可能會錯過創建「ClientID」（如ActiveMQ所稱的），但無法看到（在Qpid質子文檔中）如何設置它。

這裏是我的代碼： -

def on_start(self, event): 
    if self.subscription_name: 
     logging.debug("Naming durable subscription " + self.subscription_name) 
     durable = DurableSubscription() 
    else: 
     logging.debug("Subscription will not be durable") 
     durable = None 

    messaging_connection = event.container.connect(self.url) 
    logging.info(messaging_connection.clientID) 
    event.container.create_receiver(
     messaging_connection, 
     self.resource, 
     name=self.subscription_name, 
     options=durable 
    ) 
    logging.debug("Connected to " + self.url + "/" + self.resource)

來源

2017-02-13 Jeremy Gooch