[xgws-dev] CVS Update: codes/xsul/java/modules/ws_adressing_detect_duplicates/xsul/ws_addressing

[Aleksander Andrzej Slominski]

aslom       06/04/19 13:31:41

  Added:       xsul/java/modules/ws_adressing_detect_duplicates/xsul/ws_addressing
                        WsaDetectDuplicateMessageId.java
  Log:
  handler to drop m,essages with already seen messageIds
  
  Revision  Changes    Path
  1.1                  codes/xsul/java/modules/ws_adressing_detect_duplicates/xsul/ws_addressing/WsaDetectDuplicateMessageId.java
  
  Index: WsaDetectDuplicateMessageId.java
  ===================================================================
  /* -*- mode: Java; c-basic-offset: 4; indent-tabs-mode: nil; -*-  //------100-columns-wide------>|*/
  /* Copyright (c) 2006 Extreme! Lab, Indiana University. All rights reserved.
   * This software is open source. See the bottom of this file for the licence.
   * $Id: WsaDetectDuplicateMessageId.java,v 1.1 2006/04/19 17:31:41 aslom Exp $ */
  
  package xsul.ws_addressing;
  
  import java.net.URI;
  import java.util.HashSet;
  import java.util.Set;
  import org.xmlpull.v1.builder.XmlElement;
  import org.xmlpull.v1.builder.XmlInfosetBuilder;
  import xsul.XmlConstants;
  import xsul.XsulException;
  
  /**
   * Detect if a message if messages woth a duplicated WS-Addressing MessageId.
   *
   * @version $Revision: 1.1 $
   * @author <a href="http://www.extreme.indiana.edu/~aslom/">Aleksander Slominski</a>
   */
  public class WsaDetectDuplicateMessageId {
      private final static XmlInfosetBuilder builder = XmlConstants.BUILDER;
      // It would nice ot add some cleanup to remove ids longer than N days (to free memory on busy server)
      private Set messageIds = new HashSet();
      
      public WsaDetectDuplicateMessageId() {
      }
      
      public boolean seenMessageId(XmlElement soapEnvelopeOrHeader) throws XsulException {
          if(soapEnvelopeOrHeader == null) throw new IllegalArgumentException();
          XmlElement header = soapEnvelopeOrHeader;
          if(header.getName().equals("Envelope")) {
              header = soapEnvelopeOrHeader.element(null, "Header");
              if(header == null) { // no SOAP::Header --> no way to detect duplicates
                  return false;
              }
          } else  if(!header.getName().equals("Header")) {
              throw new IllegalArgumentException("element passed must be SOAP Envelope or Header");
          }
          WsaMessageInformationHeaders wmih = new WsaMessageInformationHeaders(header);
          URI uri = wmih.getMessageId();
          if(uri != null) { // no messageId --> no way to detect duplicates
              String id = uri.toString();
              boolean notSeenBefore = messageIds.add(id);
              return ! notSeenBefore;
          }
          return false;
      }
  }
  
  
  /*
   * Indiana University Extreme! Lab Software License, Version 1.2
   *
   * Copyright (C) 2006 The Trustees of Indiana University.
   * All rights reserved.
   *
   * Redistribution and use in source and binary forms, with or without
   * modification, are permitted provided that the following conditions are
   * met:
   *
   * 1) All redistributions of source code must retain the above
   *    copyright notice, the list of authors in the original source
   *    code, this list of conditions and the disclaimer listed in this
   *    license;
   *
   * 2) All redistributions in binary form must reproduce the above
   *    copyright notice, this list of conditions and the disclaimer
   *    listed in this license in the documentation and/or other
   *    materials provided with the distribution;
   *
   * 3) Any documentation included with all redistributions must include
   *    the following acknowledgement:
   *
   *      "This product includes software developed by the Indiana
   *      University Extreme! Lab.  For further information please visit
   *      http://www.extreme.indiana.edu/"
   *
   *    Alternatively, this acknowledgment may appear in the software
   *    itself, and wherever such third-party acknowledgments normally
   *    appear.
   *
   * 4) The name "Indiana University" or "Indiana University
   *    Extreme! Lab" shall not be used to endorse or promote
   *    products derived from this software without prior written
   *    permission from Indiana University.  For written permission,
   *    please contact http://www.extreme.indiana.edu/.
   *
   * 5) Products derived from this software may not use "Indiana
   *    University" name nor may "Indiana University" appear in their name,
   *    without prior written permission of the Indiana University.
   *
   * Indiana University provides no reassurances that the source code
   * provided does not infringe the patent or any other intellectual
   * property rights of any other entity.  Indiana University disclaims any
   * liability to any recipient for claims brought by any other entity
   * based on infringement of intellectual property rights or otherwise.
   *
   * LICENSEE UNDERSTANDS THAT SOFTWARE IS PROVIDED "AS IS" FOR WHICH
   * NO WARRANTIES AS TO CAPABILITIES OR ACCURACY ARE MADE. INDIANA
   * UNIVERSITY GIVES NO WARRANTIES AND MAKES NO REPRESENTATION THAT
   * SOFTWARE IS FREE OF INFRINGEMENT OF THIRD PARTY PATENT, COPYRIGHT, OR
   * OTHER PROPRIETARY RIGHTS.  INDIANA UNIVERSITY MAKES NO WARRANTIES THAT
   * SOFTWARE IS FREE FROM "BUGS", "VIRUSES", "TROJAN HORSES", "TRAP
   * DOORS", "WORMS", OR OTHER HARMFUL CODE.  LICENSEE ASSUMES THE ENTIRE
   * RISK AS TO THE PERFORMANCE OF SOFTWARE AND/OR ASSOCIATED MATERIALS,
   * AND TO THE PERFORMANCE AND VALIDITY OF INFORMATION GENERATED USING
   * SOFTWARE.
   */