|
@@ -37,6 +37,7 @@ import org.slf4j.LoggerFactory;
|
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
|
+import javax.annotation.PostConstruct;
|
|
|
import java.util.ArrayList;
|
|
|
import java.util.List;
|
|
|
import java.util.Map;
|
|
@@ -75,7 +76,7 @@ public class EtlMQConsumer {
|
|
|
this.etlService = etlService;
|
|
|
}
|
|
|
|
|
|
- // @PostConstruct
|
|
|
+ @PostConstruct
|
|
|
public void init() {
|
|
|
mqClient = new MQClient(httpEndpoint, accessKey, secretKey);
|
|
|
priorityPool = new ThreadPoolExecutor(Runtime.getRuntime().availableProcessors(), Runtime.getRuntime().availableProcessors() * 2, 60L,
|