logger.info("Created allocation on {}", peerSS.getLocalSocketAddress());
SocketListener peerSocketListener = new SocketListener(peerSS, Executors.newCachedThreadPool(),
new PeerHandlerTaskFactory(connIDToQueue, controlConnectionWriter, relayExecutor));
controlConnectionHandlerExecutor.execute(new RefreshMessageHandlerTask(controlConnection,
controlConnectionWriter, lifetime, peerSocketListener));
peerSocketListener.start();
Message successResponse = relayAllocationMessage.buildSuccessResponse();
successResponse.addAttribute(new XorMappedAddress(new InetSocketAddress(peerSS.getInetAddress(), peerSS
.getLocalPort())));
successResponse.addAttribute(new EndpointClass(EndpointCategory.RELAY));
successResponse.addAttribute(new RelayingLifetime(lifetime));