01: /*
02: * Portions Copyright 2006 Sun Microsystems, Inc. All Rights Reserved.
03: * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
04: *
05: * This code is free software; you can redistribute it and/or modify it
06: * under the terms of the GNU General Public License version 2 only, as
07: * published by the Free Software Foundation. Sun designates this
08: * particular file as subject to the "Classpath" exception as provided
09: * by Sun in the LICENSE file that accompanied this code.
10: *
11: * This code is distributed in the hope that it will be useful, but WITHOUT
12: * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
13: * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
14: * version 2 for more details (a copy is included in the LICENSE file that
15: * accompanied this code).
16: *
17: * You should have received a copy of the GNU General Public License version
18: * 2 along with this work; if not, write to the Free Software Foundation,
19: * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
20: *
21: * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
22: * CA 95054 USA or visit www.sun.com if you need additional information or
23: * have any questions.
24: */
25: package com.sun.xml.internal.ws.client;
26:
27: import javax.xml.ws.AsyncHandler;
28: import javax.xml.ws.Response;
29: import java.rmi.server.UID;
30: import java.util.concurrent.Callable;
31: import java.util.concurrent.Executor;
32:
33: public class AsyncHandlerService {
34:
35: private AsyncHandler _handler;
36: private UID _uid;
37: private Executor _executor;
38: private WSFuture wsfuture;
39: private Response response;
40:
41: public AsyncHandlerService(AsyncHandler handler, Executor executor) {
42: _uid = new UID();
43: _handler = handler;
44: _executor = executor;
45: }
46:
47: public synchronized UID getUID() {
48: return _uid;
49: }
50:
51: public void executeWSFuture() {
52:
53: _executor.execute((Runnable) wsfuture);
54: }
55:
56: public WSFuture<Object> setupAsyncCallback(
57: final Response<Object> result) {
58: response = result;
59:
60: wsfuture = new WSFuture<Object>(new Callable<Object>() {
61:
62: public Object call() throws Exception {
63: _handler.handleResponse(response);
64: return null;
65: }
66: });
67: return wsfuture;
68: }
69: }
|