mirror of https://github.com/apache/activemq.git
small op
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@509720 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
341a1d4753
commit
76c466ddef
|
@ -43,7 +43,7 @@ public class ResponseCorrelator extends TransportFilter {
|
|||
|
||||
private final ConcurrentHashMap requestMap = new ConcurrentHashMap();
|
||||
private IntSequenceGenerator sequenceGenerator;
|
||||
|
||||
private final boolean debug = log.isDebugEnabled();
|
||||
public ResponseCorrelator(Transport next) {
|
||||
this(next, new IntSequenceGenerator());
|
||||
}
|
||||
|
@ -82,7 +82,7 @@ public class ResponseCorrelator extends TransportFilter {
|
|||
|
||||
public void onCommand(Object o) {
|
||||
Command command = (Command) o;
|
||||
boolean debug = log.isDebugEnabled();
|
||||
|
||||
if( command.isResponse() ) {
|
||||
Response response = (Response) command;
|
||||
FutureResponse future = (FutureResponse) requestMap.remove(new Integer(response.getCorrelationId()));
|
||||
|
|
Loading…
Reference in New Issue