Skip to content

Commit

Permalink
Fixes unncessary client context creation per proxy
Browse files Browse the repository at this point in the history
  • Loading branch information
sancar committed Mar 21, 2017
1 parent 828dca4 commit 080bbea
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -118,6 +118,7 @@ public final class ProxyManager {
private final ConcurrentMap<String, ClientProxyFactory> proxyFactories = new ConcurrentHashMap<String, ClientProxyFactory>();
private final ConcurrentMap<ObjectNamespace, ClientProxyFuture> proxies
= new ConcurrentHashMap<ObjectNamespace, ClientProxyFuture>();
private final ClientContext context;

private final ListenerMessageCodec distributedObjectListenerCodec = new ListenerMessageCodec() {
@Override
Expand Down Expand Up @@ -151,6 +152,7 @@ public ProxyManager(HazelcastClientInstanceImpl client) {
}
}
}
context = new ClientContext(client, this);
}

public void init(ClientConfig config) {
Expand Down Expand Up @@ -345,7 +347,6 @@ private void initialize(ClientProxy clientProxy) throws Exception {
final Connection connection = getTargetOrOwnerConnection(initializationTarget);
final ClientMessage clientMessage = ClientCreateProxyCodec.encodeRequest(clientProxy.getDistributedObjectName(),
clientProxy.getServiceName(), initializationTarget);
final ClientContext context = new ClientContext(client, this);
new ClientInvocation(client, clientMessage, connection).invoke().get();
clientProxy.setContext(context);
clientProxy.onInitialize();
Expand Down

0 comments on commit 080bbea

Please sign in to comment.