}
connectorConfig = new SocketConnectorConfig();
connectorConfig.getFilterChain().addLast("logger", new LoggingFilter());
connectorConfig.getFilterChain().addLast("serialization",
new ProtocolCodecFilter(new ObjectSerializationCodecFactory()));
LOCAL_ADDRESS = new InetSocketAddress("localhost", remotePort);
String processors = getProperty("pastrybroker.maxprocessors", "5");
SocketConnector clientConnector = new SocketConnector(Integer
.parseInt(processors), Executors.newCachedThreadPool());