Package org.opendaylight.protocol.bgp.rib.impl

Class BGPDispatcherImpl

java.lang.Object

org.opendaylight.protocol.bgp.rib.impl.BGPDispatcherImpl

All Implemented Interfaces:

AutoCloseable, BGPDispatcher

@Singleton
public final class BGPDispatcherImpl
extends Object
implements BGPDispatcher, AutoCloseable

Implementation of BGPDispatcher.

Constructor Summary

Constructors

Constructor	Description
BGPDispatcherImpl(BGPExtensionConsumerContext extensions, io.netty.channel.EventLoopGroup bossGroup, io.netty.channel.EventLoopGroup workerGroup, BGPPeerRegistry bgpPeerRegistry)

Method Summary

Modifier and Type	Method	Description
void	close()
io.netty.util.concurrent.Future<BGPSessionImpl>	createClient(InetSocketAddress localAddress, InetSocketAddress remoteAddress, int retryTimer, boolean reuseAddress)
io.netty.util.concurrent.Future<Void>	createReconnectingClient(InetSocketAddress remoteAddress, InetSocketAddress localAddress, int retryTimer, KeyMapping keys)	Creates Reconnecting client.
io.netty.channel.ChannelFuture	createServer(InetSocketAddress serverAddress)	Create new BGP server to accept incoming bgp connections (bound to provided socket localAddress).
BGPPeerRegistry	getBGPPeerRegistry()	Return BGP Peer Registry.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BGPDispatcherImpl

@Inject
public BGPDispatcherImpl(BGPExtensionConsumerContext extensions,
                         io.netty.channel.EventLoopGroup bossGroup,
                         io.netty.channel.EventLoopGroup workerGroup,
                         BGPPeerRegistry bgpPeerRegistry)

Method Detail

createClient

public io.netty.util.concurrent.Future<BGPSessionImpl> createClient(InetSocketAddress localAddress,
                                                                    InetSocketAddress remoteAddress,
                                                                    int retryTimer,
                                                                    boolean reuseAddress)

close

@PreDestroy
public void close()

Specified by:

close in interface AutoCloseable

createReconnectingClient

public io.netty.util.concurrent.Future<Void> createReconnectingClient(InetSocketAddress remoteAddress,
                                                                      InetSocketAddress localAddress,
                                                                      int retryTimer,
                                                                      KeyMapping keys)

Description copied from interface: BGPDispatcher

Creates Reconnecting client.

Specified by:

createReconnectingClient in interface BGPDispatcher

Parameters:

remoteAddress - remote Peer Address

localAddress - local Peer address

retryTimer - Retry timer

keys - for TCPMD5

Returns:

Future promising a client session

createServer

public io.netty.channel.ChannelFuture createServer(InetSocketAddress serverAddress)

Description copied from interface: BGPDispatcher

Create new BGP server to accept incoming bgp connections (bound to provided socket localAddress).

Specified by:

createServer in interface BGPDispatcher

Parameters:

serverAddress - Peer localAddress

Returns:

ChannelFuture promising a client session

getBGPPeerRegistry

public BGPPeerRegistry getBGPPeerRegistry()

Description copied from interface: BGPDispatcher

Return BGP Peer Registry.

Specified by:

getBGPPeerRegistry in interface BGPDispatcher

Returns:

BGPPeerRegistry