1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17 package org.kuali.rice.kew.messaging;
18
19 import javax.xml.namespace.QName;
20
21 import org.apache.commons.lang.StringUtils;
22 import org.kuali.rice.kew.actionrequest.service.DocumentRequeuerService;
23 import org.kuali.rice.kew.actions.asyncservices.ActionInvocationService;
24 import org.kuali.rice.kew.actions.asyncservices.BlanketApproveProcessorService;
25 import org.kuali.rice.kew.actions.asyncservices.MoveDocumentService;
26 import org.kuali.rice.kew.docsearch.service.SearchableAttributeProcessingService;
27 import org.kuali.rice.kew.mail.service.ActionListImmediateEmailReminderService;
28 import org.kuali.rice.kew.routeheader.DocumentRouteHeaderValue;
29 import org.kuali.rice.kew.rule.service.RuleCacheProcessor;
30 import org.kuali.rice.ksb.messaging.service.KSBXMLService;
31 import org.kuali.rice.ksb.service.KSBServiceLocator;
32
33
34
35
36
37
38
39 public class MessageServiceNames {
40
41 public static final String DOCUMENT_ROUTING_SERVICE = "DocumentRoutingService";
42
43 public static final String ACTION_LIST_IMMEDIATE_REMINDER_SERVICE = "ImmediateEmailService";
44
45 public static final String BLANKET_APPROVE_PROCESSING_SERVICE = "BlanketApproveProcessorService";
46
47 public static final String SEARCHABLE_ATTRIBUTE_PROCESSING_SERVICE = "SearchableAttributeProcessorService";
48
49 public static final String DOCUMENT_REQUEUE_PROCESSING_SERVICE = "DocumentRequeueProcessorService";
50
51 public static final String WORKGROUP_MEMBERSHIP_CHANGE_SERVICE = "WorkgroupMembershipChangeService";
52
53 public static final String SERVICE_REMOVER_SERVICE = "RemoteClassRemoverService";
54
55 public static final String RULE_CACHE_PROCESSOR_SERVICE = "RuleCacheProcessorService";
56
57 public static final String ROLE_POKER = "RolePokerProcessorService";
58
59 public static final String MOVE_DOCUMENT_PROCESSOR = "MoveDocumentProcessor";
60
61 public static final String ACTION_INVOCATION_PROCESSOR = "ActionInvocationProcessor";
62
63 public static final String RESPONSIBILITY_CHANGE_SERVICE = "ResponsibilityChangeService";
64
65 private static QName getQName(String baseServiceName, DocumentRouteHeaderValue document) {
66 if (document != null) {
67 return new QName(document.getDocumentType().getServiceNamespace(), baseServiceName);
68 }
69 return new QName(baseServiceName);
70 }
71
72 private static QName getQName(String baseServiceName, String serviceNamespace) {
73 if (!StringUtils.isEmpty(serviceNamespace)) {
74 return new QName(serviceNamespace, baseServiceName);
75 }
76 return new QName(baseServiceName);
77 }
78
79 public static KSBXMLService getRouteDocumentMessageService(DocumentRouteHeaderValue document) {
80 return (KSBXMLService) getServiceAsynchronously(getQName(DOCUMENT_ROUTING_SERVICE, document), document);
81 }
82
83 public static MoveDocumentService getMoveDocumentProcessorService(DocumentRouteHeaderValue document) {
84 return (MoveDocumentService) getServiceAsynchronously(getQName(MOVE_DOCUMENT_PROCESSOR, document), document);
85 }
86
87 public static ActionInvocationService getActionInvocationProcessorService(DocumentRouteHeaderValue document) {
88 return (ActionInvocationService) getServiceAsynchronously(getQName(ACTION_INVOCATION_PROCESSOR, document), document);
89 }
90
91 public static BlanketApproveProcessorService getBlanketApproveProcessorService(DocumentRouteHeaderValue document) {
92 return (BlanketApproveProcessorService) getServiceAsynchronously(getQName(BLANKET_APPROVE_PROCESSING_SERVICE, document), document);
93 }
94
95 public static ActionListImmediateEmailReminderService getImmediateEmailService() {
96 return (ActionListImmediateEmailReminderService) getServiceAsynchronously(getQName(ACTION_LIST_IMMEDIATE_REMINDER_SERVICE, (DocumentRouteHeaderValue) null), (Long)null);
97 }
98
99 public static SearchableAttributeProcessingService getSearchableAttributeService(DocumentRouteHeaderValue document) {
100 return (SearchableAttributeProcessingService) getServiceAsynchronously(getQName(SEARCHABLE_ATTRIBUTE_PROCESSING_SERVICE, document), document);
101 }
102
103 public static RuleCacheProcessor getRuleCacheProcessor() {
104 return (RuleCacheProcessor) getServiceAsynchronously(new QName(MessageServiceNames.RULE_CACHE_PROCESSOR_SERVICE), (Long)null);
105 }
106
107 public static DocumentRequeuerService getDocumentRequeuerService(String serviceNamespace, Long documentId, long waitTime) {
108 QName serviceName = getQName(DOCUMENT_REQUEUE_PROCESSING_SERVICE, serviceNamespace);
109 if (waitTime > 0) {
110 return (DocumentRequeuerService) getDelayedServiceAsynchronously(serviceName, documentId, waitTime);
111 }
112 return (DocumentRequeuerService) getServiceAsynchronously(serviceName, documentId);
113 }
114
115 public static Object getServiceAsynchronously(QName serviceName, DocumentRouteHeaderValue document) {
116 return getServiceAsynchronously(serviceName, getDocId(document));
117 }
118
119 public static Object getServiceAsynchronously(QName serviceName, Long documentId) {
120 return KSBServiceLocator.getMessageHelper().getServiceAsynchronously(serviceName, null, null, (documentId == null ? null : documentId.toString()), null);
121 }
122
123 public static Object getDelayedServiceAsynchronously(QName serviceName, DocumentRouteHeaderValue document, long waitTime) {
124 return getDelayedServiceAsynchronously(serviceName, getDocId(document), waitTime);
125 }
126
127 public static Object getDelayedServiceAsynchronously(QName serviceName, Long documentId, long waitTime) {
128 return KSBServiceLocator.getMessageHelper().getServiceAsynchronously(serviceName, null, (documentId == null ? null : documentId.toString()), null, waitTime);
129 }
130
131 private static Long getDocId(DocumentRouteHeaderValue document) {
132 return (document == null ? null : document.getRouteHeaderId());
133 }
134
135 }