提交 a2f7a72f 编写于 作者: Y youyong205

modify the message id

上级 f09e1c1e
......@@ -90,6 +90,16 @@ public class MessageIdFactory {
}
File mark = new File("/data/appdatas/cat/", "cat-" + domain + ".mark");
if (!mark.exists()) {
boolean success = mark.createNewFile();
if (!success) {
String tmpDir = System.getProperty("java.io.tmpdir");
mark = new File(tmpDir, "cat-" + domain + ".mark");
}
}
m_markFile = new RandomAccessFile(mark, "rw");
m_byteBuffer = m_markFile.getChannel().map(MapMode.READ_WRITE, 0, 20);
......
......@@ -4,6 +4,8 @@ import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import org.codehaus.plexus.personality.plexus.lifecycle.phase.Initializable;
import org.codehaus.plexus.personality.plexus.lifecycle.phase.InitializationException;
import org.unidal.dal.jdbc.DalException;
import org.unidal.dal.jdbc.DalNotFoundException;
import org.unidal.lookup.annotation.Inject;
......@@ -20,7 +22,7 @@ import com.dianping.cat.home.dal.user.DpAdminLoginDao;
import com.dianping.cat.home.dal.user.DpAdminLoginEntity;
import com.dianping.cat.system.page.alarm.UserReportSubState.UserReportSubStateCompartor;
public class ScheduledManager {
public class ScheduledManager implements Initializable{
@Inject
private DpAdminLoginDao m_loginDao;
......@@ -164,4 +166,8 @@ public class ScheduledManager {
model.setOpState(Handler.FAIL);
}
}
@Override
public void initialize() throws InitializationException {
}
}
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册