BUG-6647 Increase code coverage and clean up II
[bgpcep.git] / bgp / rib-mock / src / main / java / org / opendaylight / protocol / bgp / rib / mock / BGPMock.java
index 11c82e26c509c9c34bd419e6bd3d9a132bd7e000..e50006587441d9578c119c0da1f73f3ce9ed95dc 100644 (file)
@@ -13,8 +13,6 @@ import com.google.common.eventbus.EventBus;
 import io.netty.buffer.Unpooled;
 
 import java.io.Closeable;
-import java.util.Arrays;
-import java.util.Iterator;
 import java.util.List;
 
 import javax.annotation.concurrent.GuardedBy;
@@ -71,22 +69,6 @@ public final class BGPMock implements Closeable {
         return messages;
     }
 
-    public synchronized void insertConnectionLostEvent() {
-        this.insertMessage(CONNECTION_LOST_MAGIC_MSG);
-    }
-
-    public synchronized void insertMessages(final List<Notification> messages) {
-        for (final Notification message : messages) {
-            this.insertMessage(message);
-        }
-    }
-
-    @GuardedBy("this")
-    private void insertMessage(final Notification message) {
-        this.allPreviousBGPMessages.add(message);
-        this.eventBus.post(message);
-    }
-
     @Override
     public synchronized void close() {
         // unregister all EventBusRegistration instances
@@ -96,24 +78,6 @@ public final class BGPMock implements Closeable {
         this.openRegistrations.clear();
     }
 
-    public boolean isMessageListSame(final List<byte[]> newMessages) {
-        if (this.allPreviousBGPMessages.size() != newMessages.size()) {
-            return false;
-        }
-        final Iterator<byte[]> i1 = this.allPreviousByteMessages.iterator();
-        final Iterator<byte[]> i2 = newMessages.iterator();
-        for (int i = 0; i < this.allPreviousBGPMessages.size(); i++) {
-            if (!Arrays.equals(i1.next(), i2.next())) {
-                return false;
-            }
-        }
-        return true;
-    }
-
-    public EventBus getEventBus() {
-        return this.eventBus;
-    }
-
     public ListenerRegistration<BGPSessionListener> registerUpdateListener(final BGPSessionListener listener) {
         return EventBusRegistration.createAndRegister(this.eventBus, listener, this.allPreviousBGPMessages);
     }