Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
Use a concurrency of 1 for response routers [IMMUTANT-593]
Using numProcs is wasteful, since the listener just satisfies a future.
  • Loading branch information
tobias committed Nov 10, 2015
1 parent d172d0a commit 48de151
Showing 1 changed file with 1 addition and 0 deletions.
Expand Up @@ -79,6 +79,7 @@ public Response request(Object content, Codec codec,
final String nodeId = context != null ? context.id() : JMSMessagingSkeleton.BROKER_ID;
final ConcreteResponse response = new ConcreteResponse();
Options<ListenOption> routerOpts = new Options<>();
routerOpts.put(ListenOption.CONCURRENCY, 1);
routerOpts.put(ListenOption.SELECTOR,
JMSMessage.REQUEST_NODE_ID_PROPERTY + " = '" + nodeId + "' AND " +
JMSMessage.SYNC_RESPONSE_PROPERTY + " = TRUE");
Expand Down

0 comments on commit 48de151

Please sign in to comment.