各位大神：
现在有一需要如下：A项目中的service层要调用B项目的一个方法，这个调用是利用Activemq的消息传递的，B项目处理完成后，将消息回复到A项目中activemq消息监听QUEUE上，而A项目的service层要将B处理的结果同步返回给调用者，
小弟我采用了两种方式，总感觉处理的不太舒服，求指导
第一种：采用加锁机制 ReentrantLock
第二种：采用了Spring 的DeferredResult,deferredResult在没有超时的的情况下，一直循环去断定是否被设置了值
DeferredResult deferredResult =newDeferredResult(5000L);
TaskDetail taskDetail =newTaskDetail("/login",deferredResult);
Task.addTask(correlationID,taskDetail);
deferredResult.onTimeout(newAsyncRequestTimeHandler(correlationID,taskDetail));
boolean hasReturn =false;
while(!hasReturn) {
hasReturn = deferredResult.hasResult();
}
JSONObject result = (JSONObject) deferredResult.getResult();
在Listener处做了如下处理：
if(Task.TASK_MAP.containsKey(correlationID)) {
longendTime = System.currentTimeMillis();
TaskDetail taskDetail = Task.TASK_MAP.get(correlationID);
longstartTime = taskDetail.getStartTime();
DeferredResult deferredResult = taskDetail.getResult();
deferredResult.setResult(json);
logger.info("correlationID:[{}] request normal,in {} ms.",correlationID,+(endTime - startTime));
Task.TASK_MAP.remove(correlationID);
}
