1 package org.opendaylight.protocol.bgp.rib.impl;
3 import io.netty.channel.Channel;
4 import io.netty.util.Timer;
5 import io.netty.util.concurrent.Promise;
7 import org.opendaylight.protocol.bgp.parser.BGPSessionListener;
8 import org.opendaylight.protocol.bgp.rib.impl.spi.BGPSessionPreferences;
9 import org.opendaylight.protocol.framework.SessionListenerFactory;
10 import org.opendaylight.protocol.framework.SessionNegotiator;
11 import org.opendaylight.protocol.framework.SessionNegotiatorFactory;
12 import org.opendaylight.yangtools.yang.binding.Notification;
14 import com.google.common.base.Preconditions;
16 public final class BGPSessionNegotiatorFactory implements SessionNegotiatorFactory<Notification, BGPSessionImpl, BGPSessionListener> {
17 private final BGPSessionPreferences initialPrefs;
18 private final Timer timer;
20 public BGPSessionNegotiatorFactory(final Timer timer, final BGPSessionPreferences initialPrefs) {
21 this.timer = Preconditions.checkNotNull(timer);
22 this.initialPrefs = Preconditions.checkNotNull(initialPrefs);
26 public SessionNegotiator<BGPSessionImpl> getSessionNegotiator(final SessionListenerFactory<BGPSessionListener> factory,
27 final Channel channel, final Promise<BGPSessionImpl> promise) {
28 return new BGPSessionNegotiator(this.timer, promise, channel, this.initialPrefs, factory.getSessionListener());