import org.opendaylight.protocol.util.ByteArray;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.Notify;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev200120.NotifyBuilder;
-import org.opendaylight.yangtools.concepts.ListenerRegistration;
+import org.opendaylight.yangtools.concepts.Registration;
import org.opendaylight.yangtools.yang.binding.Notification;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
* Mock BGP session. It provides a way how to route a set of messages to BGPSessionListener. This class is thread-safe.
*/
public final class BGPMock implements Closeable {
-
private static final Logger LOG = LoggerFactory.getLogger(BGPMock.class);
static final Notify CONNECTION_LOST_MAGIC_MSG = new NotifyBuilder().setErrorCode(BGPError.CEASE.getCode()).build();
openRegistrations.clear();
}
- public ListenerRegistration<BGPSessionListener> registerUpdateListener(final BGPSessionListener listener) {
+ public Registration registerUpdateListener(final BGPSessionListener listener) {
return EventBusRegistration.createAndRegister(eventBus, listener, allPreviousBGPMessages);
}
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.AddPathCapability;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.MultiprotocolCapability;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.multiprotocol.rev180329.mp.capabilities.add.path.capability.AddressFamilies;
-import org.opendaylight.yangtools.concepts.AbstractListenerRegistration;
+import org.opendaylight.yangtools.concepts.AbstractObjectRegistration;
import org.opendaylight.yangtools.yang.binding.Notification;
import org.opendaylight.yangtools.yang.common.Uint32;
import org.slf4j.Logger;
* This class has @Subscribe annotated methods which receive events from {@link EventBus} . Events are produced by
* {@link BGPMock}, and each instance notifies exactly one {@link BGPSessionListener}.
*/
-final class EventBusRegistration extends AbstractListenerRegistration<BGPSessionListener> {
-
+final class EventBusRegistration extends AbstractObjectRegistration<BGPSessionListener> {
private static final Logger LOG = LoggerFactory.getLogger(EventBusRegistration.class);
private final EventBus eventBus;
@Subscribe
public void onMessage(final Notification<?> message) {
- sendMessage(this.getInstance(), message);
+ sendMessage(getInstance(), message);
}
@Override
*/
package org.opendaylight.protocol.bgp.rib.spi;
-import java.util.EventListener;
import org.eclipse.jdt.annotation.NonNullByDefault;
import org.eclipse.jdt.annotation.Nullable;
import org.opendaylight.protocol.bgp.parser.BGPDocumentedException;
* Listener that receives session informations from the session.
*/
@NonNullByDefault
-public interface BGPSessionListener extends PeerRPCs, EventListener {
+public interface BGPSessionListener extends PeerRPCs {
/**
* Marks synchronization finished for given Table key.
*
* 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.bmp.api;
-import java.util.EventListener;
import org.opendaylight.yangtools.yang.binding.Notification;
-public interface BmpSessionListener extends EventListener {
+public interface BmpSessionListener {
void onSessionUp(BmpSession session);
*/
package org.opendaylight.protocol.pcep;
-import java.util.EventListener;
import org.eclipse.jdt.annotation.NonNullByDefault;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev181109.Message;
* Listener that receives session informations from the session.
*/
@NonNullByDefault
-public interface PCEPSessionListener extends EventListener {
+public interface PCEPSessionListener {
/**
* Fired when the session was established successfully.
*