+ verify(this.bgpPeerRegistry, times(2)).removePeer(any());
+ verify(this.future, times(2)).cancel(true);
+
+ this.bgpPeer.instantiateServiceInstance();
+ verify(this.bgpPeerRegistry, times(3)).addPeer(any(), any(), any());
+ verify(this.dispatcher, times(3)).createReconnectingClient(any(InetSocketAddress.class),
+ any(), anyInt(), any(KeyMapping.class));
+
+ this.bgpPeer.closeServiceInstance();
+ verify(this.bgpPeerRegistry, times(3)).removePeer(any());
+ verify(this.future, times(3)).cancel(true);