<capability>urn:opendaylight:params:xml:ns:yang:controller:bgp:parser:spi?module=odl-bgp-parser-spi-cfg&revision=2013-11-15</capability>
<capability>urn:opendaylight:params:xml:ns:yang:controller:bgp:rib:spi?module=odl-bgp-rib-spi-cfg&revision=2013-11-15</capability>
<capability>urn:opendaylight:params:xml:ns:yang:controller:bgp:rib:impl?module=odl-bgp-rib-impl-cfg&revision=2016-03-30</capability>
- <capability>urn:opendaylight:params:xml:ns:yang:controller:md:sal:binding?module=opendaylight-md-sal-binding&revision=2013-10-28</capability>
- <capability>urn:opendaylight:params:xml:ns:yang:controller:netty?module=netty&revision=2013-11-19</capability>
<capability>urn:opendaylight:params:xml:ns:yang:controller:rsvp:spi?module=odl-rsvp-parser-spi-cfg&revision=2015-08-26</capability>
</required-capabilities>
<configuration>
<module>
<type xmlns:prefix="urn:opendaylight:params:xml:ns:yang:controller:bgp:rib:impl">prefix:bgp-dispatcher-impl</type>
<name>global-bgp-dispatcher</name>
- <bgp-extensions>
- <type xmlns:bgpspi="urn:opendaylight:params:xml:ns:yang:controller:bgp:parser:spi">bgpspi:extensions</type>
- <name>global-bgp-extensions</name>
- </bgp-extensions>
- <boss-group>
- <type xmlns:netty="urn:opendaylight:params:xml:ns:yang:controller:netty">netty:netty-threadgroup</type>
- <name>global-boss-group</name>
- </boss-group>
- <worker-group>
- <type xmlns:netty="urn:opendaylight:params:xml:ns:yang:controller:netty">netty:netty-threadgroup</type>
- <name>global-worker-group</name>
- </worker-group>
-
- <!--
- Uncomment this block to enable TCP MD5 Signature support
-
- <md5-channel-factory>
- <type xmlns:prefix="urn:opendaylight:params:xml:ns:yang:controller:tcpmd5:netty:cfg">prefix:md5-channel-factory</type>
- <name>md5-client-channel-factory</name>
- </md5-channel-factory>
-
- <md5-server-channel-factory>
- <type xmlns:prefix="urn:opendaylight:params:xml:ns:yang:controller:tcpmd5:netty:cfg">prefix:md5-server-channel-factory</type>
- <name>md5-server-channel-factory</name>
- </md5-server-channel-factory>
- -->
</module>
<module>
*/
package org.opendaylight.controller.config.yang.bgp.rib.impl;
-import org.opendaylight.protocol.bgp.parser.spi.BGPExtensionConsumerContext;
-import org.opendaylight.protocol.bgp.rib.impl.BGPDispatcherImpl;
+import com.google.common.reflect.AbstractInvocationHandler;
+import com.google.common.reflect.Reflection;
+import java.lang.reflect.Method;
+import org.opendaylight.controller.config.api.osgi.WaitingServiceTracker;
+import org.opendaylight.protocol.bgp.rib.impl.spi.BGPDispatcher;
+import org.osgi.framework.BundleContext;
/**
- *
+ * @deprecated Replaced by blueprint wiring but remains for backwards compatibility until downstream users
+ * of the provided config system service are converted to blueprint.
*/
+@Deprecated
public final class BGPDispatcherImplModule extends org.opendaylight.controller.config.yang.bgp.rib.impl.AbstractBGPDispatcherImplModule {
+ private BundleContext bundleContext;
public BGPDispatcherImplModule(final org.opendaylight.controller.config.api.ModuleIdentifier name,
final org.opendaylight.controller.config.api.DependencyResolver dependencyResolver) {
}
@Override
- public java.lang.AutoCloseable createInstance() {
- final BGPExtensionConsumerContext bgpExtensions = getBgpExtensionsDependency();
- return new BGPDispatcherImpl(bgpExtensions.getMessageRegistry(), getBossGroupDependency(), getWorkerGroupDependency());
+ public AutoCloseable createInstance() {
+ // The BGPDispatcher instance is created and advertised as an OSGi service via blueprint
+ // so obtain it here (waiting if necessary).
+ final WaitingServiceTracker<BGPDispatcher> tracker =
+ WaitingServiceTracker.create(BGPDispatcher.class, bundleContext);
+ final BGPDispatcher service = tracker.waitForService(WaitingServiceTracker.FIVE_MINUTES);
+
+ // Create a proxy to override close to close the ServiceTracker. The actual BGPDispatcher
+ // instance will be closed via blueprint.
+ return Reflection.newProxy(AutoCloseableBGPDispatcher.class, new AbstractInvocationHandler() {
+ @Override
+ protected Object handleInvocation(Object proxy, Method method, Object[] args) throws Throwable {
+ if (method.getName().equals("close")) {
+ tracker.close();
+ return null;
+ } else {
+ return method.invoke(service, args);
+ }
+ }
+ });
+ }
+
+ void setBundleContext(BundleContext bundleContext) {
+ this.bundleContext = bundleContext;
+ }
+
+ private static interface AutoCloseableBGPDispatcher extends BGPDispatcher, AutoCloseable {
}
}
*/
package org.opendaylight.controller.config.yang.bgp.rib.impl;
+import org.opendaylight.controller.config.api.DependencyResolver;
+import org.osgi.framework.BundleContext;
+
/**
-*
-*/
-public class BGPDispatcherImplModuleFactory extends
- org.opendaylight.controller.config.yang.bgp.rib.impl.AbstractBGPDispatcherImplModuleFactory {
+ * @deprecated Replaced by blueprint wiring but remains for backwards compatibility until downstream users
+ * of the provided config system service are converted to blueprint.
+ */
+@Deprecated
+public class BGPDispatcherImplModuleFactory extends AbstractBGPDispatcherImplModuleFactory {
+ @Override
+ public BGPDispatcherImplModule instantiateModule(String instanceName, DependencyResolver dependencyResolver,
+ BGPDispatcherImplModule oldModule, AutoCloseable oldInstance, BundleContext bundleContext) {
+ BGPDispatcherImplModule module = super.instantiateModule(instanceName, dependencyResolver, oldModule,
+ oldInstance, bundleContext);
+ module.setBundleContext(bundleContext);
+ return module;
+ }
+ @Override
+ public BGPDispatcherImplModule instantiateModule(String instanceName, DependencyResolver dependencyResolver,
+ BundleContext bundleContext) {
+ BGPDispatcherImplModule module = super.instantiateModule(instanceName, dependencyResolver, bundleContext);
+ module.setBundleContext(bundleContext);
+ return module;
+ }
}
<service ref="RIBActivator" interface="org.opendaylight.protocol.bgp.rib.spi.RIBExtensionProviderActivator"
odl:type="org.opendaylight.protocol.bgp.rib.impl.RIBActivator"/>
+
+ <reference id="BGPExtensionContext" interface="org.opendaylight.protocol.bgp.parser.spi.BGPExtensionConsumerContext"/>
+ <reference id="globalBossGroup" interface="io.netty.channel.EventLoopGroup" odl:type="global-boss-group"/>
+ <reference id="globalWorkerGroup" interface="io.netty.channel.EventLoopGroup" odl:type="global-worker-group"/>
+
+ <bean id="BGPDispatcher" class="org.opendaylight.protocol.bgp.rib.impl.BGPDispatcherImpl">
+ <argument>
+ <bean factory-ref="BGPExtensionContext" factory-method="getMessageRegistry"/>
+ </argument>
+ <argument ref="globalBossGroup"/>
+ <argument ref="globalWorkerGroup"/>
+ </bean>
+
+ <service ref="BGPDispatcher" interface="org.opendaylight.protocol.bgp.rib.impl.spi.BGPDispatcher"/>
</blueprint>
\ No newline at end of file
base "config:service-type";
config:java-class "org.opendaylight.protocol.bgp.rib.impl.spi.BGPDispatcher";
+ config:disable-osgi-service-registration;
}
identity bgp-dispatcher-impl {
augment "/config:modules/config:module/config:configuration" {
case bgp-dispatcher-impl {
when "/config:modules/config:module/config:type = 'bgp-dispatcher-impl'";
-
- container bgp-extensions {
- uses config:service-ref {
- refine type {
- mandatory true;
- config:required-identity bgpspi:consumer-extensions;
- }
- }
- }
-
- container boss-group {
- uses config:service-ref {
- refine type {
- mandatory true;
- config:required-identity netty:netty-threadgroup;
- }
- }
- }
-
- container worker-group {
- uses config:service-ref {
- refine type {
- mandatory true;
- config:required-identity netty:netty-threadgroup;
- }
- }
- }
}
}
package org.opendaylight.controller.config.yang.bgp.rib.impl;
import static org.mockito.Matchers.any;
+import static org.mockito.Matchers.anyInt;
import static org.mockito.Matchers.anyString;
import static org.mockito.Matchers.contains;
import static org.mockito.Mockito.doAnswer;
import static org.mockito.Mockito.doNothing;
import static org.mockito.Mockito.doReturn;
import static org.mockito.Mockito.mock;
+import com.google.common.base.Optional;
import com.google.common.collect.Lists;
import com.google.common.io.ByteSource;
import com.google.common.io.Resources;
import com.google.common.util.concurrent.CheckedFuture;
import io.netty.channel.EventLoopGroup;
import io.netty.util.concurrent.EventExecutor;
+import io.netty.util.concurrent.ImmediateEventExecutor;
+import io.netty.util.concurrent.SucceededFuture;
import java.io.IOException;
+import java.net.InetSocketAddress;
import java.net.URL;
import java.util.ArrayList;
import java.util.Collection;
import org.opendaylight.controller.sal.core.api.model.YangTextSourceProvider;
import org.opendaylight.protocol.bgp.parser.spi.BGPExtensionProviderContext;
import org.opendaylight.protocol.bgp.parser.spi.MessageRegistry;
+import org.opendaylight.protocol.bgp.rib.impl.spi.BGPDispatcher;
+import org.opendaylight.protocol.bgp.rib.impl.spi.BGPPeerRegistry;
import org.opendaylight.protocol.bgp.rib.spi.RIBExtensionProviderContext;
import org.opendaylight.protocol.bgp.rib.spi.SimpleRIBExtensionProviderContext;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Address;
@Mock
private RpcResult<TransactionStatus> mockedResult;
+ @Mock
+ protected BGPDispatcher mockedBGPDispatcher;
+
@SuppressWarnings("unchecked")
@Before
public void setUp() throws Exception {
setupMockService(DOMRpcProviderService.class, mock(DOMRpcProviderService.class));
setupMockService(DOMMountPointService.class, mock(DOMMountPointService.class));
+ setupMockService(BGPDispatcher.class, mockedBGPDispatcher);
+ doReturn(new SucceededFuture<>(ImmediateEventExecutor.INSTANCE, null)).when(mockedBGPDispatcher).createReconnectingClient(
+ any(InetSocketAddress.class), any(BGPPeerRegistry.class), anyInt(), any(Optional.class));
+
setupMockService(RIBExtensionProviderContext.class, new SimpleRIBExtensionProviderContext());
}
mxBean.setDataProvider(dataBroker);
mxBean.setDomDataProvider(lookupDomAsyncDataBroker(transaction));
mxBean.setCodecTreeFactory(lookupMappingServiceInstance(transaction));
- mxBean.setBgpDispatcher(BGPDispatcherImplModuleTest.createInstance(transaction));
+ mxBean.setBgpDispatcher(createBGPDispatcherImplInstance(transaction));
mxBean.setExtensions(createRibExtensionsInstance(transaction));
mxBean.setRibId(ribId);
mxBean.setLocalAs(localAs);
return nameCreated;
}
+ public static ObjectName createBGPDispatcherImplInstance(final ConfigTransactionJMXClient transaction) throws InstanceAlreadyExistsException {
+ final ObjectName nameCreated = transaction.createModule(BGPDispatcherImplModuleFactory.NAME, "bgp-message-fct");
+ final BGPDispatcherImplModuleMXBean mxBean = transaction.newMXBeanProxy(nameCreated, BGPDispatcherImplModuleMXBean.class);
+ return nameCreated;
+ }
+
protected ObjectName createRIBImplModuleInstance(final ConfigTransactionJMXClient transaction) throws Exception {
return createRIBImplModuleInstance(transaction, RIB_ID, 5000L, BGP_ID, CLUSTER_ID,
createAsyncDataBrokerInstance(transaction));
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;
-
import java.util.List;
-
import javax.management.InstanceNotFoundException;
import javax.management.ObjectName;
-
import org.junit.Test;
import org.opendaylight.controller.config.api.jmx.CommitStatus;
import org.opendaylight.controller.config.spi.ModuleFactory;
public class BGPApplicationPeerModuleTest extends AbstractRIBImplModuleTest {
+ private static final int EXP_INSTANCES = 8;
private static final String INSTANCE_NAME = "application-peer-instance";
private static final String INSTANCE_NAME2 = "application-peer-instance-2";
private static final String FACTORY_NAME = BGPApplicationPeerModuleFactory.NAME;
public void testCreateInstance() throws Exception {
final CommitStatus status = createApplicationPeerInstance();
assertBeanCount(1, FACTORY_NAME);
- assertStatus(status, 11, 0, 0);
+ assertStatus(status, EXP_INSTANCES, 0, 0);
}
@Test
assertBeanCount(1, FACTORY_NAME);
final CommitStatus status = transaction.commit();
assertBeanCount(1, FACTORY_NAME);
- assertStatus(status, 0, 0, 11);
+ assertStatus(status, 0, 0, EXP_INSTANCES);
}
@Test
mxBean.setApplicationRibId(new ApplicationRibId(NEW_APP_RIB_ID));
final CommitStatus status = transaction.commit();
assertBeanCount(1, FACTORY_NAME);
- assertStatus(status, 0, 1, 10);
+ assertStatus(status, 0, 1, EXP_INSTANCES - 1);
assertEquals(NEW_APP_RIB_ID, getApplicationRibId());
}
+++ /dev/null
-/*
- * Copyright (c) 2013 Cisco Systems, Inc. and others. All rights reserved.
- *
- * This program and the accompanying materials are made available under the
- * terms of the Eclipse Public License v1.0 which accompanies this distribution,
- * and is available at http://www.eclipse.org/legal/epl-v10.html
- */
-package org.opendaylight.controller.config.yang.bgp.rib.impl;
-
-import javax.management.InstanceAlreadyExistsException;
-import javax.management.ObjectName;
-import org.junit.Test;
-import org.opendaylight.controller.config.api.jmx.CommitStatus;
-import org.opendaylight.controller.config.util.ConfigTransactionJMXClient;
-import org.opendaylight.controller.config.yang.bgp.parser.spi.SimpleBGPExtensionProviderContextModuleFactory;
-import org.opendaylight.controller.config.yang.bgp.parser.spi.SimpleBGPExtensionProviderContextModuleMXBean;
-import org.opendaylight.controller.config.yang.netty.threadgroup.NettyThreadgroupModuleFactory;
-import org.opendaylight.controller.config.yang.netty.threadgroup.NettyThreadgroupModuleMXBean;
-
-public class BGPDispatcherImplModuleTest extends AbstractRIBImplModuleTest {
-
- private static final String INSTANCE_NAME = "bgp-message-fct";
- private static final String FACTORY_NAME = BGPDispatcherImplModuleFactory.NAME;
-
- private static final String BGP_EXTENSION_INSTANCE_NAME = "bgp-extension-impl";
- private static final String BOSS_TG_INSTANCE_NAME = "boss-threadgroup-impl";
- private static final String WORKER_TG_INSTANCE_NAME = "worker-threadgroup-impl";
-
- @Test
- public void testCreateBean() throws Exception {
- final CommitStatus status = createInstance();
- assertBeanCount(1, FACTORY_NAME);
- assertStatus(status, 4, 0, 0);
- }
-
- @Test
- public void testReusingOldInstance() throws Exception {
- createInstance();
- final ConfigTransactionJMXClient transaction = this.configRegistryClient.createTransaction();
- assertBeanCount(1, FACTORY_NAME);
- final CommitStatus status = transaction.commit();
- assertBeanCount(1, FACTORY_NAME);
- assertStatus(status, 0, 0, 4);
- }
-
- @Override
- protected CommitStatus createInstance() throws Exception {
- final ConfigTransactionJMXClient transaction = this.configRegistryClient.createTransaction();
- createInstance(transaction);
- return transaction.commit();
- }
-
- public static ObjectName createInstance(final ConfigTransactionJMXClient transaction) throws InstanceAlreadyExistsException {
- final ObjectName nameCreated = transaction.createModule(FACTORY_NAME, INSTANCE_NAME);
- final BGPDispatcherImplModuleMXBean mxBean = transaction.newMXBeanProxy(nameCreated, BGPDispatcherImplModuleMXBean.class);
- mxBean.setBossGroup(createThreadgroupInstance(transaction, BOSS_TG_INSTANCE_NAME, 10));
- mxBean.setWorkerGroup(createThreadgroupInstance(transaction, WORKER_TG_INSTANCE_NAME, 10));
- mxBean.setBgpExtensions(createBgpExtensionsInstance(transaction));
- return nameCreated;
- }
-
- private static ObjectName createThreadgroupInstance(final ConfigTransactionJMXClient transaction, final String instanceName,
- final Integer threadCount) throws InstanceAlreadyExistsException {
- final ObjectName nameCreated = transaction.createModule(NettyThreadgroupModuleFactory.NAME, instanceName);
- final NettyThreadgroupModuleMXBean mxBean = transaction.newMXBeanProxy(nameCreated, NettyThreadgroupModuleMXBean.class);
- mxBean.setThreadCount(threadCount);
- return nameCreated;
- }
-
- private static ObjectName createBgpExtensionsInstance(final ConfigTransactionJMXClient transaction)
- throws InstanceAlreadyExistsException {
- final ObjectName nameCreated = transaction.createModule(SimpleBGPExtensionProviderContextModuleFactory.NAME, BGP_EXTENSION_INSTANCE_NAME);
- transaction.newMXBeanProxy(nameCreated, SimpleBGPExtensionProviderContextModuleMXBean.class);
- return nameCreated;
- }
-}
@Override
protected AutoCloseable prepareMockedInstance() throws Exception {return dispatcher;}
-
- @Override
- public ObjectName getWorkerGroup() {return null;}
-
- @Override
- public void setWorkerGroup(final ObjectName workerGroup) {}
-
- @Override
- public ObjectName getBgpExtensions() {return null;}
-
- @Override
- public void setBgpExtensions(final ObjectName bgpExtensions) {}
-
- @Override
- public ObjectName getBossGroup() {return null;}
-
- @Override
- public void setBossGroup(final ObjectName bossGroup) {}
}
}
import java.util.List;
import javax.management.InstanceAlreadyExistsException;
import javax.management.ObjectName;
+import org.junit.Assert;
import org.junit.Test;
import org.opendaylight.controller.config.api.IdentityAttributeRef;
import org.opendaylight.controller.config.api.ValidationException;
public class BGPPeerModuleTest extends AbstractRIBImplModuleTest {
+ private static final int EXP_INSTANCES = 18;
private static final String INSTANCE_NAME = "bgp-peer-module-impl";
private static final String FACTORY_NAME = BGPPeerModuleFactory.NAME;
public void testCreateBean() throws Exception {
final CommitStatus status = createBgpPeerInstance();
assertBeanCount(1, FACTORY_NAME);
- assertStatus(status, 21, 0, 0);
+ assertStatus(status, EXP_INSTANCES, 0, 0);
}
@Test
assertBeanCount(1, FACTORY_NAME);
status = transaction.commit();
assertBeanCount(1, FACTORY_NAME);
- assertStatus(status, 0, 0, 21);
+ assertStatus(status, 0, 0, EXP_INSTANCES);
}
@Test
mxBean.setPort(new PortNumber(10));
status = transaction.commit();
assertBeanCount(1, FACTORY_NAME);
- assertStatus(status, 0, 1, 20);
+ assertStatus(status, 0, 1, EXP_INSTANCES - 1);
}
private ObjectName createBgpPeerInstance(final ConfigTransactionJMXClient transaction, final IpAddress host,
import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;
-
import org.junit.Test;
import org.opendaylight.controller.config.api.ValidationException;
import org.opendaylight.controller.config.api.jmx.CommitStatus;
import org.opendaylight.controller.config.util.ConfigTransactionJMXClient;
public class RIBImplModuleTest extends AbstractRIBImplModuleTest {
+ private static final int EXP_INSTANCES = 7;
private static final String INSTANCE_NAME = "rib-impl";
private static final String FACTORY_NAME = RIBImplModuleFactory.NAME;
public void testCreateBean() throws Exception {
final CommitStatus status = createInstance();
assertBeanCount(1, FACTORY_NAME);
- assertStatus(status, 10, 0, 0);
+ assertStatus(status, EXP_INSTANCES, 0, 0);
}
@Test
assertBeanCount(1, FACTORY_NAME);
final CommitStatus status = transaction.commit();
assertBeanCount(1, FACTORY_NAME);
- assertStatus(status, 0, 0, 10);
+ assertStatus(status, 0, 0, EXP_INSTANCES);
}
@Test
mxBean.setLocalAs(100L);
final CommitStatus status = transaction.commit();
assertBeanCount(1, FACTORY_NAME);
- assertStatus(status, 0, 1, 9);
+ assertStatus(status, 0, 1, EXP_INSTANCES - 1);
}
}
base "config:service-type";
config:java-class "org.opendaylight.protocol.bgp.rib.spi.RIBExtensionConsumerContext";
+ config:disable-osgi-service-registration;
}
identity extensions {
base "consumer-extensions";
config:java-class "org.opendaylight.protocol.bgp.rib.spi.RIBExtensionProviderContext";
+ config:disable-osgi-service-registration;
}
identity extension {
import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;
-
import java.util.List;
import javax.management.ObjectName;
import org.junit.Test;
public void testCreateBean() throws Exception {
final CommitStatus status = createIpv4ReachabilityTopoBuilderModuleInstance();
assertBeanCount(1, FACTORY_NAME);
- assertStatus(status, 11, 0, 0);
+ assertStatus(status, 8, 0, 0);
}
@Test
assertBeanCount(1, FACTORY_NAME);
final CommitStatus status = transaction.commit();
assertBeanCount(1, FACTORY_NAME);
- assertStatus(status, 0, 0, 11);
+ assertStatus(status, 0, 0, 8);
}
@Test
mxBean.setTopologyId(new TopologyId("new-bgp-topology"));
final CommitStatus status = transaction.commit();
assertBeanCount(1, FACTORY_NAME);
- assertStatus(status, 0, 1, 10);
+ assertStatus(status, 0, 1, 7);
}
private CommitStatus createIpv4ReachabilityTopoBuilderModuleInstance() throws Exception {
import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;
-
import java.util.List;
import javax.management.ObjectName;
import org.junit.Test;
public void testCreateBean() throws Exception {
final CommitStatus status = createIpv6ReachabilityTopoBuilderModuleInstance();
assertBeanCount(1, FACTORY_NAME);
- assertStatus(status, 11, 0, 0);
+ assertStatus(status, 8, 0, 0);
}
@Test
assertBeanCount(1, FACTORY_NAME);
final CommitStatus status = transaction.commit();
assertBeanCount(1, FACTORY_NAME);
- assertStatus(status, 0, 0, 11);
+ assertStatus(status, 0, 0, 8);
}
@Test
mxBean.setTopologyId(new TopologyId("new-bgp-topology"));
final CommitStatus status = transaction.commit();
assertBeanCount(1, FACTORY_NAME);
- assertStatus(status, 0, 1, 10);
+ assertStatus(status, 0, 1, 7);
}
private CommitStatus createIpv6ReachabilityTopoBuilderModuleInstance() throws Exception {
import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;
-
import java.util.List;
import javax.management.ObjectName;
import org.junit.Test;
public void testCreateBean() throws Exception {
final CommitStatus status = createLinkstateTopologyBuilderModuleInstance();
assertBeanCount(1, FACTORY_NAME);
- assertStatus(status, 11, 0, 0);
+ assertStatus(status, 8, 0, 0);
}
@Test
assertBeanCount(1, FACTORY_NAME);
final CommitStatus status = transaction.commit();
assertBeanCount(1, FACTORY_NAME);
- assertStatus(status, 0, 0, 11);
+ assertStatus(status, 0, 0, 8);
}
@Test
mxBean.setTopologyId(new TopologyId("new-bgp-topology"));
final CommitStatus status = transaction.commit();
assertBeanCount(1, FACTORY_NAME);
- assertStatus(status, 0, 1, 10);
+ assertStatus(status, 0, 1, 7);
}
private CommitStatus createLinkstateTopologyBuilderModuleInstance() throws Exception {
Code Review / bgpcep.git / commitdiff