|
From: Alex W. <ale...@gm...> - 2018-11-20 00:33:08
|
Hi Christoph,
I should also mention that we are using ThreadedSocketAcceptor. So, it
looks roughly like:
Acceptor acceptor = new ThreadedSocketAcceptor(application,
messageStoreFactory, settings, logFactory, messageFactory);
for (final SessionID sessionID : (Iterable<SessionID>)
settings::sectionIterator){
final int acceptPort = (int) settings.getLong(sessionID,
Acceptor.SETTING_SOCKET_ACCEPT_PORT);
if (settings.getBool(sessionID,
Acceptor.SETTING_ACCEPTOR_TEMPLATE)) {
final AcceptorSessionProvider
dynamicAcceptorSessionProvider = new
DynamicAcceptorSessionProvider(settings, sessionID, application,
messageStoreFactory, logFactory, messageFactory);
acceptor.setSessionProvider(new
InetSocketAddress(acceptPort), dynamicAcceptorSessionProvider);
}
}
The example and the test included in the project is using SocketAcceptor
(instead of ThreadedSocketAcceptor).
Regards,
Alex
|