- public synchronized Future<BGPSessionImpl> createClient(final InetSocketAddress address,
- final AsNumber remoteAs, final BGPPeerRegistry listener, final ReconnectStrategy strategy) {
- final BGPClientSessionNegotiatorFactory snf = new BGPClientSessionNegotiatorFactory(remoteAs, listener);
- final ChannelPipelineInitializer initializer = BGPChannel.createChannelPipelineInitializer
- (BGPDispatcherImpl.this.hf.getDecoders(), snf, BGPDispatcherImpl.this.hf.getEncoders());
-
- final Bootstrap b = new Bootstrap();
- final BGPProtocolSessionPromise p = new BGPProtocolSessionPromise(this.executor, address, strategy, b);
- b.option(ChannelOption.SO_KEEPALIVE, Boolean.valueOf(true));
- b.handler(BGPChannel.createChannelInitializer(initializer, p));
- this.customizeBootstrap(b);
- this.setWorkerGroup(b);
- p.connect();
- LOG.debug("Client created.");
- return p;
+ public synchronized Future<BGPSessionImpl> createClient(final InetSocketAddress remoteAddress, final BGPPeerRegistry listener, final int retryTimer) {
+ return createClient(remoteAddress, listener, retryTimer, createClientBootStrap(Optional.absent(), false));