- ReconnectStrategyFactory sessionStrategy;
-
- BindingCodecTreeFactory codecFactory;
-
- private SchemaService schemaService;
-
-
- @Override
- protected DataBrokerTestCustomizer createDataBrokerTestCustomizer() {
- DataBrokerTestCustomizer customizer = super.createDataBrokerTestCustomizer();
- codecFactory = customizer.getBindingToNormalized();
- schemaService = customizer.getSchemaService();
- return customizer;
- }
-
- @Override
- protected void setupWithDataBroker(DataBroker dataBroker) {
- MockitoAnnotations.initMocks(this);
- final List<byte[]> bgpMessages;
- try {
- bgpMessages = HexDumpBGPFileParser.parseMessages(ParserToSalTest.class.getResourceAsStream(this.hex_messages));
- } catch (IOException e) {
- throw Throwables.propagate(e);
- }
- this.mock = new BGPMock(new EventBus("test"), ServiceLoaderBGPExtensionProviderContext.getSingletonInstance().getMessageRegistry(), Lists.newArrayList(fixMessages(bgpMessages)));
-
- Mockito.doReturn(GlobalEventExecutor.INSTANCE.newSucceededFuture(null)).when(this.dispatcher).createReconnectingClient(
- Mockito.any(InetSocketAddress.class), Mockito.any(AsNumber.class),
- Mockito.any(BGPPeerRegistry.class), Mockito.eq(this.tcpStrategyFactory), Mockito.eq(this.sessionStrategy),
- Mockito.any(KeyMapping.class));
-
- this.ext = new SimpleRIBExtensionProviderContext();
+ private BGPDispatcher dispatcher;
+ private CodecsRegistryImpl codecsRegistry;
+
+ @Before
+ public void setUp() throws Exception {
+ super.setUp();
+ final String hexMessages = "/bgp_hex.txt";
+ final List<byte[]> bgpMessages = HexDumpBGPFileParser
+ .parseMessages(ParserToSalTest.class.getResourceAsStream(hexMessages));
+ this.mock = new BGPMock(new EventBus("test"), ServiceLoaderBGPExtensionProviderContext
+ .getSingletonInstance().getMessageRegistry(), Lists.newArrayList(fixMessages(bgpMessages)));
+
+ Mockito.doReturn(GlobalEventExecutor.INSTANCE.newSucceededFuture(null)).when(this.dispatcher)
+ .createReconnectingClient(any(InetSocketAddress.class), any(InetSocketAddress.class),
+ anyInt(), any(KeyMapping.class));
+
+ this.ext1 = new SimpleRIBExtensionProviderContext();
+ this.ext2 = new SimpleRIBExtensionProviderContext();