1 | |
|
2 | |
|
3 | |
|
4 | |
|
5 | |
|
6 | |
|
7 | |
|
8 | |
|
9 | |
|
10 | |
|
11 | |
|
12 | |
|
13 | |
|
14 | |
|
15 | |
|
16 | |
package org.kuali.rice.ksb.service; |
17 | |
|
18 | |
import java.util.List; |
19 | |
|
20 | |
import javax.persistence.EntityManagerFactory; |
21 | |
import javax.sql.DataSource; |
22 | |
|
23 | |
import org.apache.cxf.Bus; |
24 | |
import org.apache.cxf.bus.CXFBusImpl; |
25 | |
import org.apache.cxf.endpoint.ServerRegistry; |
26 | |
import org.apache.cxf.interceptor.Interceptor; |
27 | |
import org.apache.cxf.transport.servlet.ServletTransportFactory; |
28 | |
import org.kuali.rice.core.exception.RiceRemoteServiceConnectionException; |
29 | |
import org.kuali.rice.core.resourceloader.GlobalResourceLoader; |
30 | |
import org.kuali.rice.ksb.messaging.MessageHelper; |
31 | |
import org.kuali.rice.ksb.messaging.RemotedServiceRegistry; |
32 | |
import org.kuali.rice.ksb.messaging.bam.service.BAMService; |
33 | |
import org.kuali.rice.ksb.messaging.exceptionhandling.ExceptionRoutingService; |
34 | |
import org.kuali.rice.ksb.messaging.service.BusAdminService; |
35 | |
import org.kuali.rice.ksb.messaging.service.MessageQueueService; |
36 | |
import org.kuali.rice.ksb.messaging.service.ServiceRegistry; |
37 | |
import org.kuali.rice.ksb.messaging.threadpool.KSBScheduledPool; |
38 | |
import org.kuali.rice.ksb.messaging.threadpool.KSBThreadPool; |
39 | |
import org.kuali.rice.ksb.security.admin.service.JavaSecurityManagementService; |
40 | |
import org.kuali.rice.ksb.security.service.DigitalSignatureService; |
41 | |
import org.kuali.rice.ksb.util.KSBConstants; |
42 | |
import org.quartz.Scheduler; |
43 | |
import org.springframework.transaction.PlatformTransactionManager; |
44 | |
import org.springframework.transaction.support.TransactionTemplate; |
45 | |
|
46 | |
|
47 | 0 | public class KSBServiceLocator { |
48 | |
|
49 | |
|
50 | |
|
51 | |
|
52 | |
@Deprecated |
53 | |
public static final String OBJECT_REMOTER = KSBConstants.ServiceNames.OBJECT_REMOTER; |
54 | |
|
55 | |
|
56 | |
|
57 | |
|
58 | |
@Deprecated |
59 | |
public static final String SERVICE_REMOVER_SERVICE = KSBConstants.ServiceNames.SERVICE_REMOVER_SERVICE; |
60 | |
|
61 | |
|
62 | |
|
63 | |
|
64 | |
@Deprecated |
65 | |
public static final String THREAD_POOL_SERVICE = KSBConstants.ServiceNames.THREAD_POOL_SERVICE; |
66 | |
|
67 | |
|
68 | |
|
69 | |
|
70 | |
@Deprecated |
71 | |
public static final String REMOTED_SERVICE_REGISTRY = KSBConstants.ServiceNames.REMOTED_SERVICE_REGISTRY; |
72 | |
|
73 | |
|
74 | |
|
75 | |
|
76 | |
@Deprecated |
77 | |
public static final String REPEAT_TOPIC_INVOKING_QUEUE = KSBConstants.ServiceNames.REPEAT_TOPIC_INVOKING_QUEUE; |
78 | |
|
79 | |
|
80 | |
|
81 | |
|
82 | |
@Deprecated |
83 | |
public static final String ENCRYPTION_SERVICE = KSBConstants.ServiceNames.ENCRYPTION_SERVICE; |
84 | |
|
85 | |
|
86 | |
|
87 | |
|
88 | |
@Deprecated |
89 | |
public static final String DIGITAL_SIGNATURE_SERVICE = KSBConstants.ServiceNames.DIGITAL_SIGNATURE_SERVICE; |
90 | |
|
91 | |
|
92 | |
|
93 | |
|
94 | |
@Deprecated |
95 | |
public static final String JAVA_SECURITY_MANAGEMENT_SERVICE = KSBConstants.ServiceNames.JAVA_SECURITY_MANAGEMENT_SERVICE; |
96 | |
|
97 | |
|
98 | |
|
99 | |
|
100 | |
@Deprecated |
101 | |
public static final String CACHE_ADMINISTRATOR_FACTORY = KSBConstants.ServiceNames.CACHE_ADMINISTRATOR_FACTORY; |
102 | |
|
103 | |
|
104 | |
|
105 | |
|
106 | |
@Deprecated |
107 | |
public static final String JTA_TRANSACTION_MANAGER = KSBConstants.ServiceNames.JTA_TRANSACTION_MANAGER; |
108 | |
|
109 | |
|
110 | |
|
111 | |
|
112 | |
@Deprecated |
113 | |
public static final String SCHEDULED_THREAD_POOL_SERVICE = KSBConstants.ServiceNames.SCHEDULED_THREAD_POOL_SERVICE; |
114 | |
|
115 | |
|
116 | |
|
117 | |
|
118 | |
@Deprecated |
119 | |
public static final String BUS_ADMIN_SERVICE = KSBConstants.ServiceNames.BUS_ADMIN_SERVICE; |
120 | |
|
121 | |
|
122 | |
|
123 | |
|
124 | |
@Deprecated |
125 | |
public static final String MESSAGE_ENTITY_MANAGER_FACTORY = KSBConstants.ServiceNames.MESSAGE_ENTITY_MANAGER_FACTORY; |
126 | |
|
127 | |
|
128 | |
|
129 | |
|
130 | |
@Deprecated |
131 | |
public static final String REGISTRY_ENTITY_MANAGER_FACTORY = KSBConstants.ServiceNames.REGISTRY_ENTITY_MANAGER_FACTORY; |
132 | |
|
133 | |
|
134 | |
public static Object getService(String name) { |
135 | 0 | return GlobalResourceLoader.getService(name); |
136 | |
} |
137 | |
|
138 | |
public static EntityManagerFactory getMessageEntityManagerFactory() { |
139 | 0 | return (EntityManagerFactory) getService(KSBConstants.ServiceNames.MESSAGE_ENTITY_MANAGER_FACTORY); |
140 | |
} |
141 | |
|
142 | |
public static EntityManagerFactory getRegistryEntityManagerFactory() { |
143 | 0 | return (EntityManagerFactory) getService(KSBConstants.ServiceNames.REGISTRY_ENTITY_MANAGER_FACTORY); |
144 | |
} |
145 | |
|
146 | |
public static TransactionTemplate getTransactionTemplate() { |
147 | 0 | return (TransactionTemplate) getService(KSBConstants.ServiceNames.TRANSACTION_TEMPLATE); |
148 | |
} |
149 | |
|
150 | |
public static PlatformTransactionManager getPlatformTransactionManager() { |
151 | 0 | return (PlatformTransactionManager) getService(KSBConstants.ServiceNames.TRANSACTION_MANAGER); |
152 | |
} |
153 | |
|
154 | |
public static BAMService getBAMService() { |
155 | 0 | return (BAMService) getService(KSBConstants.ServiceNames.BAM_SERVICE); |
156 | |
} |
157 | |
|
158 | |
public static MessageHelper getMessageHelper() { |
159 | 0 | return (MessageHelper) getService(KSBConstants.ServiceNames.MESSAGE_HELPER); |
160 | |
} |
161 | |
|
162 | |
public static MessageQueueService getRouteQueueService() { |
163 | 0 | return (MessageQueueService) getService(KSBConstants.ServiceNames.ROUTE_QUEUE_SERVICE); |
164 | |
} |
165 | |
|
166 | |
public static ExceptionRoutingService getExceptionRoutingService() { |
167 | 0 | return (ExceptionRoutingService) getService(KSBConstants.ServiceNames.EXCEPTION_MESSAGING_SERVICE); |
168 | |
} |
169 | |
|
170 | |
public static RemotedServiceRegistry getServiceDeployer() { |
171 | 0 | return (RemotedServiceRegistry) getService(KSBConstants.ServiceNames.REMOTED_SERVICE_REGISTRY); |
172 | |
} |
173 | |
|
174 | |
public static DigitalSignatureService getDigitalSignatureService() { |
175 | 0 | return (DigitalSignatureService) getService(KSBConstants.ServiceNames.DIGITAL_SIGNATURE_SERVICE); |
176 | |
} |
177 | |
|
178 | |
public static JavaSecurityManagementService getJavaSecurityManagementService() { |
179 | 0 | return (JavaSecurityManagementService) getService(KSBConstants.ServiceNames.JAVA_SECURITY_MANAGEMENT_SERVICE); |
180 | |
} |
181 | |
|
182 | |
public static KSBThreadPool getThreadPool() { |
183 | 0 | return (KSBThreadPool) getService(KSBConstants.ServiceNames.THREAD_POOL_SERVICE); |
184 | |
} |
185 | |
|
186 | |
public static KSBScheduledPool getScheduledPool() { |
187 | 0 | return (KSBScheduledPool) getService(KSBConstants.ServiceNames.SCHEDULED_THREAD_POOL_SERVICE); |
188 | |
} |
189 | |
|
190 | |
public static ServiceRegistry getServiceRegistry() { |
191 | 0 | return (ServiceRegistry) getService(KSBConstants.ServiceNames.SERVICE_REGISTRY); |
192 | |
} |
193 | |
|
194 | |
public static Bus getCXFBus(){ |
195 | 0 | return (CXFBusImpl) getService(KSBConstants.ServiceNames.CXF_BUS); |
196 | |
} |
197 | |
|
198 | |
public static ServletTransportFactory getCXFServletTransportFactory(){ |
199 | 0 | return (ServletTransportFactory)getService(KSBConstants.ServiceNames.CXF_SERVLET_TRANSPORT_FACTORY); |
200 | |
} |
201 | |
|
202 | |
public static ServerRegistry getCXFServerRegistry(){ |
203 | 0 | return (ServerRegistry)getService(KSBConstants.ServiceNames.CXF_SERVER_REGISTRY); |
204 | |
} |
205 | |
|
206 | |
public static List<Interceptor> getInInterceptors() { |
207 | |
try { |
208 | 0 | return (List<Interceptor>) getService(KSBConstants.ServiceNames.BUS_IN_INTERCEPTORS); |
209 | |
} |
210 | 0 | catch(RiceRemoteServiceConnectionException ex) { |
211 | |
|
212 | 0 | return null; |
213 | |
} |
214 | |
} |
215 | |
|
216 | |
public static List<Interceptor> getOutInterceptors() { |
217 | |
try { |
218 | 0 | return (List<Interceptor>) getService(KSBConstants.ServiceNames.BUS_OUT_INTERCEPTORS); |
219 | |
} |
220 | 0 | catch(RiceRemoteServiceConnectionException ex) { |
221 | |
|
222 | 0 | return null; |
223 | |
} |
224 | |
} |
225 | |
|
226 | |
public static DataSource getMessageDataSource() { |
227 | 0 | return (DataSource) getService(KSBConstants.ServiceNames.MESSAGE_DATASOURCE); |
228 | |
} |
229 | |
|
230 | |
public static DataSource getMessageNonTransactionalDataSource() { |
231 | 0 | return (DataSource) getService(KSBConstants.ServiceNames.MESSAGE_NON_TRANSACTIONAL_DATASOURCE); |
232 | |
} |
233 | |
|
234 | |
public static DataSource getRegistryDataSource() { |
235 | 0 | return (DataSource) getService(KSBConstants.ServiceNames.REGISTRY_DATASOURCE); |
236 | |
} |
237 | |
|
238 | |
public static Scheduler getScheduler() { |
239 | 0 | return (Scheduler) getService(KSBConstants.ServiceNames.SCHEDULER); |
240 | |
} |
241 | |
|
242 | |
public static BusAdminService getService() { |
243 | 0 | return (BusAdminService) getService(KSBConstants.ServiceNames.BUS_ADMIN_SERVICE); |
244 | |
} |
245 | |
|
246 | |
} |