dianping/camel
1
1
Fork 0
mirror of https://github.com/dianping/camel.git synced 2024-09-20 06:56:03 +08:00
Code Issues Packages Projects Releases Wiki Activity

add fetch status api

Browse source
This commit is contained in:
leon.li 2016-08-31 14:50:16 +08:00
parent 6de97fa8c4
commit f0698058b4
2 changed files with 21 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
camel-agent/src/main/java/com/dianping/platform/slb/agent/web/controller/ApiController.java
View file

@ -8,6 +8,7 @@ import com.dianping.platform.slb.agent.task.model.SubmitResult;
import com.dianping.platform.slb.agent.task.model.config.upgrade.ConfigUpgradeTask;
import com.dianping.platform.slb.agent.task.processor.TransactionProcessor;
import com.dianping.platform.slb.agent.transaction.Transaction;
import com.dianping.platform.slb.agent.transaction.manager.TransactionManager;
import com.dianping.platform.slb.agent.web.api.API;
import com.dianping.platform.slb.agent.web.model.Response;
import com.dianping.platform.slb.agent.web.wrapper.ResponseAction;
@ -45,6 +46,9 @@ public class ApiController implements API {
@Autowired
private TransactionProcessor m_transactionProcessor;
@Autowired
private TransactionManager m_transactionManager;
@Override
@RequestMapping(params = "op=deploy", method = RequestMethod.POST)
public Response deploy(
@ -112,8 +116,18 @@ public class ApiController implements API {
}
@Override
public Response fetchStatus(long deployId) {
return null;
public Response fetchStatus(final long deployId) {
final Response response = new Response();
return m_responseAction.doTransaction(response, "load transaction error", new Wrapper<Response>() {
@Override
public Response doAction() throws Exception {
Transaction transaction = m_transactionManager.loadTransaction(deployId);
response.setStatus(transaction.getStatus().toString().toLowerCase());
return response;
}
});
}
@Override

6
camel-agent/src/main/java/com/dianping/platform/slb/agent/web/model/Response.java
View file

@ -17,7 +17,11 @@ public class Response {
}
public void setStatus(Status status) {
this.status = status.getMessage();
setStatus(status.getMessage());
}
public void setStatus(String status) {
this.status = status;
}
public String getMessage() {