src/share/jaxws_classes/com/sun/xml/internal/ws/server/WSEndpointMOMProxy.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.server;
aoqi@0 27
aoqi@0 28 import com.sun.istack.internal.NotNull;
aoqi@0 29 import com.sun.xml.internal.ws.api.SOAPVersion;
aoqi@0 30 import com.sun.xml.internal.ws.api.WSBinding;
aoqi@0 31 import com.sun.xml.internal.ws.api.message.Packet;
aoqi@0 32 import com.sun.xml.internal.ws.api.model.SEIModel;
aoqi@0 33 import com.sun.xml.internal.ws.api.model.wsdl.WSDLPort;
aoqi@0 34 import com.sun.xml.internal.ws.api.pipe.Codec;
aoqi@0 35 import com.sun.xml.internal.ws.api.pipe.FiberContextSwitchInterceptor;
aoqi@0 36 import com.sun.xml.internal.ws.api.pipe.ServerTubeAssemblerContext;
aoqi@0 37 import com.sun.xml.internal.ws.api.pipe.ThrowableContainerPropertySet;
aoqi@0 38 import com.sun.xml.internal.ws.api.server.Container;
aoqi@0 39 import com.sun.xml.internal.ws.api.server.ServiceDefinition;
aoqi@0 40 import com.sun.xml.internal.ws.api.server.WSEndpoint;
aoqi@0 41 import com.sun.xml.internal.ws.policy.PolicyMap;
aoqi@0 42 import com.sun.xml.internal.ws.wsdl.OperationDispatcher;
aoqi@0 43 import com.sun.org.glassfish.gmbal.AMXClient;
aoqi@0 44 import com.sun.org.glassfish.gmbal.GmbalMBean;
aoqi@0 45 import com.sun.org.glassfish.gmbal.ManagedObjectManager;
aoqi@0 46
aoqi@0 47 import javax.management.MBeanServer;
aoqi@0 48 import javax.management.ObjectName;
aoqi@0 49 import java.io.IOException;
aoqi@0 50 import java.lang.annotation.Annotation;
aoqi@0 51 import java.lang.reflect.AnnotatedElement;
aoqi@0 52 import java.util.List;
aoqi@0 53 import java.util.ResourceBundle;
aoqi@0 54 import java.util.Set;
aoqi@0 55 import java.util.concurrent.Executor;
aoqi@0 56 import javax.xml.namespace.QName;
aoqi@0 57 import javax.xml.ws.EndpointReference;
aoqi@0 58 import org.w3c.dom.Element;
aoqi@0 59
aoqi@0 60 /**
aoqi@0 61 * {@link ManagedObjectManager} proxy class for {@link WSEndpointImpl} instances that could be used when Gmbal API calls
aoqi@0 62 * need to be deferred. The proxy tries to defer a need of a real ManagedObjectManager instance to the time when any
aoqi@0 63 * method from {@link ManagedObjectManager} is invoked on it. In this case a real instance of ManagedObjectManager is
aoqi@0 64 * obtained from WSEndpointImpl and the method is rather invoked on this object.
aoqi@0 65 */
aoqi@0 66 public class WSEndpointMOMProxy extends WSEndpoint implements ManagedObjectManager {
aoqi@0 67
aoqi@0 68 private final @NotNull
aoqi@0 69 WSEndpointImpl wsEndpoint;
aoqi@0 70 private ManagedObjectManager managedObjectManager;
aoqi@0 71
aoqi@0 72 WSEndpointMOMProxy(@NotNull WSEndpointImpl wsEndpoint) {
aoqi@0 73 this.wsEndpoint = wsEndpoint;
aoqi@0 74 }
aoqi@0 75
aoqi@0 76 /**
aoqi@0 77 * Returns a real instance of {@link ManagedObjectManager}
aoqi@0 78 *
aoqi@0 79 * @return an ManagedObjectManager instance
aoqi@0 80 */
aoqi@0 81 @Override
aoqi@0 82 public ManagedObjectManager getManagedObjectManager() {
aoqi@0 83 if (managedObjectManager == null) {
aoqi@0 84 managedObjectManager = wsEndpoint.obtainManagedObjectManager();
aoqi@0 85 }
aoqi@0 86 return managedObjectManager;
aoqi@0 87 }
aoqi@0 88
aoqi@0 89 void setManagedObjectManager(ManagedObjectManager managedObjectManager) {
aoqi@0 90 this.managedObjectManager = managedObjectManager;
aoqi@0 91 }
aoqi@0 92
aoqi@0 93 /**
aoqi@0 94 * Returns {@code true} if this proxy contains a reference to real ManagedObjectManager instance, {@code false}
aoqi@0 95 * otherwise.
aoqi@0 96 *
aoqi@0 97 * @return {@code true} if ManagedObjectManager has been created, {@code false} otherwise.
aoqi@0 98 */
aoqi@0 99 public boolean isInitialized() {
aoqi@0 100 return this.managedObjectManager != null;
aoqi@0 101 }
aoqi@0 102
aoqi@0 103 public WSEndpointImpl getWsEndpoint() {
aoqi@0 104 return wsEndpoint;
aoqi@0 105 }
aoqi@0 106
aoqi@0 107 @Override
aoqi@0 108 public void suspendJMXRegistration() {
aoqi@0 109 getManagedObjectManager().suspendJMXRegistration();
aoqi@0 110 }
aoqi@0 111
aoqi@0 112 @Override
aoqi@0 113 public void resumeJMXRegistration() {
aoqi@0 114 getManagedObjectManager().resumeJMXRegistration();
aoqi@0 115 }
aoqi@0 116
aoqi@0 117 @Override
aoqi@0 118 public boolean isManagedObject(Object obj) {
aoqi@0 119 return getManagedObjectManager().isManagedObject(obj);
aoqi@0 120 }
aoqi@0 121
aoqi@0 122 @Override
aoqi@0 123 public GmbalMBean createRoot() {
aoqi@0 124 return getManagedObjectManager().createRoot();
aoqi@0 125 }
aoqi@0 126
aoqi@0 127 @Override
aoqi@0 128 public GmbalMBean createRoot(Object root) {
aoqi@0 129 return getManagedObjectManager().createRoot(root);
aoqi@0 130 }
aoqi@0 131
aoqi@0 132 @Override
aoqi@0 133 public GmbalMBean createRoot(Object root, String name) {
aoqi@0 134 return getManagedObjectManager().createRoot(root, name);
aoqi@0 135 }
aoqi@0 136
aoqi@0 137 @Override
aoqi@0 138 public Object getRoot() {
aoqi@0 139 return getManagedObjectManager().getRoot();
aoqi@0 140 }
aoqi@0 141
aoqi@0 142 @Override
aoqi@0 143 public GmbalMBean register(Object parent, Object obj, String name) {
aoqi@0 144 return getManagedObjectManager().register(parent, obj, name);
aoqi@0 145 }
aoqi@0 146
aoqi@0 147 @Override
aoqi@0 148 public GmbalMBean register(Object parent, Object obj) {
aoqi@0 149 return getManagedObjectManager().register(parent, obj);
aoqi@0 150 }
aoqi@0 151
aoqi@0 152 @Override
aoqi@0 153 public GmbalMBean registerAtRoot(Object obj, String name) {
aoqi@0 154 return getManagedObjectManager().registerAtRoot(obj, name);
aoqi@0 155 }
aoqi@0 156
aoqi@0 157 @Override
aoqi@0 158 public GmbalMBean registerAtRoot(Object obj) {
aoqi@0 159 return getManagedObjectManager().registerAtRoot(obj);
aoqi@0 160 }
aoqi@0 161
aoqi@0 162 @Override
aoqi@0 163 public void unregister(Object obj) {
aoqi@0 164 getManagedObjectManager().unregister(obj);
aoqi@0 165 }
aoqi@0 166
aoqi@0 167 @Override
aoqi@0 168 public ObjectName getObjectName(Object obj) {
aoqi@0 169 return getManagedObjectManager().getObjectName(obj);
aoqi@0 170 }
aoqi@0 171
aoqi@0 172 @Override
aoqi@0 173 public AMXClient getAMXClient(Object obj) {
aoqi@0 174 return getManagedObjectManager().getAMXClient(obj);
aoqi@0 175 }
aoqi@0 176
aoqi@0 177 @Override
aoqi@0 178 public Object getObject(ObjectName oname) {
aoqi@0 179 return getManagedObjectManager().getObject(oname);
aoqi@0 180 }
aoqi@0 181
aoqi@0 182 @Override
aoqi@0 183 public void stripPrefix(String... str) {
aoqi@0 184 getManagedObjectManager().stripPrefix(str);
aoqi@0 185 }
aoqi@0 186
aoqi@0 187 @Override
aoqi@0 188 public void stripPackagePrefix() {
aoqi@0 189 getManagedObjectManager().stripPackagePrefix();
aoqi@0 190 }
aoqi@0 191
aoqi@0 192 @Override
aoqi@0 193 public String getDomain() {
aoqi@0 194 return getManagedObjectManager().getDomain();
aoqi@0 195 }
aoqi@0 196
aoqi@0 197 @Override
aoqi@0 198 public void setMBeanServer(MBeanServer server) {
aoqi@0 199 getManagedObjectManager().setMBeanServer(server);
aoqi@0 200 }
aoqi@0 201
aoqi@0 202 @Override
aoqi@0 203 public MBeanServer getMBeanServer() {
aoqi@0 204 return getManagedObjectManager().getMBeanServer();
aoqi@0 205 }
aoqi@0 206
aoqi@0 207 @Override
aoqi@0 208 public void setResourceBundle(ResourceBundle rb) {
aoqi@0 209 getManagedObjectManager().setResourceBundle(rb);
aoqi@0 210 }
aoqi@0 211
aoqi@0 212 @Override
aoqi@0 213 public ResourceBundle getResourceBundle() {
aoqi@0 214 return getManagedObjectManager().getResourceBundle();
aoqi@0 215 }
aoqi@0 216
aoqi@0 217 @Override
aoqi@0 218 public void addAnnotation(AnnotatedElement element, Annotation annotation) {
aoqi@0 219 getManagedObjectManager().addAnnotation(element, annotation);
aoqi@0 220 }
aoqi@0 221
aoqi@0 222 @Override
aoqi@0 223 public void setRegistrationDebug(RegistrationDebugLevel level) {
aoqi@0 224 getManagedObjectManager().setRegistrationDebug(level);
aoqi@0 225 }
aoqi@0 226
aoqi@0 227 @Override
aoqi@0 228 public void setRuntimeDebug(boolean flag) {
aoqi@0 229 getManagedObjectManager().setRuntimeDebug(flag);
aoqi@0 230 }
aoqi@0 231
aoqi@0 232 @Override
aoqi@0 233 public void setTypelibDebug(int level) {
aoqi@0 234 getManagedObjectManager().setTypelibDebug(level);
aoqi@0 235 }
aoqi@0 236
aoqi@0 237 @Override
aoqi@0 238 public void setJMXRegistrationDebug(boolean flag) {
aoqi@0 239 getManagedObjectManager().setJMXRegistrationDebug(flag);
aoqi@0 240 }
aoqi@0 241
aoqi@0 242 @Override
aoqi@0 243 public String dumpSkeleton(Object obj) {
aoqi@0 244 return getManagedObjectManager().dumpSkeleton(obj);
aoqi@0 245 }
aoqi@0 246
aoqi@0 247 @Override
aoqi@0 248 public void suppressDuplicateRootReport(boolean suppressReport) {
aoqi@0 249 getManagedObjectManager().suppressDuplicateRootReport(suppressReport);
aoqi@0 250 }
aoqi@0 251
aoqi@0 252 @Override
aoqi@0 253 public void close() throws IOException {
aoqi@0 254 getManagedObjectManager().close();
aoqi@0 255 }
aoqi@0 256
aoqi@0 257 @Override
aoqi@0 258 public boolean equalsProxiedInstance(WSEndpoint endpoint) {
aoqi@0 259 if (wsEndpoint == null) {
aoqi@0 260 return (endpoint == null);
aoqi@0 261 }
aoqi@0 262 return wsEndpoint.equals(endpoint);
aoqi@0 263 }
aoqi@0 264
aoqi@0 265 @Override
aoqi@0 266 public Codec createCodec() {
aoqi@0 267 return this.wsEndpoint.createCodec();
aoqi@0 268 }
aoqi@0 269
aoqi@0 270 @Override
aoqi@0 271 public QName getServiceName() {
aoqi@0 272 return this.wsEndpoint.getServiceName();
aoqi@0 273 }
aoqi@0 274
aoqi@0 275 @Override
aoqi@0 276 public QName getPortName() {
aoqi@0 277 return this.wsEndpoint.getPortName();
aoqi@0 278 }
aoqi@0 279
aoqi@0 280 @Override
aoqi@0 281 public Class getImplementationClass() {
aoqi@0 282 return this.wsEndpoint.getImplementationClass();
aoqi@0 283 }
aoqi@0 284
aoqi@0 285 @Override
aoqi@0 286 public WSBinding getBinding() {
aoqi@0 287 return this.wsEndpoint.getBinding();
aoqi@0 288 }
aoqi@0 289
aoqi@0 290 @Override
aoqi@0 291 public Container getContainer() {
aoqi@0 292 return this.wsEndpoint.getContainer();
aoqi@0 293 }
aoqi@0 294
aoqi@0 295 @Override
aoqi@0 296 public WSDLPort getPort() {
aoqi@0 297 return this.wsEndpoint.getPort();
aoqi@0 298 }
aoqi@0 299
aoqi@0 300 @Override
aoqi@0 301 public void setExecutor(Executor exec) {
aoqi@0 302 this.wsEndpoint.setExecutor(exec);
aoqi@0 303 }
aoqi@0 304
aoqi@0 305 @Override
aoqi@0 306 public void schedule(Packet request, CompletionCallback callback, FiberContextSwitchInterceptor interceptor) {
aoqi@0 307 this.wsEndpoint.schedule(request, callback, interceptor);
aoqi@0 308 }
aoqi@0 309
aoqi@0 310 @Override
aoqi@0 311 public PipeHead createPipeHead() {
aoqi@0 312 return this.wsEndpoint.createPipeHead();
aoqi@0 313 }
aoqi@0 314
aoqi@0 315 @Override
aoqi@0 316 public void dispose() {
aoqi@0 317 if (this.wsEndpoint != null) {
aoqi@0 318 this.wsEndpoint.dispose();
aoqi@0 319 }
aoqi@0 320 }
aoqi@0 321
aoqi@0 322 @Override
aoqi@0 323 public ServiceDefinition getServiceDefinition() {
aoqi@0 324 return this.wsEndpoint.getServiceDefinition();
aoqi@0 325 }
aoqi@0 326
aoqi@0 327 @Override
aoqi@0 328 public Set getComponentRegistry() {
aoqi@0 329 return this.wsEndpoint.getComponentRegistry();
aoqi@0 330 }
aoqi@0 331
aoqi@0 332 @Override
aoqi@0 333 public SEIModel getSEIModel() {
aoqi@0 334 return this.wsEndpoint.getSEIModel();
aoqi@0 335 }
aoqi@0 336
aoqi@0 337 @Override
aoqi@0 338 public PolicyMap getPolicyMap() {
aoqi@0 339 return this.wsEndpoint.getPolicyMap();
aoqi@0 340 }
aoqi@0 341
aoqi@0 342 @Override
aoqi@0 343 public void closeManagedObjectManager() {
aoqi@0 344 this.wsEndpoint.closeManagedObjectManager();
aoqi@0 345 }
aoqi@0 346
aoqi@0 347 @Override
aoqi@0 348 public ServerTubeAssemblerContext getAssemblerContext() {
aoqi@0 349 return this.wsEndpoint.getAssemblerContext();
aoqi@0 350 }
aoqi@0 351
aoqi@0 352 @Override
aoqi@0 353 public EndpointReference getEndpointReference(Class clazz, String address, String wsdlAddress, Element... referenceParameters) {
aoqi@0 354 return wsEndpoint.getEndpointReference(clazz, address, wsdlAddress, referenceParameters);
aoqi@0 355 }
aoqi@0 356
aoqi@0 357 @Override
aoqi@0 358 public EndpointReference getEndpointReference(Class clazz, String address, String wsdlAddress, List metadata, List referenceParameters) {
aoqi@0 359 return wsEndpoint.getEndpointReference(clazz, address, wsdlAddress, metadata, referenceParameters);
aoqi@0 360 }
aoqi@0 361
aoqi@0 362 @Override
aoqi@0 363 public OperationDispatcher getOperationDispatcher() {
aoqi@0 364 return wsEndpoint.getOperationDispatcher();
aoqi@0 365 }
aoqi@0 366
aoqi@0 367 @Override
aoqi@0 368 public Packet createServiceResponseForException(final ThrowableContainerPropertySet tc,
aoqi@0 369 final Packet responsePacket,
aoqi@0 370 final SOAPVersion soapVersion,
aoqi@0 371 final WSDLPort wsdlPort,
aoqi@0 372 final SEIModel seiModel,
aoqi@0 373 final WSBinding binding)
aoqi@0 374 {
aoqi@0 375 return wsEndpoint.createServiceResponseForException(tc, responsePacket, soapVersion,
aoqi@0 376 wsdlPort, seiModel, binding);
aoqi@0 377 }
aoqi@0 378 }

mercurial