本文整理了Java中org.apache.mina.transport.socket.nio.NioSocketAcceptor.setFilterChainBuilder()
方法的一些代码示例,展示了NioSocketAcceptor.setFilterChainBuilder()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。NioSocketAcceptor.setFilterChainBuilder()
方法的具体详情如下:
包路径:org.apache.mina.transport.socket.nio.NioSocketAcceptor
类名称:NioSocketAcceptor
方法名:setFilterChainBuilder
暂无
代码示例来源:origin: org.eclipse.neoscada.core/org.eclipse.scada.core.server.ngp
public ServerBase ( final Collection<InetSocketAddress> addresses, final ProtocolConfigurationFactory protocolConfigurationFactory ) throws Exception
{
this.addresses = addresses;
this.acceptor = new NioSocketAcceptor ();
this.acceptor.setReuseAddress ( true );
this.chainBuilder = new FilterChainBuilder ( false );
this.chainBuilder.setLoggerName ( ServerBase.class.getName () + ".protocol" );
this.acceptor.setFilterChainBuilder ( this.chainBuilder );
this.acceptor.setHandler ( new ServerBaseHandler ( this, protocolConfigurationFactory.createConfiguration ( false ) ) );
}
代码示例来源:origin: com.synaptix/SynaptixServer
public void start() throws IOException {
NioSocketAcceptor acceptor = new NioSocketAcceptor();
DefaultIoFilterChainBuilder filterChainBuilder = new DefaultIoFilterChainBuilder();
// filterChainBuilder.addLast("executorFilter", new OrderedThreadPoolExecutor());
// filterChainBuilder.addLast("xmppCodec", new ProtocolCodecFilter(new XMPPProtocolCodecFactory()));
filterChainBuilder.addLast("xmppCodec", new ProtocolCodecFilter(new SynaptixXMPPProtocolCodecFactory()));
filterChainBuilder.addLast("loggingFilter", new StanzaLoggingFilter());
acceptor.setFilterChainBuilder(filterChainBuilder);
SynaptixXmppIoHandlerAdapter adapter = new SynaptixXmppIoHandlerAdapter();
adapter.setServerRuntimeContext(serverRuntimeContext);
acceptor.setHandler(adapter);
acceptor.setReuseAddress(true);
acceptor.bind(new InetSocketAddress(port));
this.acceptor = acceptor;
}
代码示例来源:origin: org.apache.vysper/vysper-core
public void start() throws IOException {
NioSocketAcceptor acceptor = new NioSocketAcceptor();
DefaultIoFilterChainBuilder filterChainBuilder = new DefaultIoFilterChainBuilder();
//filterChainBuilder.addLast("executorFilter", new OrderedThreadPoolExecutor());
filterChainBuilder.addLast("xmppCodec", new ProtocolCodecFilter(new XMPPProtocolCodecFactory()));
filterChainBuilder.addLast("loggingFilter", new StanzaLoggingFilter());
acceptor.setFilterChainBuilder(filterChainBuilder);
XmppIoHandlerAdapter adapter = new XmppIoHandlerAdapter();
adapter.setServerRuntimeContext(serverRuntimeContext);
acceptor.setHandler(adapter);
acceptor.setReuseAddress(true);
acceptor.bind(new InetSocketAddress(port));
this.acceptor = acceptor;
}
内容来源于网络,如有侵权,请联系作者删除!