KickJava   Java API By Example, From Geeks To Geeks.

Java > Open Source Codes > sample > amazon > amazonSimpleQueueService > util > RunnableReadQueue


1 /*
2 * Copyright 2004,2005 The Apache Software Foundation.
3 *
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
7 *
8 * http://www.apache.org/licenses/LICENSE-2.0
9 *
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
15 */
16 package sample.amazon.amazonSimpleQueueService.util;
17
18 import org.apache.axis2.Constants;
19 import org.apache.axis2.addressing.AddressingConstants;
20 import org.apache.axis2.addressing.EndpointReference;
21 import org.apache.axis2.clientapi.Call;
22 import org.apache.axis2.clientapi.Callback;
23 import org.apache.axis2.engine.AxisFault;
24 import org.apache.axis2.om.OMElement;
25 import sample.amazon.amazonSimpleQueueService.OMElementCreator;
26
27 import javax.swing.*;
28
29 /**
30  * This will create the Excutable code which runs seperately of GUI interations
31  *
32  * @author Saminda Abeyruwan <saminda@opensource.lk>
33  */
34 public class RunnableReadQueue extends QueueManager implements Runnable JavaDoc {
35     JTextField createQueue;
36     JTextArea result;
37     JTextField queueCode;
38     JTextField read;
39
40     public RunnableReadQueue(JTextField createQueue, JTextField queueCode, JTextField read,
41                              JTextArea result) {
42         this.createQueue = createQueue;
43         this.queueCode = queueCode;
44         this.read = read;
45         this.result = result;
46     }
47
48     public void run() {
49         OMElement readQueueElement = OMElementCreator.read(this.createQueue.getText(),getKey());
50         this.axis2EngineRuns("Read", readQueueElement,
51                 new SimpleQueueReadCallbackHandler(this.queueCode, this.result));
52     }
53
54     private void axis2EngineRuns(String JavaDoc operation, OMElement element,
55                                  Callback specificCallbackObject) {
56         //endpoint uri is hard coded....
57 String JavaDoc url = "http://webservices.amazon.com/onca/soap?Service=AWSSimpleQueueService";
58         try {
59             Call call = new Call();
60             call.setTo(new EndpointReference(AddressingConstants.WSA_TO, url));
61             call.setTransportInfo(Constants.TRANSPORT_HTTP, Constants.TRANSPORT_HTTP, false);
62             call.invokeNonBlocking(operation, element, specificCallbackObject);
63         } catch (AxisFault axisFault) {
64             axisFault.printStackTrace();
65         } catch (Exception JavaDoc e) {
66             e.printStackTrace();
67         }
68     }
69
70 }
71
Popular Tags