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);