+++ /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.protocol.bgp.parser.spi.pojo;
-
-import java.util.ServiceLoader;
-import org.opendaylight.protocol.bgp.parser.spi.BGPExtensionProviderActivator;
-import org.opendaylight.protocol.bgp.parser.spi.BGPExtensionProviderContext;
-
-public final class ServiceLoaderBGPExtensionProviderContext {
- private static final class Holder {
- private static final BGPExtensionProviderContext INSTANCE = create();
-
- private Holder() {
- }
- }
-
- private ServiceLoaderBGPExtensionProviderContext() {
- }
-
- public static BGPExtensionProviderContext create() {
- final BGPExtensionProviderContext ctx = new SimpleBGPExtensionProviderContext();
-
- final ServiceLoader<BGPExtensionProviderActivator> loader = ServiceLoader.load(
- BGPExtensionProviderActivator.class);
- for (final BGPExtensionProviderActivator a : loader) {
- a.start(ctx);
- }
-
- return ctx;
- }
-
- public static BGPExtensionProviderContext getSingletonInstance() {
- return Holder.INSTANCE;
- }
-}
import org.opendaylight.yangtools.yang.binding.DataObject;
import org.opendaylight.yangtools.yang.binding.Notification;
-public class SimpleBGPExtensionProviderContext extends SimpleBGPExtensionConsumerContext
+public final class SimpleBGPExtensionProviderContext extends SimpleBGPExtensionConsumerContext
implements BGPExtensionProviderContext {
public static final int DEFAULT_MAXIMUM_CACHED_OBJECTS = 100000;
*/
package org.opendaylight.protocol.bmp.mock;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.timeout;
import static org.mockito.Mockito.verify;
import io.netty.channel.Channel;
import io.netty.channel.nio.NioEventLoopGroup;
import java.net.InetSocketAddress;
import java.util.List;
+import java.util.ServiceLoader;
import java.util.concurrent.TimeUnit;
import org.junit.After;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
-import org.mockito.Mockito;
-import org.opendaylight.protocol.bgp.parser.spi.pojo.ServiceLoaderBGPExtensionProviderContext;
+import org.opendaylight.protocol.bgp.parser.spi.BGPExtensionConsumerContext;
import org.opendaylight.protocol.bmp.api.BmpSession;
import org.opendaylight.protocol.bmp.api.BmpSessionListener;
import org.opendaylight.protocol.bmp.api.BmpSessionListenerFactory;
import org.opendaylight.yangtools.yang.binding.Notification;
public class BmpMockTest {
-
- private final BmpSessionListener sessionListener = Mockito.mock(BmpSessionListener.class);
+ private final BmpSessionListener sessionListener = mock(BmpSessionListener.class);
private BmpExtensionProviderActivator bmpActivator;
private BmpDispatcherImpl bmpDispatcher;
public void setUp() {
final BmpExtensionProviderContext ctx = new SimpleBmpExtensionProviderContext();
this.bmpActivator = new BmpActivator(
- ServiceLoaderBGPExtensionProviderContext.getSingletonInstance());
+ ServiceLoader.load(BGPExtensionConsumerContext.class).findFirst().orElseThrow());
this.bmpActivator.start(ctx);
this.bmpDispatcher = new BmpDispatcherImpl(new NioEventLoopGroup(), new NioEventLoopGroup(), ctx,
new DefaultBmpSessionFactory());
"--pre_policy_routes",
"3"});
- verify(this.sessionListener, Mockito.timeout(TimeUnit.SECONDS.toMillis(sessionUpWait)))
- .onSessionUp(Mockito.any(BmpSession.class));
+ verify(this.sessionListener, timeout(TimeUnit.SECONDS.toMillis(sessionUpWait)))
+ .onSessionUp(any(BmpSession.class));
//1 * Initiate message + 3 * PeerUp Notification + 9 * Route Monitoring message
- verify(this.sessionListener, Mockito.timeout(TimeUnit.SECONDS.toMillis(10))
+ verify(this.sessionListener, timeout(TimeUnit.SECONDS.toMillis(10))
.times(13))
- .onMessage(Mockito.any(Notification.class));
+ .onMessage(any(Notification.class));
if (serverChannel != null) {
serverChannel.close().sync();
sessionUpWait = 40;
}
- verify(this.sessionListener, Mockito.timeout(TimeUnit.SECONDS.toMillis(sessionUpWait)))
- .onSessionUp(Mockito.any(BmpSession.class));
+ verify(this.sessionListener, timeout(TimeUnit.SECONDS.toMillis(sessionUpWait)))
+ .onSessionUp(any(BmpSession.class));
//1 * Initiate message + 3 * PeerUp Notification + 9 * Route Monitoring message
- verify(this.sessionListener, Mockito.timeout(TimeUnit.SECONDS.toMillis(10))
+ verify(this.sessionListener, timeout(TimeUnit.SECONDS.toMillis(10))
.times(13))
- .onMessage(Mockito.any(Notification.class));
+ .onMessage(any(Notification.class));
if (serverChannel != null) {
serverChannel.close().sync();
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
+import java.util.ServiceLoader;
import org.junit.Before;
import org.junit.Test;
-import org.opendaylight.protocol.bgp.parser.spi.BGPExtensionProviderContext;
+import org.opendaylight.protocol.bgp.parser.spi.BGPExtensionConsumerContext;
import org.opendaylight.protocol.bgp.parser.spi.MessageRegistry;
-import org.opendaylight.protocol.bgp.parser.spi.pojo.ServiceLoaderBGPExtensionProviderContext;
import org.opendaylight.protocol.util.ByteArray;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.AsNumber;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddressNoZone;
public class AbstractBmpPerPeerMessageParserTest {
private static final String RD = "5:3";
- private BGPExtensionProviderContext ctx;
+ private MessageRegistry msgRegistry;
private AbstractBmpPerPeerMessageParser<?> parser;
private final byte[] ipv6MsgWithDistinguishergBytes = {
(byte) 0x01, (byte) 0xc0,
@Before
public void setUp() {
- this.ctx = ServiceLoaderBGPExtensionProviderContext.getSingletonInstance();
- final MessageRegistry msgRegistry = this.ctx.getMessageRegistry();
+ msgRegistry = ServiceLoader.load(BGPExtensionConsumerContext.class).findFirst().orElseThrow()
+ .getMessageRegistry();
this.parser = new AbstractBmpPerPeerMessageParser<>(msgRegistry) {
@Override
public Notification parseMessageBody(final ByteBuf bytes) {
@Test
public void testBgpMessageRegistry() {
- final MessageRegistry msgRegistry = this.ctx.getMessageRegistry();
assertEquals(msgRegistry, this.parser.getBgpMessageRegistry());
}
import static org.junit.Assert.assertNotNull;
-import org.junit.Before;
import org.junit.Test;
+import org.junit.runner.RunWith;
import org.mockito.Mock;
-import org.mockito.MockitoAnnotations;
+import org.mockito.junit.MockitoJUnitRunner;
import org.opendaylight.protocol.bmp.spi.parser.BmpTlvParser;
import org.opendaylight.protocol.bmp.spi.parser.BmpTlvSerializer;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.Keepalive;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev200120.description.tlv.DescriptionTlv;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev200120.reason.tlv.ReasonTlv;
+@RunWith(MockitoJUnitRunner.StrictStubs.class)
public class SimpleBmpExtensionProviderContextTest {
private static final SimpleBmpMessageRegistry MESSAGE_REGISTRY = new SimpleBmpMessageRegistry();
@Mock
private BmpTlvSerializer tlvSerializer;
- @Before
- public void setUp() {
- MockitoAnnotations.initMocks(this);
- }
-
@Test
public void testRegisterBmpMessageParser() {
assertNotNull(CONTEXT.registerBmpMessageParser(TEST_TYPE, MESSAGE_REGISTRY));
import io.netty.buffer.Unpooled;
import org.junit.Before;
import org.junit.Test;
+import org.junit.runner.RunWith;
import org.mockito.ArgumentCaptor;
import org.mockito.Mock;
import org.mockito.Mockito;
-import org.mockito.MockitoAnnotations;
+import org.mockito.junit.MockitoJUnitRunner;
import org.opendaylight.protocol.bmp.spi.parser.BmpDeserializationException;
import org.opendaylight.protocol.bmp.spi.parser.BmpTlvParser;
import org.opendaylight.protocol.bmp.spi.parser.BmpTlvSerializer;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev200120.Tlv;
+@RunWith(MockitoJUnitRunner.StrictStubs.class)
public class SimpleBmpTlvRegistryTest {
-
private final SimpleBmpTlvRegistry bmpTlvRegistry = new SimpleBmpTlvRegistry();
private final byte[] bytes = new byte[]{1, 2, 3};
private final ByteBuf input = Unpooled.wrappedBuffer(this.bytes);
@Before
public void setUp() throws BmpDeserializationException {
- MockitoAnnotations.initMocks(this);
this.bmpTlvRegistry.registerBmpTlvParser(DESCRIPTION_TLV_TYPE, this.descriptionTlvParser);
this.bmpTlvRegistry.registerBmpTlvSerializer(MockDescriptionTlv.class, this.descriptionTlvSerializer);
Mockito.doReturn(new MockDescriptionTlv()).when(this.descriptionTlvParser).parseTlv(this.input);