Removed some sonar warnings from pcep.

[bgpcep.git] / pcep / testtool / src / main / java / org / opendaylight / protocol / pcep / testtool / TestingSessionListener.java

diff --git a/pcep/testtool/src/main/java/org/opendaylight/protocol/pcep/testtool/TestingSessionListener.java b/pcep/testtool/src/main/java/org/opendaylight/protocol/pcep/testtool/TestingSessionListener.java
index c259eee9cf19e066c0dbe56ef1485a39782e67b9..30a62268dc26514b1b5cac14809fbccb57d4aacc 100644 (file)
--- a/pcep/testtool/src/main/java/org/opendaylight/protocol/pcep/testtool/TestingSessionListener.java
+++ b/pcep/testtool/src/main/java/org/opendaylight/protocol/pcep/testtool/TestingSessionListener.java
@@ -7,30 +7,22 @@
  */
 package org.opendaylight.protocol.pcep.testtool;
 
-import java.util.ArrayList;
 import java.util.List;
 
-import org.opendaylight.protocol.concepts.IPv4Address;
-import org.opendaylight.protocol.concepts.IPv4Prefix;
-import org.opendaylight.protocol.concepts.Prefix;
-import org.opendaylight.protocol.framework.TerminationReason;
-import org.opendaylight.protocol.pcep.PCEPMessage;
 import org.opendaylight.protocol.pcep.PCEPSession;
 import org.opendaylight.protocol.pcep.PCEPSessionListener;
-import org.opendaylight.protocol.pcep.message.PCEPXRAddTunnelMessage;
-import org.opendaylight.protocol.pcep.object.PCEPCloseObject;
-import org.opendaylight.protocol.pcep.object.PCEPEndPointsObject;
-import org.opendaylight.protocol.pcep.object.PCEPExplicitRouteObject;
-import org.opendaylight.protocol.pcep.object.PCEPLspObject;
-import org.opendaylight.protocol.pcep.object.PCEPOpenObject;
-import org.opendaylight.protocol.pcep.subobject.EROIPPrefixSubobject;
-import org.opendaylight.protocol.pcep.subobject.ExplicitRouteSubobject;
+import org.opendaylight.protocol.pcep.PCEPTerminationReason;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.pcep.types.rev131005.Message;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-public class TestingSessionListener extends PCEPSessionListener {
+import com.google.common.collect.Lists;
 
-       public List<PCEPMessage> messages = new ArrayList<PCEPMessage>();
+public class TestingSessionListener implements PCEPSessionListener {
+
+       private final List<Message> messages = Lists.newArrayList();
+
+       public boolean up = false;
 
        private static final Logger logger = LoggerFactory.getLogger(TestingSessionListener.class);
 
@@ -38,28 +30,29 @@ public class TestingSessionListener extends PCEPSessionListener {
        }
 
        @Override
-       public void onMessage(final PCEPSession session, final PCEPMessage message) {
+       public void onMessage(final PCEPSession session, final Message message) {
                logger.debug("Received message: {}", message);
                this.messages.add(message);
        }
 
        @Override
-       public void onSessionUp(final PCEPSession session, final PCEPOpenObject local, final PCEPOpenObject remote) {
+       public void onSessionUp(final PCEPSession session) {
                logger.debug("Session up.");
-               final List<ExplicitRouteSubobject> subs = new ArrayList<ExplicitRouteSubobject>();
-               subs.add(new EROIPPrefixSubobject<Prefix<?>>(new IPv4Prefix(new IPv4Address(new byte[] { 10, 1, 1, 2 }), 32), false));
-               subs.add(new EROIPPrefixSubobject<Prefix<?>>(new IPv4Prefix(new IPv4Address(new byte[] { 2, 2, 2, 2 }), 32), false));
-               session.sendMessage(new PCEPXRAddTunnelMessage(new PCEPLspObject(23, false, false, false, false), new PCEPEndPointsObject<IPv4Address>(new IPv4Address(new byte[] {
-                               1, 1, 1, 1 }), new IPv4Address(new byte[] { 2, 2, 2, 2 })), new PCEPExplicitRouteObject(subs, false)));
+               this.up = true;
        }
 
        @Override
-       public void onSessionDown(final PCEPSession session, final PCEPCloseObject reason, final Exception e) {
-               logger.debug("Session down because: {}", reason);
+       public void onSessionDown(final PCEPSession session, final Exception e) {
+               logger.debug("Session down. Cause : {} or {}", e);
+               this.up = false;
        }
 
        @Override
-       public void onSessionTerminated(final PCEPSession session, final TerminationReason cause) {
-               logger.debug("Session terminated. Cause : {}", cause.toString());
+       public void onSessionTerminated(final PCEPSession session, final PCEPTerminationReason cause) {
+               logger.debug("Session terminated. Cause : {}", cause);
+       }
+
+       public List<Message> messages() {
+               return this.messages;
        }
 }