Changeset 1906 for trunk/autoquest-plugin-http/src/main/java/de/ugoe/cs/autoquest

Timestamp:

03/11/15 13:56:46 (10 years ago)

Author:

pharms

Message:

• created support for client names
• adapted support for service names

File:

• trunk/autoquest-plugin-http/src/main/java/de/ugoe/cs/autoquest/plugin/http/eventcore/SOAPEventType.java (modified) (6 diffs)

trunk/autoquest-plugin-http/src/main/java/de/ugoe/cs/autoquest/plugin/http/eventcore/SOAPEventType.java

@@ -65 +65 @@
     /**
      * <p>
-     * the name of the service; this is either the path or, if a path map is available
+     * the name of the client; this is either the host/ip and port of the sender or, if a path
+     * map is available, a human readable name that may be based also on the receiver
+     * </p>
+     */
+    private final String clientName;
+   
+    /**
+     * <p>
+     * the name of the service; this is either the path or, if a path map is available, a human
+     * readable name that is mapped to the path
      * </p>
      */
@@ -107 +116 @@
         StringBuffer nameBuffer = new StringBuffer("SOAPEvent");
         
-        boolean somethingAdded = false;
-        
+        // determine the client name
+        if (urlNameMap == null) {
+            clientName = exchange.getSender().getHost() + ":" + exchange.getSender().getPort();
+        }
+        else {
+            // check for a mapping of the sender host
+            String key = "clientName.sender." + exchange.getSender().getHost();
+            String value = urlNameMap.getProperty(key);
+            
+            if (value == null) {
+                key += ":" + exchange.getSender().getPort();
+                value = urlNameMap.getProperty(key);
+            }
+            
+            if (value == null) {
+                key = "clientName.receiver." + exchange.getReceiver().getHost();
+                value = urlNameMap.getProperty(key);
+            }
+            
+            if (value == null) {
+                key += ":" + exchange.getReceiver().getPort();
+                value = urlNameMap.getProperty(key);
+            }
+            
+            if (value != null) {
+                clientName = value;
+            }
+            else {
+                clientName = exchange.getSender().getHost() + ":" + exchange.getSender().getPort();
+            }
+        }
+
+        nameBuffer.append(clientName);
+        
+        // determine the service name
         if (path != null) {
-            nameBuffer.append("(");
-            if( urlNameMap==null ) {
+            nameBuffer.append(", ");
+            if (urlNameMap == null) {
                 serviceName = path;
-            } else {
-                String value = urlNameMap.getProperty(path);
-                if( value!=null ) {
+            }
+            else {
+                String value = urlNameMap.getProperty("serviceName.path." + path);
+                if (value != null) {
                     serviceName = value;
-                } else {
+                }
+                else {
                     serviceName = path;
                 }
             }
             nameBuffer.append(serviceName);
-            somethingAdded = true;
-        } else {
+        }
+        else {
             serviceName = "NA";
         }
         
         if (calledMethod != null) {
-            nameBuffer.append(somethingAdded ? ", " : "(");
+            nameBuffer.append(", ");
             nameBuffer.append(calledMethod);
-            somethingAdded = true;
         }
         
@@ -137 +180 @@
         
         if ((senderStr != null) && (receiverStr != null)) {
-            nameBuffer.append(somethingAdded ? ", " : "(");
+            nameBuffer.append(", ");
             nameBuffer.append(senderStr);
             nameBuffer.append(" --> ");
             nameBuffer.append(receiverStr);
-            somethingAdded = true;
         }
         else if (senderStr != null) {
-            nameBuffer.append(somethingAdded ? ", " : "(");
+            nameBuffer.append(", ");
             nameBuffer.append(senderStr);
-            somethingAdded = true;
         }
         else if (receiverStr != null) {
-            nameBuffer.append(somethingAdded ? ", " : "(");
+            nameBuffer.append(", ");
             nameBuffer.append(receiverStr);
-            somethingAdded = true;
-        }
-        
-        if (somethingAdded) {
-            nameBuffer.append(")");
-        }
+        }
+        
+        nameBuffer.append(")");
         
         this.name = nameBuffer.toString();
@@ -170 +208 @@
     public String getCalledMethod() {
         return calledMethod;
+    }
+    
+    /**
+     * <p>
+     * the name of the client calling in this request
+     * </p>
+     *
+     * @return the name of the client calling in this request
+     */
+    public String getClientName() {
+        return clientName;
     }
     
@@ -229 +278 @@
                 super.equals(obj) &&
                 HTTPUtils.equals(calledMethod, ((SOAPEventType) obj).calledMethod) &&
-                HTTPUtils.equals(serviceName, ((SOAPEventType) obj).serviceName);
+                HTTPUtils.equals(serviceName, ((SOAPEventType) obj).serviceName) &&
+                HTTPUtils.equals(clientName, ((SOAPEventType) obj).clientName);
         }
         else {
@@ -247 +297 @@
         if( serviceName != null ) {
             hashCode += serviceName.hashCode();
+        }
+        if( clientName != null ) {
+            hashCode += clientName.hashCode();
         }
         return hashCode;