jdk8-mips64-public/jaxws: comparison src/share/jaxws_classes/com/sun/xml/internal/ws/api/addressing/OneWayFeature.java

--1:000000000000
+:373ffda63c9a
+/*
+* Copyright (c) 1997, 2013, Oracle and/or its affiliates. All rights reserved.
+* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
+*
+* This code is free software; you can redistribute it and/or modify it
+* under the terms of the GNU General Public License version 2 only, as
+* published by the Free Software Foundation.  Oracle designates this
+* particular file as subject to the "Classpath" exception as provided
+* by Oracle in the LICENSE file that accompanied this code.
+*
+* This code is distributed in the hope that it will be useful, but WITHOUT
+* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+* FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
+* version 2 for more details (a copy is included in the LICENSE file that
+* accompanied this code).
+*
+* You should have received a copy of the GNU General Public License version
+* 2 along with this work; if not, write to the Free Software Foundation,
+* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
+*
+* Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
+* or visit www.oracle.com if you need additional information or have any
+* questions.
+*/
+package com.sun.xml.internal.ws.api.addressing;
+import java.net.URL;
+import com.sun.istack.internal.NotNull;
+import com.sun.istack.internal.Nullable;
+import com.sun.xml.internal.ws.api.FeatureConstructor;
+import javax.xml.ws.WebServiceFeature;
+import com.sun.org.glassfish.gmbal.ManagedAttribute;
+import com.sun.org.glassfish.gmbal.ManagedData;
+/**
+* Unsupported RI extension to work around an issue in WSIT.
+*
+* <p>
+* <b>This feature is not meant to be used by a common Web service developer</b> as there
+* is no need to send the above mentioned header for a one-way operation. But these
+* properties may need to be sent in certain middleware Web services.
+*
+* <p>
+* This feature allows ReplyTo, From and RelatesTo Message Addressing Properties
+* to be added for all messages that are sent from the port configured with
+* this annotation. All operations are assumed to be one-way, and
+* this feature should be used for one-way
+* operations only.
+*
+* If a non-null ReplyTo is specified, then MessageID property is also added.
+*
+* @author Arun Gupta
+*/
+@ManagedData
+public class OneWayFeature extends WebServiceFeature {
+/**
+* Constant value identifying the {@link OneWayFeature}
+*/
+public static final String ID = "http://java.sun.com/xml/ns/jaxws/addressing/oneway";
+private String messageId;
+private WSEndpointReference replyTo;
+private WSEndpointReference sslReplyTo;
+private WSEndpointReference from;
+private WSEndpointReference faultTo;
+private WSEndpointReference sslFaultTo;
+private String relatesToID;
+private boolean useAsyncWithSyncInvoke = false;
+/**
+* Create an {@link OneWayFeature}. The instance created will be enabled.
+*/
+public OneWayFeature() {
+this.enabled = true;
+}
+/**
+* Create an {@link OneWayFeature}
+*
+* @param enabled specifies whether this feature should
+*                be enabled or not.
+*/
+public OneWayFeature(boolean enabled) {
+this.enabled = enabled;
+}
+/**
+* Create an {@link OneWayFeature}
+*
+* @param enabled specifies whether this feature should be enabled or not.
+* @param replyTo specifies the {@link WSEndpointReference} of wsa:ReplyTo header.
+*/
+public OneWayFeature(boolean enabled, WSEndpointReference replyTo) {
+this.enabled = enabled;
+this.replyTo = replyTo;
+}
+/**
+* Create an {@link OneWayFeature}
+*
+* @param enabled specifies whether this feature should be enabled or not.
+* @param replyTo specifies the {@link WSEndpointReference} of wsa:ReplyTo header.
+* @param from specifies the {@link WSEndpointReference} of wsa:From header.
+* @param relatesTo specifies the MessageID to be used for wsa:RelatesTo header.
+*/
+@FeatureConstructor({"enabled","replyTo","from","relatesTo"})
+public OneWayFeature(boolean enabled, WSEndpointReference replyTo, WSEndpointReference from, String relatesTo) {
+this.enabled = enabled;
+this.replyTo = replyTo;
+this.from = from;
+this.relatesToID = relatesTo;
+}
+public OneWayFeature(final AddressingPropertySet a, AddressingVersion v) {
+this.enabled     = true;
+this.messageId   = a.getMessageId();
+this.relatesToID = a.getRelatesTo();
+this.replyTo     = makeEPR(a.getReplyTo(), v);
+this.faultTo     = makeEPR(a.getFaultTo(), v);
+}
+private WSEndpointReference makeEPR(final String x, final AddressingVersion v) {
+if (x == null) { return null; }
+return new WSEndpointReference(x, v);
+}
+public String getMessageId() {
+return messageId;
+}
+/**
+* {@inheritDoc}
+*/
+@ManagedAttribute
+public String getID() {
+return ID;
+}
+public boolean
+hasSslEprs() {
+return sslReplyTo != null || sslFaultTo != null;
+}
+/**
+* Getter for wsa:ReplyTo header {@link WSEndpointReference} .
+*
+* @return address of the wsa:ReplyTo header
+*/
+@ManagedAttribute
+public WSEndpointReference getReplyTo() {
+return replyTo;
+}
+public WSEndpointReference getReplyTo(boolean ssl) {
+return (ssl && sslReplyTo != null) ? sslReplyTo : replyTo;
+}
+/**
+* Setter for wsa:ReplyTo header {@link WSEndpointReference}.
+*
+* @param address
+*/
+public void setReplyTo(WSEndpointReference address) {
+this.replyTo = address;
+}
+public WSEndpointReference getSslReplyTo() {
+return sslReplyTo;
+}
+public void setSslReplyTo(WSEndpointReference sslReplyTo) {
+this.sslReplyTo = sslReplyTo;
+}
+/**
+* Getter for wsa:From header {@link WSEndpointReference}.
+*
+* @return address of the wsa:From header
+*/
+@ManagedAttribute
+public WSEndpointReference getFrom() {
+return from;
+}
+/**
+* Setter for wsa:From header {@link WSEndpointReference}.
+*
+* @param address of the wsa:From header
+*/
+public void setFrom(WSEndpointReference address) {
+this.from = address;
+}
+/**
+* Getter for MessageID for wsa:RelatesTo header.
+*
+* @return address of the wsa:FaultTo header
+*/
+@ManagedAttribute
+public String getRelatesToID() {
+return relatesToID;
+}
+/**
+* Setter for MessageID for wsa:RelatesTo header.
+*
+* @param id
+*/
+public void setRelatesToID(String id) {
+this.relatesToID = id;
+}
+/**
+* Getter for wsa:FaultTo header {@link WSEndpointReference}.
+*
+* @return address of the wsa:FaultTo header
+*/
+public WSEndpointReference getFaultTo() {
+return faultTo;
+}
+public WSEndpointReference getFaultTo(boolean ssl) {
+return (ssl && sslFaultTo != null) ? sslFaultTo : faultTo;
+}
+/**
+* Setter for wsa:FaultTo header {@link WSEndpointReference}.
+*
+* @param address of the wsa:FaultTo header
+*/
+public void setFaultTo(WSEndpointReference address) {
+this.faultTo = address;
+}
+public WSEndpointReference getSslFaultTo() {
+return sslFaultTo;
+}
+public void setSslFaultTo(WSEndpointReference sslFaultTo) {
+this.sslFaultTo = sslFaultTo;
+}
+/**
+* Getter for whether async is to be used with sync invoke
+*
+* @return whether async is to be used with sync invoke
+*/
+public boolean isUseAsyncWithSyncInvoke() {
+return useAsyncWithSyncInvoke;
+}
+/**
+*  Setter for whether async is to be used with sync invoke
+*
+* @param useAsyncWithSyncInvoke whether async is to be used with sync invoke
+*/
+public void setUseAsyncWithSyncInvoke(boolean useAsyncWithSyncInvoke) {
+this.useAsyncWithSyncInvoke = useAsyncWithSyncInvoke;
+}
+/**
+* Calculate a new EPR using an existing one and substituting SSL specific
+* host and port values.
+* @param epr Existing EPR that will be the starting point for the SSL
+*        version
+* @param sslHost New SSL host or null if the existing host should be used
+* @param sslPort New SSL port or -1 if the existing port should be used
+* @return
+*/
+public static WSEndpointReference
+enableSslForEpr(@NotNull WSEndpointReference epr,
+@Nullable String sslHost,
+int sslPort) {
+if (!epr.isAnonymous()) {
+String address = epr.getAddress();
+URL url;
+try {
+url = new URL(address);
+} catch (Exception e) {
+throw new RuntimeException(e);
+}
+String protocol = url.getProtocol();
+if (!protocol.equalsIgnoreCase("https")) {
+protocol = "https";
+String host = url.getHost();
+if (sslHost != null) {
+host = sslHost;
+}
+int port = url.getPort();
+if (sslPort > 0) {
+port = sslPort;
+}
+try {
+url = new URL(protocol, host, port, url.getFile());
+} catch (Exception e) {
+throw new RuntimeException(e);
+}
+address = url.toExternalForm();
+return
+new WSEndpointReference(address, epr.getVersion());
+}
+}
+return epr;
+}
+}

Mercurial > jdk8-mips64-public > jaxws / file comparison

comparison: src/share/jaxws_classes/com/sun/xml/internal/ws/api/addressing/OneWayFeature.java

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