|
|
|
@ -26,9 +26,6 @@ public class ClientHandler { |
|
|
|
|
|
|
|
private static final Logger logger = LoggerFactory.getLogger(ClientHandler.class); |
|
|
|
|
|
|
|
private static final int PARTITIONS = 16; |
|
|
|
private static final String STREAM_KEY_PREFIX = "aeon_tcp_stream_"; |
|
|
|
|
|
|
|
private static final Random random = new Random(); |
|
|
|
|
|
|
|
private final MessageHandler messageHandler; |
|
|
|
|