|
@@ -554,7 +554,7 @@ class Dataflow_ActivteMQ_extract(Dataflow_extract):
|
|
|
|
|
|
self.industy_url = "http://127.0.0.1:15000/industry_extract"
|
|
|
|
|
|
- self.extract_interfaces = [["http://127.0.0.1:15030/content_extract",20],
|
|
|
+ self.extract_interfaces = [["http://127.0.0.1:15030/content_extract",30],
|
|
|
["http://192.168.0.115:15030/content_extract",10]
|
|
|
]
|
|
|
|
|
@@ -575,7 +575,7 @@ class Dataflow_ActivteMQ_extract(Dataflow_extract):
|
|
|
self.block_url = RLock()
|
|
|
self.url_count = 0
|
|
|
|
|
|
- self.comsumer_count = 40
|
|
|
+ self.comsumer_count = 45
|
|
|
self.list_extract_comsumer = []
|
|
|
for _i in range(self.comsumer_count):
|
|
|
listener_extract = self.ExtractListener(getConnect_activateMQ(),self.comsumer_handle)
|