Skip to content

Commit

Permalink
No commit message
Browse files Browse the repository at this point in the history
  • Loading branch information
chj9 committed Jan 3, 2019
1 parent 1781787 commit 2d3304c
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 4 deletions.
2 changes: 1 addition & 1 deletion src/main/java/com/chenhj/dao/ConnectionManager.java
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@
*/
public class ConnectionManager {
private static Logger LOG = LoggerFactory.getLogger(ConnectionManager.class);
/** 定义c3p0 连接池的数据源 */
/** 定义连接池的数据源 */
private static DruidDataSource cpds =null;
private static volatile ConnectionManager dbConnection;
/**
Expand Down
4 changes: 1 addition & 3 deletions src/main/java/com/chenhj/job/ThreadUtil.java
Original file line number Diff line number Diff line change
Expand Up @@ -25,9 +25,7 @@ public ThreadUtil() throws Exception {
nThreads = Config.COMMON_CONFIG.getThread_size();
}
/**
* 启动topic所有分区的消费
* @param topic
* 需要启动消费的topic名
* 启动所有线程池
* @throws Exception
*/
public void startConsume() throws Exception{
Expand Down

0 comments on commit 2d3304c

Please sign in to comment.