#8 add Ending Diameter activity explicitly from SBB function

resources/diameter-base/common/ra/src/main/java/org/mobicents/slee/resource/diameter/base/AccountingServerSessionActivityImpl.java

@@ -204,4 +204,10 @@ public void endActivity() {
     super.endActivity();
   }
 
+  @Override
+  public void delayedEndActivity() {
+    this.setTerminateAfterProcessing(true);
+    super.baseListener.startActivityRemoveTimer(getActivityHandle());
+  }
+
 }

resources/diameter-base/common/ra/src/main/java/org/mobicents/slee/resource/diameter/base/AuthServerSessionActivityImpl.java

@@ -202,4 +202,10 @@ public void endActivity() {
     this.serverSession.release();
     super.endActivity();
   }
+
+  @Override
+  public void delayedEndActivity() {
+    this.setTerminateAfterProcessing(true);
+    super.baseListener.startActivityRemoveTimer(getActivityHandle());
+  }
 }

resources/diameter-base/common/ratype/src/main/java/net/java/slee/resource/diameter/base/AccountingServerSessionActivity.java

@@ -67,5 +67,5 @@ public interface AccountingServerSessionActivity extends AccountingSessionActivi
    * @throws IllegalArgumentException if accountingAnswer is missing any required AVPs
    */
   void sendAccountingAnswer(AccountingAnswer aca) throws IOException, IllegalArgumentException;
-
+  void delayedEndActivity();
 }

resources/diameter-base/common/ratype/src/main/java/net/java/slee/resource/diameter/base/AuthServerSessionActivity.java

@@ -90,5 +90,5 @@ public interface AuthServerSessionActivity extends AuthSessionActivity {
    * @throws IOException 
    */
   void sendSessionTerminationAnswer(SessionTerminationAnswer request) throws IOException;
-
+  void delayedEndActivity();
 }

resources/diameter-gq/ra/src/main/java/org/mobicents/slee/resource/diameter/gq/GqServerSessionActivityImpl.java

@@ -207,4 +207,10 @@ public void endActivity() {
     this.session.release();
     super.endActivity();
   }
+
+  @Override
+  public void delayedEndActivity() {
+    this.setTerminateAfterProcessing(true);
+    super.baseListener.startActivityRemoveTimer(getActivityHandle());
+  }
 }

resources/diameter-gq/ratype/src/main/java/net/java/slee/resource/diameter/gq/GqServerSessionActivity.java

@@ -79,4 +79,5 @@ public interface GqServerSessionActivity extends GqSessionActivity {
   public void sendGqSessionTerminationAnswer(GqSessionTerminationAnswer sta) throws IOException;
 
   public void sendAbortSessionRequest(GqAbortSessionRequest asr) throws java.io.IOException;
+  public void delayedEndActivity();
 }

resources/diameter-gx/ra/src/main/java/org/mobicents/slee/resource/diameter/gx/GxServerSessionActivityImpl.java

@@ -226,4 +226,10 @@ public void endActivity() {
      this.session.release();
      super.endActivity();
    }
+
+   @Override
+   public void delayedEndActivity() {
+     this.setTerminateAfterProcessing(true);
+     super.baseListener.startActivityRemoveTimer(getActivityHandle());
+   }
 }

resources/diameter-gx/ratype/src/main/java/net/java/slee/resource/diameter/gx/GxServerSessionActivity.java

@@ -62,4 +62,5 @@ public interface GxServerSessionActivity extends GxSessionActivity {
      * @throws IOException if an error occurred while sending the message to the client.
      */
     void sendGxReAuthRequest(GxReAuthRequest rar) throws IOException;
+    void delayedEndActivity();
 }

resources/diameter-rf/ra/src/main/java/org/mobicents/slee/resource/diameter/rf/RfServerSessionActivityImpl.java

@@ -253,6 +253,11 @@ public void endActivity() {
     super.endActivity();
   }
 
+  @Override
+  public void delayedEndActivity() {
+    this.setTerminateAfterProcessing(true);
+    super.baseListener.startActivityRemoveTimer(getActivityHandle());
+  }
   /*
    * (non-Javadoc)
    * 

resources/diameter-rf/ratype/src/main/java/net/java/slee/resource/diameter/rf/RfServerSessionActivity.java

@@ -65,5 +65,5 @@ public interface RfServerSessionActivity extends RfSessionActivity {
    * @throws IllegalArgumentException if accountingAnswer is missing any required AVPs
    */
   public void sendRfAccountingAnswer(RfAccountingAnswer accountingAnswer) throws IOException, IllegalArgumentException;
-
+  public void delayedEndActivity();
 }

resources/diameter-ro/ra/src/main/java/org/mobicents/slee/resource/diameter/ro/RoServerSessionActivityImpl.java

@@ -235,4 +235,10 @@ public void endActivity() {
     super.endActivity();
   }
 
+  @Override
+  public void delayedEndActivity() {
+    this.setTerminateAfterProcessing(true);
+    super.baseListener.startActivityRemoveTimer(getActivityHandle());
+  }
+
 }

resources/diameter-ro/ratype/src/main/java/net/java/slee/resource/diameter/ro/RoServerSessionActivity.java

@@ -59,5 +59,5 @@ public interface RoServerSessionActivity extends RoSessionActivity {
   public void sendRoCreditControlAnswer(RoCreditControlAnswer cca) throws IOException;
 
   public void sendReAuthRequest(ReAuthRequest rar) throws java.io.IOException;
-
+  public void delayedEndActivity();
 }

resources/diameter-rx/ra/src/main/java/org/mobicents/slee/resource/diameter/rx/RxServerSessionActivityImpl.java

@@ -284,4 +284,10 @@ public void endActivity() {
     this.session.release();
     super.endActivity();
   }
+
+  @Override
+  public void delayedEndActivity() {
+    this.setTerminateAfterProcessing(true);
+    super.baseListener.startActivityRemoveTimer(getActivityHandle());
+  }
 }

resources/diameter-rx/ratype/src/main/java/net/java/slee/resource/diameter/rx/RxServerSessionActivity.java

@@ -54,4 +54,5 @@ public interface RxServerSessionActivity extends RxSessionActivity {
 
   void sendAbortSessionRequest(AbortSessionRequest asr) throws IOException;
 
+  void delayedEndActivity();
 }