src/share/jaxws_classes/com/sun/xml/internal/ws/addressing/WsaPropertyBag.java

Thu, 31 Aug 2017 15:18:52 +0800

author
aoqi
date
Thu, 31 Aug 2017 15:18:52 +0800
changeset 637
9c07ef4934dd
parent 368
0989ad8c0860
parent 0
373ffda63c9a
permissions
-rw-r--r--

merge

aoqi@0 1 /*
aoqi@0 2 * Copyright (c) 1997, 2013, Oracle and/or its affiliates. All rights reserved.
aoqi@0 3 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
aoqi@0 4 *
aoqi@0 5 * This code is free software; you can redistribute it and/or modify it
aoqi@0 6 * under the terms of the GNU General Public License version 2 only, as
aoqi@0 7 * published by the Free Software Foundation. Oracle designates this
aoqi@0 8 * particular file as subject to the "Classpath" exception as provided
aoqi@0 9 * by Oracle in the LICENSE file that accompanied this code.
aoqi@0 10 *
aoqi@0 11 * This code is distributed in the hope that it will be useful, but WITHOUT
aoqi@0 12 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
aoqi@0 13 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
aoqi@0 14 * version 2 for more details (a copy is included in the LICENSE file that
aoqi@0 15 * accompanied this code).
aoqi@0 16 *
aoqi@0 17 * You should have received a copy of the GNU General Public License version
aoqi@0 18 * 2 along with this work; if not, write to the Free Software Foundation,
aoqi@0 19 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
aoqi@0 20 *
aoqi@0 21 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
aoqi@0 22 * or visit www.oracle.com if you need additional information or have any
aoqi@0 23 * questions.
aoqi@0 24 */
aoqi@0 25
aoqi@0 26 package com.sun.xml.internal.ws.addressing;
aoqi@0 27
aoqi@0 28 import com.oracle.webservices.internal.api.message.BasePropertySet;
aoqi@0 29 import com.sun.istack.internal.NotNull;
aoqi@0 30 import com.sun.xml.internal.ws.api.SOAPVersion;
aoqi@0 31 import com.sun.xml.internal.ws.api.addressing.AddressingVersion;
aoqi@0 32 import com.sun.xml.internal.ws.api.addressing.WSEndpointReference;
aoqi@0 33 import com.sun.xml.internal.ws.api.message.AddressingUtils;
aoqi@0 34 import com.sun.xml.internal.ws.api.message.Header;
aoqi@0 35 import com.sun.xml.internal.ws.api.message.Message;
aoqi@0 36 import com.sun.xml.internal.ws.api.message.Packet;
aoqi@0 37 import com.sun.xml.internal.ws.developer.JAXWSProperties;
aoqi@0 38
aoqi@0 39 import javax.xml.namespace.QName;
aoqi@0 40 import javax.xml.stream.XMLStreamException;
aoqi@0 41
aoqi@0 42
aoqi@0 43 /**
aoqi@0 44 * Provides access to the Addressing headers.
aoqi@0 45 *
aoqi@0 46 * @author Kohsuke Kawaguchi
aoqi@0 47 * @author Rama Pulavarthi
aoqi@0 48 * @since 2.1.3
aoqi@0 49 */
aoqi@0 50 public class WsaPropertyBag extends BasePropertySet {
aoqi@0 51
aoqi@0 52 public static final String WSA_REPLYTO_FROM_REQUEST = "com.sun.xml.internal.ws.addressing.WsaPropertyBag.ReplyToFromRequest";
aoqi@0 53 public static final String WSA_FAULTTO_FROM_REQUEST = "com.sun.xml.internal.ws.addressing.WsaPropertyBag.FaultToFromRequest";
aoqi@0 54 public static final String WSA_MSGID_FROM_REQUEST = "com.sun.xml.internal.ws.addressing.WsaPropertyBag.MessageIdFromRequest";
aoqi@0 55 public static final String WSA_TO = "com.sun.xml.internal.ws.addressing.WsaPropertyBag.To";
aoqi@0 56
aoqi@0 57 private final @NotNull AddressingVersion addressingVersion;
aoqi@0 58 private final @NotNull SOAPVersion soapVersion;
aoqi@0 59 /**
aoqi@0 60 * We can't store {@link Message} here as those may get replaced as
aoqi@0 61 * the packet travels through the pipeline.
aoqi@0 62 */
aoqi@0 63 private final @NotNull Packet packet;
aoqi@0 64
aoqi@0 65 public WsaPropertyBag(AddressingVersion addressingVersion, SOAPVersion soapVersion, Packet packet) {
aoqi@0 66 this.addressingVersion = addressingVersion;
aoqi@0 67 this.soapVersion = soapVersion;
aoqi@0 68 this.packet = packet;
aoqi@0 69 }
aoqi@0 70
aoqi@0 71 /**
aoqi@0 72 * Gets the <tt>wsa:To</tt> header.
aoqi@0 73 *
aoqi@0 74 * @return
aoqi@0 75 * null if the incoming SOAP message didn't have the header.
aoqi@0 76 */
aoqi@0 77 @Property(JAXWSProperties.ADDRESSING_TO)
aoqi@0 78 public String getTo() throws XMLStreamException {
aoqi@0 79 if (packet.getMessage() == null) {
aoqi@0 80 return null;
aoqi@0 81 }
aoqi@0 82 Header h = packet.getMessage().getHeaders().get(addressingVersion.toTag, false);
aoqi@0 83 if(h==null) return null;
aoqi@0 84 return h.getStringContent();
aoqi@0 85 }
aoqi@0 86
aoqi@0 87 /**
aoqi@0 88 * Gets the <tt>wsa:To</tt> header.
aoqi@0 89 *
aoqi@0 90 * @return
aoqi@0 91 * null if the incoming SOAP message didn't have the header.
aoqi@0 92 */
aoqi@0 93 @Property(WSA_TO)
aoqi@0 94 public WSEndpointReference getToAsReference() throws XMLStreamException {
aoqi@0 95 if (packet.getMessage() == null) {
aoqi@0 96 return null;
aoqi@0 97 }
aoqi@0 98 Header h = packet.getMessage().getHeaders().get(addressingVersion.toTag, false);
aoqi@0 99 if(h==null) return null;
aoqi@0 100 return new WSEndpointReference(h.getStringContent(),addressingVersion);
aoqi@0 101 }
aoqi@0 102
aoqi@0 103 /**
aoqi@0 104 * Gets the <tt>wsa:From</tt> header.
aoqi@0 105 *
aoqi@0 106 * @return
aoqi@0 107 * null if the incoming SOAP message didn't have the header.
aoqi@0 108 */
aoqi@0 109 @Property(JAXWSProperties.ADDRESSING_FROM)
aoqi@0 110 public WSEndpointReference getFrom() throws XMLStreamException {
aoqi@0 111 return getEPR(addressingVersion.fromTag);
aoqi@0 112 }
aoqi@0 113
aoqi@0 114 /**
aoqi@0 115 * Gets the <tt>wsa:Action</tt> header content as String.
aoqi@0 116 *
aoqi@0 117 * @return
aoqi@0 118 * null if the incoming SOAP message didn't have the header.
aoqi@0 119 */
aoqi@0 120 @Property(JAXWSProperties.ADDRESSING_ACTION)
aoqi@0 121 public String getAction() {
aoqi@0 122 if (packet.getMessage() == null) {
aoqi@0 123 return null;
aoqi@0 124 }
aoqi@0 125 Header h = packet.getMessage().getHeaders().get(addressingVersion.actionTag, false);
aoqi@0 126 if(h==null) return null;
aoqi@0 127 return h.getStringContent();
aoqi@0 128 }
aoqi@0 129
aoqi@0 130 /**
aoqi@0 131 * Gets the <tt>wsa:MessageID</tt> header content as String.
aoqi@0 132 *
aoqi@0 133 * @return
aoqi@0 134 * null if the incoming SOAP message didn't have the header.
aoqi@0 135 */
aoqi@0 136 // WsaServerTube.REQUEST_MESSAGE_ID is exposed for backward compatibility with 2.1
aoqi@0 137 @Property({JAXWSProperties.ADDRESSING_MESSAGEID,WsaServerTube.REQUEST_MESSAGE_ID})
aoqi@0 138 public String getMessageID() {
aoqi@0 139 if (packet.getMessage() == null) {
aoqi@0 140 return null;
aoqi@0 141 }
aoqi@0 142 return AddressingUtils.getMessageID(packet.getMessage().getHeaders(), addressingVersion,soapVersion);
aoqi@0 143 }
aoqi@0 144
aoqi@0 145 private WSEndpointReference getEPR(QName tag) throws XMLStreamException {
aoqi@0 146 if (packet.getMessage() == null) {
aoqi@0 147 return null;
aoqi@0 148 }
aoqi@0 149 Header h = packet.getMessage().getHeaders().get(tag, false);
aoqi@0 150 if(h==null) return null;
aoqi@0 151 return h.readAsEPR(addressingVersion);
aoqi@0 152 }
aoqi@0 153
aoqi@0 154 protected PropertyMap getPropertyMap() {
aoqi@0 155 return model;
aoqi@0 156 }
aoqi@0 157
aoqi@0 158 private static final PropertyMap model;
aoqi@0 159 static {
aoqi@0 160 model = parse(WsaPropertyBag.class);
aoqi@0 161 }
aoqi@0 162
aoqi@0 163 private WSEndpointReference _replyToFromRequest = null;
aoqi@0 164
aoqi@0 165 @Property(WSA_REPLYTO_FROM_REQUEST)
aoqi@0 166 public WSEndpointReference getReplyToFromRequest() {
aoqi@0 167 return _replyToFromRequest;
aoqi@0 168 }
aoqi@0 169
aoqi@0 170 public void setReplyToFromRequest(WSEndpointReference ref) {
aoqi@0 171 _replyToFromRequest = ref;
aoqi@0 172 }
aoqi@0 173
aoqi@0 174 private WSEndpointReference _faultToFromRequest = null;
aoqi@0 175
aoqi@0 176 @Property(WSA_FAULTTO_FROM_REQUEST)
aoqi@0 177 public WSEndpointReference getFaultToFromRequest() {
aoqi@0 178 return _faultToFromRequest;
aoqi@0 179 }
aoqi@0 180
aoqi@0 181 public void setFaultToFromRequest(WSEndpointReference ref) {
aoqi@0 182 _faultToFromRequest = ref;
aoqi@0 183 }
aoqi@0 184
aoqi@0 185 private String _msgIdFromRequest = null;
aoqi@0 186
aoqi@0 187 @Property(WSA_MSGID_FROM_REQUEST)
aoqi@0 188 public String getMessageIdFromRequest() {
aoqi@0 189 return _msgIdFromRequest;
aoqi@0 190 }
aoqi@0 191
aoqi@0 192 public void setMessageIdFromRequest(String id) {
aoqi@0 193 _msgIdFromRequest = id;
aoqi@0 194 }
aoqi@0 195 }

mercurial