|
@@ -132,7 +132,7 @@ class Dataflow_ActivteMQ_attachment(Dataflow_attachment):
|
|
|
if attachment_size<100 and failed_attachment_size>0:
|
|
if attachment_size<100 and failed_attachment_size>0:
|
|
|
list_comsumer = []
|
|
list_comsumer = []
|
|
|
for _i in range(self.retry_comsumer_count):
|
|
for _i in range(self.retry_comsumer_count):
|
|
|
- listener_attachment = ActiveMQListener(getConnect_activateMQ(),self.queue_attachment)
|
|
|
|
|
|
|
+ listener_attachment = self.AttachmentMQListener(getConnect_activateMQ(),self.attachment_listener_handler,_i)
|
|
|
list_comsumer.append(listener_attachment)
|
|
list_comsumer.append(listener_attachment)
|
|
|
createComsumer(listener_attachment,self.mq_attachment_failed)
|
|
createComsumer(listener_attachment,self.mq_attachment_failed)
|
|
|
while 1:
|
|
while 1:
|
luojiehua