1 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 34 public class RunnableDeleteQueue extends QueueManager implements Runnable { 35 JTextField createQueue; 36 JTextArea result; 37 JTextField queueCode; 38 JTextField read; 39 JButton button; 40 41 public RunnableDeleteQueue(JTextField createQueue, JTextField queueCode, JTextField read, 42 JTextArea result, JButton button) { 43 this.createQueue = createQueue; 44 this.queueCode = queueCode; 45 this.read = read; 46 this.result = result; 47 this.button = button; 48 } 49 50 public void run() { 51 OMElement deleteQueueElement = OMElementCreator.deleteQueueElement(this.createQueue.getText(),getKey()); 52 this.axis2EngineRuns("DeleteQueue", deleteQueueElement, 53 new SimpleQueueDeleteQueueCallbackHandler(this.result, this.button)); 54 } 55 56 private void axis2EngineRuns(String operation, OMElement element, 57 Callback specificCallbackObject) { 58 String url = "http://webservices.amazon.com/onca/soap?Service=AWSSimpleQueueService"; 60 try { 61 Call call = new Call(); 62 call.setTo(new EndpointReference(AddressingConstants.WSA_TO, url)); 63 call.setTransportInfo(Constants.TRANSPORT_HTTP, Constants.TRANSPORT_HTTP, false); 64 call.invokeNonBlocking(operation, element, specificCallbackObject); 65 } catch (AxisFault axisFault) { 66 axisFault.printStackTrace(); 67 } catch (Exception e) { 68 e.printStackTrace(); 69 } 70 } 71 72 } 73 | Popular Tags |