| /* |
| * Copyright 2004,2005 The Apache Software Foundation. |
| * |
| * Licensed under the Apache License, Version 2.0 (the "License"); |
| * you may not use this file except in compliance with the License. |
| * You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| |
| package sample.amazon.amazonSimpleQueueService; |
| |
| import org.apache.axiom.om.OMAbstractFactory; |
| import org.apache.axiom.om.OMElement; |
| import org.apache.axiom.om.OMNamespace; |
| import org.apache.axiom.soap.SOAPFactory; |
| |
| /** |
| * This will create the OMElement needed to be used in invokeNonBlocking() method |
| * OMElements are created for CreateQueueu, ListMyQueues, Read, and Enqueue operations |
| */ |
| public class OMElementCreator { |
| public static OMElement creatQueueElement(String createQueueElement, |
| String key) { |
| SOAPFactory factory = OMAbstractFactory.getSOAP11Factory(); |
| OMNamespace opN = factory.createOMNamespace( |
| "http://webservices.amazon.com/AWSSimpleQueueService/2005-01-01", |
| "nsQ"); |
| OMElement createQueue = factory.createOMElement("CreateQueue", opN); |
| OMElement subID = factory.createOMElement("SubscriptionId", opN); |
| OMElement request = factory.createOMElement("Request", opN); |
| OMElement queueName = factory.createOMElement("QueueName", opN); |
| OMElement readLockTimeOutSeconds = factory.createOMElement( |
| "ReadLockTimeoutSeconds", opN); |
| request.addChild(queueName); |
| request.addChild(readLockTimeOutSeconds); |
| subID.addChild(factory.createOMText(key)); |
| queueName.addChild(factory.createOMText(createQueueElement)); |
| readLockTimeOutSeconds.addChild(factory.createOMText("10")); |
| createQueue.addChild(subID); |
| createQueue.addChild(request); |
| return createQueue; |
| } |
| |
| public static OMElement deleteQueueElement(String deleteQueueName, |
| String key) { |
| SOAPFactory factory = OMAbstractFactory.getSOAP11Factory(); |
| OMNamespace opN = factory.createOMNamespace( |
| "http://webservices.amazon.com/AWSSimpleQueueService/2005-01-01", |
| "nsQ"); |
| OMElement enque = factory.createOMElement("DeleteQueue", opN); |
| OMElement subID = factory.createOMElement("SubscriptionId", opN); |
| OMElement request = factory.createOMElement("Request", opN); |
| OMElement queueName = factory.createOMElement("QueueName", opN); |
| //OMElement queueID = factory.createOMElement("QueueId",opN); |
| request.addChild(queueName); |
| //request.addChild(queueID); |
| subID.addChild(factory.createOMText(key)); |
| queueName.addChild(factory.createOMText(deleteQueueName)); |
| //queueID.addChild(factory.createOMText(queueIden)); |
| enque.addChild(subID); |
| enque.addChild(request); |
| return enque; |
| } |
| |
| public static OMElement enqueueElement(String queueEntyBody, |
| String queueIden, |
| String key) { |
| SOAPFactory factory = OMAbstractFactory.getSOAP11Factory(); |
| OMNamespace opN = factory.createOMNamespace( |
| "http://webservices.amazon.com/AWSSimpleQueueService/2005-01-01", |
| "nsQ"); |
| OMElement enque = factory.createOMElement("Enqueue", opN); |
| OMElement subID = factory.createOMElement("SubscriptionId", opN); |
| OMElement request = factory.createOMElement("Request", opN); |
| //OMElement queueName = factory.createOMElement("QueueName",opN); |
| OMElement queueID = factory.createOMElement("QueueId", opN); |
| OMElement queueEntryBodies = factory.createOMElement( |
| "QueueEntryBodies", opN); |
| OMElement queueEntryBody1 = factory.createOMElement("QueueEntryBody", |
| opN); |
| queueEntryBodies.addChild(queueEntryBody1); |
| //request.addChild(queueName); |
| request.addChild(queueID); |
| request.addChild(queueEntryBodies); |
| subID.addChild(factory.createOMText(key)); |
| //queueName.addChild(factory.createOMText("Test Queue LSF ")); |
| queueID.addChild(factory.createOMText(queueIden)); |
| queueEntryBody1.addChild(factory.createOMText(queueEntyBody)); |
| enque.addChild(subID); |
| enque.addChild(request); |
| return enque; |
| } |
| |
| public static OMElement queueListElement(String key) { |
| SOAPFactory factory = OMAbstractFactory.getSOAP11Factory(); |
| OMNamespace opN = factory.createOMNamespace( |
| "http://webservices.amazon.com/AWSSimpleQueueService/2005-01-01", |
| "nsQ"); |
| OMElement listMyQueues = factory.createOMElement("ListMyQueues", opN); |
| OMElement subID = factory.createOMElement("SubscriptionId", opN); |
| OMElement request = factory.createOMElement("Request", opN); |
| subID.addChild(factory.createOMText(key)); |
| listMyQueues.addChild(subID); |
| listMyQueues.addChild(request); |
| return listMyQueues; |
| } |
| |
| public static OMElement read(String requiredQueueName, String key) { |
| SOAPFactory factory = OMAbstractFactory.getSOAP11Factory(); |
| OMNamespace opN = factory.createOMNamespace( |
| "http://webservices.amazon.com/AWSSimpleQueueService/2005-01-01", |
| "nsQ"); |
| OMElement read = factory.createOMElement("Read", opN); |
| OMElement subID = factory.createOMElement("SubscriptionId", opN); |
| OMElement request = factory.createOMElement("Request", opN); |
| OMElement queueName = factory.createOMElement("QueueName", opN); |
| //OMElement queueID = factory.createOMElement("QueueId",opN); |
| OMElement readCount = factory.createOMElement("ReadCount", opN); |
| request.addChild(queueName); |
| //request.addChild(queueID); |
| request.addChild(readCount); |
| subID.addChild(factory.createOMText(key)); |
| queueName.addChild(factory.createOMText(requiredQueueName)); |
| //queueID.addChild(factory.createOMText(queueIden)); |
| readCount.addChild(factory.createOMText("25")); |
| read.addChild(subID); |
| read.addChild(request); |
| return read; |
| } |
| } |