chunkListener get also format/application of received messages.

Author: thsc42

src/net/sharksystem/asap/ASAPChunkReceivedListener.java

@@ -5,5 +5,11 @@
  * @author thsc
  */
 public interface ASAPChunkReceivedListener {
-    void chunkReceived(String sender, String uri, int era);
+    /**
+     * @param format
+     * @param sender
+     * @param uri
+     * @param era
+     */
+    void chunkReceived(String format, String sender, String uri, int era);
 }

src/net/sharksystem/asap/ASAPEngine.java

@@ -435,7 +435,7 @@ public void handleASAPAssimilate(ASAP_AssimilationPDU_1_0 asapAssimiliationPDU,
                 System.out.println(b.toString());
                 //>>>>>>>>>>>>>>>>>>>debug
 
-                listener.chunkReceived(sender, uri, eraSender);
+                listener.chunkReceived(this.format, sender, uri, eraSender);
             } else {
                 //<<<<<<<<<<<<<<<<<<debug
                 b = new StringBuilder();

src/net/sharksystem/asap/ASAPInMemoMessages.java

@@ -1,6 +1,7 @@
 package net.sharksystem.asap;
 
 import net.sharksystem.asap.apps.ASAPMessages;
+import sun.reflect.generics.reflectiveObjects.NotImplementedException;
 
 import java.io.IOException;
 import java.util.ArrayList;
@@ -9,7 +10,6 @@
 import java.util.NoSuchElementException;
 
 /**
- *
  * @author thsc
  */
 class ASAPInMemoMessages implements ASAPMessages {
@@ -101,7 +101,7 @@ public CharSequence getURI() {
 
     @Override
     public CharSequence getFormat() {
-        return null;
+        throw new NotImplementedException();
     }
 
     @Override

src/net/sharksystem/asap/management/ASAPManagementMessageHandler.java

@@ -36,10 +36,9 @@ CharSequence getURI(Set<CharSequence> recipients) throws IOException, ASAPExcept
         return null;
     }
 
-    @Override
-    public void chunkReceived(String sender, String uri, int era) {
+    public void chunkReceived(String format, String sender, String uri, int era) {
         System.out.println(this.getLogStart()
-                + "handle received chunk (sender|uri|era) " + sender + "|" + uri + "|" + era);
+                + "handle received chunk (format|sender|uri|era) " + format + sender + "|" + uri + "|" + era);
         try {
             ASAPEngine asapManagementEngine = multiASAPEngine.getEngineByFormat(ASAP_1_0.ASAP_MANAGEMENT_FORMAT);
 

src/net/sharksystem/asap/util/ASAPChunkReceivedTester.java

@@ -10,20 +10,24 @@ public class ASAPChunkReceivedTester implements ASAPChunkReceivedListener {
     private String sender = null;
     private String uri = null;
     private int era;
+    private String format;
 
     @Override
-    public void chunkReceived(String sender, String uri, int era) {
-        System.out.println("ChunkReceiverTester.chunkReceived called: (sender/uri/era) " + 
+    public void chunkReceived(String format, String sender, String uri, int era) {
+        System.out.println("ChunkReceiverTester.chunkReceived called: (format|sender|uri|era) " +
+                format +
+                " | " +
                 sender +
-                " / " + 
+                " | " +
                 uri +
-                " / " + 
+                " | " +
                 era);
+        this.format = format;
         this.sender = sender;
         this.uri = uri;
         this.era = era;
     }
-    
+
     public boolean chunkReceived() {
         return this.sender != null;
     }
@@ -32,6 +36,10 @@ public String getSender() {
         return this.sender;
     }
 
+    public String getFormat() {
+        return this.format;
+    }
+
     public String getUri() {
         return this.uri;
     }