/**

  * Copyright 2005-2011 The Kuali Foundation

  *

  * Licensed under the Educational Community 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.opensource.org/licenses/ecl2.php

  *

  * 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 org.kuali.rice.kew.messaging;

 import javax.xml.namespace.QName;

 import org.apache.commons.lang.StringUtils;

 import org.kuali.rice.kew.api.action.RolePokerQueue;

 import org.kuali.rice.kew.api.document.DocumentOrchestrationQueue;

 import org.kuali.rice.kew.api.document.DocumentRefreshQueue;

 import org.kuali.rice.kew.api.action.ActionInvocationQueue;

 import org.kuali.rice.kew.api.KewApiConstants;

 import org.kuali.rice.kew.api.document.DocumentProcessingQueue;

 import org.kuali.rice.kew.routeheader.DocumentRouteHeaderValue;

 import org.kuali.rice.kew.service.KEWServiceLocator;

 import org.kuali.rice.ksb.api.KsbApiServiceLocator;

 /**

  * Utility class for accessing names of common asynchronous services.

  *

  * @author Kuali Rice Team (rice.collab@kuali.org)

  */

 public class MessageServiceNames {

         private static final QName DOCUMENT_PROCESSING_QUEUE = new QName(KewApiConstants.Namespaces.KEW_NAMESPACE_2_0, "documentProcessingQueue");

         private static final QName DOCUMENT_ORCHESTRATION_QUEUE = new QName(KewApiConstants.Namespaces.KEW_NAMESPACE_2_0, "documentOrchestrationQueue");

         private static final QName DOCUMENT_REFRESH_QUEUE = new QName(KewApiConstants.Namespaces.KEW_NAMESPACE_2_0, "documentRefreshQueue");

         private static final QName ROLE_POKER_QUEUE = new QName(KewApiConstants.Namespaces.KEW_NAMESPACE_2_0, "rolePokerQueue");

     private static final QName ACTION_INVOCATION_QUEUE = new QName(KewApiConstants.Namespaces.KEW_NAMESPACE_2_0, "actionInvocationQueue");

         private static QName getQName(String baseServiceName, DocumentRouteHeaderValue document) {

                 if (document != null) {

                         return new QName(document.getDocumentType().getApplicationId(), baseServiceName);

                 }

                 return new QName(baseServiceName);

         }

     public static DocumentProcessingQueue getDocumentProcessingQueue(DocumentRouteHeaderValue document) {

         return (DocumentProcessingQueue)getServiceAsynchronously(DOCUMENT_PROCESSING_QUEUE, document);

     }

         public static ActionInvocationQueue getActionInvocationProcessorService(DocumentRouteHeaderValue document) {

                 return (ActionInvocationQueue) getServiceAsynchronously(ACTION_INVOCATION_QUEUE, document);

         }

         public static DocumentOrchestrationQueue getDocumentOrchestrationQueue(DocumentRouteHeaderValue document) {

                 return (DocumentOrchestrationQueue) getServiceAsynchronously(DOCUMENT_ORCHESTRATION_QUEUE, document);

         }

     public static RolePokerQueue getRolePokerQueue(String documentId) {

                 return (RolePokerQueue) getServiceAsynchronously(ROLE_POKER_QUEUE, documentId);

         }

         public static DocumentRefreshQueue getDocumentRequeuerService(String applicationId, String documentId, long waitTime) {

                 if (waitTime > 0) {

                         return (DocumentRefreshQueue) getDelayedServiceAsynchronously(DOCUMENT_REFRESH_QUEUE, documentId, waitTime);

                 }

                 return (DocumentRefreshQueue) getServiceAsynchronously(DOCUMENT_REFRESH_QUEUE, documentId, applicationId);

         }

         public static Object getServiceAsynchronously(QName serviceName, DocumentRouteHeaderValue document) {

         String applicationId = document.getDocumentType().getApplicationId();

                 return getServiceAsynchronously(serviceName, getDocId(document), applicationId);

         }

     public static Object getServiceAsynchronously(QName serviceName, String documentId) {

         String applicationId = null;

         if (StringUtils.isNotBlank(documentId)) {

             applicationId = KEWServiceLocator.getRouteHeaderService().getApplicationIdByDocumentId(documentId);

         }

         return getServiceAsynchronously(serviceName, documentId, applicationId);

         }

         public static Object getServiceAsynchronously(QName serviceName, String documentId, String applicationId) {

                 return KsbApiServiceLocator.getMessageHelper().getServiceAsynchronously(serviceName, applicationId, null, null, (documentId == null ? null : documentId.toString()), null);

         }

         public static Object getDelayedServiceAsynchronously(QName serviceName, DocumentRouteHeaderValue document, long waitTime) {

                 return getDelayedServiceAsynchronously(serviceName, getDocId(document), waitTime);

         }

         public static Object getDelayedServiceAsynchronously(QName serviceName, String documentId, long waitTime) {

                 return KsbApiServiceLocator.getMessageHelper().getServiceAsynchronously(serviceName, null, (documentId == null ? null : documentId.toString()), null, waitTime);

         }

         private static String getDocId(DocumentRouteHeaderValue document) {

                 return (document == null ? null : document.getDocumentId());

         }

 }