Revision: 16164
Author: [email protected]
Date: Tue Jan  4 21:41:36 2011
Log: Added Mtp2Listener for listening state of Mtp2
http://code.google.com/p/mobicents/source/detail?r=16164

Added:
/trunk/protocols/ss7/mtp/mtp-impl/src/main/java/org/mobicents/protocols/ss7/mtp/Mtp2Listener.java
Modified:
/trunk/protocols/ss7/mtp/mtp-impl/src/main/java/org/mobicents/protocols/ss7/mtp/Mtp2.java /trunk/protocols/ss7/mtp/mtp-impl/src/main/java/org/mobicents/protocols/ss7/mtp/Mtp3.java

=======================================
--- /dev/null
+++ /trunk/protocols/ss7/mtp/mtp-impl/src/main/java/org/mobicents/protocols/ss7/mtp/Mtp2Listener.java Tue Jan 4 21:41:36 2011
@@ -0,0 +1,9 @@
+package org.mobicents.protocols.ss7.mtp;
+
+public interface Mtp2Listener {
+
+    public void linkFailed();
+    public void linkInService();
+    public void linkUp();
+
+}
=======================================
--- /trunk/protocols/ss7/mtp/mtp-impl/src/main/java/org/mobicents/protocols/ss7/mtp/Mtp2.java Mon Dec 27 04:17:04 2010 +++ /trunk/protocols/ss7/mtp/mtp-impl/src/main/java/org/mobicents/protocols/ss7/mtp/Mtp2.java Tue Jan 4 21:41:36 2011
@@ -283,6 +283,9 @@
     /**
      * Subservice field of mtp msg. See Q.704.14.2.2
      */
+
+    protected Mtp2Listener mtp2Listener = null;
+
     private static final Logger ROOT_LOGGER = Logger.getLogger(Mtp2.class);
     private final Logger logger; //actual logger.
     public Mtp2(String name, Mtp1 channel) {
@@ -305,6 +308,16 @@
             this.transmissionBuffer[i] = new Mtp2Buffer();
         }
     }
+
+    public Mtp2Listener getMtp2Listener() {
+        return mtp2Listener;
+    }
+
+    public void setMtp2Listener(Mtp2Listener mtp2Listener) {
+        this.mtp2Listener = mtp2Listener;
+    }
+
+

     public boolean isEmergency() {
         return emergency;
=======================================
--- /trunk/protocols/ss7/mtp/mtp-impl/src/main/java/org/mobicents/protocols/ss7/mtp/Mtp3.java Wed Dec 29 20:19:30 2010 +++ /trunk/protocols/ss7/mtp/mtp-impl/src/main/java/org/mobicents/protocols/ss7/mtp/Mtp3.java Tue Jan 4 21:41:36 2011
@@ -426,6 +426,11 @@
         if (logger.isDebugEnabled()) {
logger.debug(String.format("(%s) Sending TRA(Traffic Restart Allowed) message", link.getName()));
         }
+
+        if(link.mtp2Listener != null){
+            link.mtp2Listener.linkInService();
+        }
+
         restartTraffic(link);

         //create and assign Tester;
@@ -448,6 +453,11 @@
      * @param link
      */
     private void linkUp(Mtp2 link) {
+
+        if(link.mtp2Listener != null){
+            link.mtp2Listener.linkUp();
+        }
+
         linkset.add(link);
         if (linkset.isActive() && this.mtp3Listener != null) {
             try {
@@ -462,6 +472,12 @@
     }

     public void linkFailed(Mtp2 link) {
+
+        //Call Listener
+        if(link.mtp2Listener != null){
+            link.mtp2Listener.linkFailed();
+        }
+
        //FIXME: add debug or trace?
         //remove this link from list of active links
         linkset.remove(link);

Reply via email to