BUG-58: refactor to take advantage of netty

[bgpcep.git] / bgp / rib-impl / src / test / java / org / opendaylight / protocol / bgp / rib / impl / SpeakerSessionMock.java

diff --git a/bgp/rib-impl/src/test/java/org/opendaylight/protocol/bgp/rib/impl/SpeakerSessionMock.java b/bgp/rib-impl/src/test/java/org/opendaylight/protocol/bgp/rib/impl/SpeakerSessionMock.java
index c3dc615579abd7b2f6a4283189f320f31a3d893c..c55c13bf1e60da3b8c83e90aafe9b6d72d3c7dc9 100644 (file)
--- a/bgp/rib-impl/src/test/java/org/opendaylight/protocol/bgp/rib/impl/SpeakerSessionMock.java
+++ b/bgp/rib-impl/src/test/java/org/opendaylight/protocol/bgp/rib/impl/SpeakerSessionMock.java
@@ -7,12 +7,24 @@
  */
 package org.opendaylight.protocol.bgp.rib.impl;
 
-import java.util.Timer;
+import io.netty.buffer.ByteBufAllocator;
+import io.netty.channel.Channel;
+import io.netty.channel.ChannelConfig;
+import io.netty.channel.ChannelFuture;
+import io.netty.channel.ChannelMetadata;
+import io.netty.channel.ChannelPipeline;
+import io.netty.channel.ChannelProgressivePromise;
+import io.netty.channel.ChannelPromise;
+import io.netty.channel.EventLoop;
+import io.netty.util.Attribute;
+import io.netty.util.AttributeKey;
+import io.netty.util.HashedWheelTimer;
+
+import java.net.SocketAddress;
 
 import org.opendaylight.protocol.bgp.parser.BGPMessage;
 import org.opendaylight.protocol.bgp.parser.BGPSessionListener;
-import org.opendaylight.protocol.bgp.rib.impl.spi.BGPSessionPreferences;
-import org.opendaylight.protocol.concepts.ASNumber;
+import org.opendaylight.protocol.bgp.parser.message.BGPOpenMessage;
 
 /**
  * Mock of the BGP speakers session.
@@ -22,13 +34,254 @@ public class SpeakerSessionMock extends BGPSessionImpl {
        private final BGPSessionListener client;
 
        SpeakerSessionMock(final BGPSessionListener listener, final BGPSessionListener client) {
-               super(new MockDispatcher(), new Timer(), new BGPConnectionImpl(null, listener, new BGPSessionPreferences(new ASNumber(30), (short) 15, null, null), new BGPSessionProposalCheckerImpl()), 3, null, null);
+               super(new HashedWheelTimer(), listener, new Channel() {
+
+                       @Override
+                       public <T> Attribute<T> attr(final AttributeKey<T> key) {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public ChannelFuture bind(final SocketAddress localAddress) {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public ChannelFuture connect(final SocketAddress remoteAddress) {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public ChannelFuture connect(final SocketAddress remoteAddress,
+                                       final SocketAddress localAddress) {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public ChannelFuture disconnect() {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public ChannelFuture close() {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public ChannelFuture deregister() {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public ChannelFuture bind(final SocketAddress localAddress,
+                                       final ChannelPromise promise) {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public ChannelFuture connect(final SocketAddress remoteAddress,
+                                       final ChannelPromise promise) {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public ChannelFuture connect(final SocketAddress remoteAddress,
+                                       final SocketAddress localAddress, final ChannelPromise promise) {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public ChannelFuture disconnect(final ChannelPromise promise) {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public ChannelFuture close(final ChannelPromise promise) {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public ChannelFuture deregister(final ChannelPromise promise) {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public ChannelFuture write(final Object msg) {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public ChannelFuture write(final Object msg, final ChannelPromise promise) {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public ChannelFuture writeAndFlush(final Object msg,
+                                       final ChannelPromise promise) {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public ChannelFuture writeAndFlush(final Object msg) {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public ChannelPipeline pipeline() {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public ByteBufAllocator alloc() {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public ChannelPromise newPromise() {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public ChannelProgressivePromise newProgressivePromise() {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public ChannelFuture newSucceededFuture() {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public ChannelFuture newFailedFuture(final Throwable cause) {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public ChannelPromise voidPromise() {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public int compareTo(final Channel o) {
+                               // TODO Auto-generated method stub
+                               return 0;
+                       }
+
+                       @Override
+                       public EventLoop eventLoop() {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public Channel parent() {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public ChannelConfig config() {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public boolean isOpen() {
+                               // TODO Auto-generated method stub
+                               return false;
+                       }
+
+                       @Override
+                       public boolean isRegistered() {
+                               // TODO Auto-generated method stub
+                               return false;
+                       }
+
+                       @Override
+                       public boolean isActive() {
+                               // TODO Auto-generated method stub
+                               return false;
+                       }
+
+                       @Override
+                       public ChannelMetadata metadata() {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public SocketAddress localAddress() {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public SocketAddress remoteAddress() {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public ChannelFuture closeFuture() {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public boolean isWritable() {
+                               // TODO Auto-generated method stub
+                               return false;
+                       }
+
+                       @Override
+                       public Channel flush() {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public Channel read() {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+                       @Override
+                       public Unsafe unsafe() {
+                               // TODO Auto-generated method stub
+                               return null;
+                       }
+
+               }, (short)3, new BGPOpenMessage(null, (short)5, null, null));
                this.client = client;
        }
 
        @Override
        public void sendMessage(final BGPMessage msg) {
                this.lastMessageSentAt = System.nanoTime();
-               this.client.onMessage(msg);
+               this.client.onMessage(this, msg);
        }
 }