Clover Coverage Report - Implementation 2.0.0-SNAPSHOT
Coverage timestamp: Wed Dec 31 1969 19:00:00 EST
Overview   Package   File
    FRAMES   NO FRAMES     
../../../../../../../../img/srcFileCovDistChart0.png 0% of files have more coverage
62   166   28   3.88
16   128   0.45   16
16     1.75  
1    
 
  BAMServiceImpl       Line # 35 62 0% 28 94 0% 0.0
 
No Tests
 
1    /*
2    * Copyright 2006-2011 The Kuali Foundation
3    *
4    * Licensed under the Educational Community License, Version 2.0 (the "License");
5    * you may not use this file except in compliance with the License.
6    * You may obtain a copy of the License at
7    *
8    * http://www.opensource.org/licenses/ecl2.php
9    *
10    * Unless required by applicable law or agreed to in writing, software
11    * distributed under the License is distributed on an "AS IS" BASIS,
12    * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13    * See the License for the specific language governing permissions and
14    * limitations under the License.
15    */
16   
17    package org.kuali.rice.ksb.messaging.bam.service.impl;
18   
19    import org.apache.log4j.Logger;
20    import org.kuali.rice.core.api.config.property.Config;
21    import org.kuali.rice.core.api.config.property.ConfigContext;
22    import org.kuali.rice.core.api.reflect.ObjectDefinition;
23    import org.kuali.rice.ksb.messaging.ServiceInfo;
24    import org.kuali.rice.ksb.messaging.bam.BAMParam;
25    import org.kuali.rice.ksb.messaging.bam.BAMTargetEntry;
26    import org.kuali.rice.ksb.messaging.bam.dao.BAMDAO;
27    import org.kuali.rice.ksb.messaging.bam.service.BAMService;
28   
29    import javax.xml.namespace.QName;
30    import java.lang.reflect.Method;
31    import java.sql.Timestamp;
32    import java.util.List;
33   
34   
 
35    public class BAMServiceImpl implements BAMService {
36   
37    private static final Logger LOG = Logger.getLogger(BAMServiceImpl.class);
38   
39    private BAMDAO dao;
40   
 
41  0 toggle public BAMTargetEntry recordClientInvocation(ServiceInfo serviceDefinition, Object target, Method method, Object[] params) {
42  0 if (isEnabled()) {
43  0 try {
44  0 LOG.debug("A call was received... for service: " + serviceDefinition.getQname().toString() + " method: " + method.getName());
45  0 BAMTargetEntry bamTargetEntry = getBAMTargetEntry(Boolean.FALSE, serviceDefinition, target, method, params);
46  0 this.dao.save(bamTargetEntry);
47  0 return bamTargetEntry;
48    } catch (Throwable t) {
49  0 LOG.error("BAM Failed to record client invocation", t);
50  0 return null;
51    }
52    }
53  0 return null;
54    }
55   
 
56  0 toggle public BAMTargetEntry recordServerInvocation(Object target, ServiceInfo entry, Method method, Object[] params) {
57  0 if (isEnabled()) {
58  0 try {
59  0 LOG.debug("A call was received... for service: " + target.getClass().getName() + " method: " + method.getName());
60  0 BAMTargetEntry bamTargetEntry = getBAMTargetEntry(Boolean.TRUE, entry, target, method, params);
61  0 this.dao.save(bamTargetEntry);
62  0 return bamTargetEntry;
63    } catch (Throwable t) {
64  0 LOG.error("BAM Failed to record server invocation", t);
65    }
66    }
67  0 return null;
68    }
69   
 
70  0 toggle public BAMTargetEntry recordClientInvocationError(Throwable throwable, BAMTargetEntry bamTargetEntry) {
71  0 if (bamTargetEntry != null) {
72  0 try {
73  0 setThrowableOnBAMTargetEntry(throwable, bamTargetEntry);
74  0 this.dao.save(bamTargetEntry);
75  0 return bamTargetEntry;
76    } catch (Exception e) {
77  0 LOG.error("BAM Failed to record client invocation error", e);
78    }
79    }
80  0 return null;
81    }
82   
 
83  0 toggle public BAMTargetEntry recordServerInvocationError(Throwable throwable, BAMTargetEntry bamTargetEntry) {
84  0 if (bamTargetEntry != null) {
85  0 try {
86  0 setThrowableOnBAMTargetEntry(throwable, bamTargetEntry);
87  0 this.dao.save(bamTargetEntry);
88  0 return bamTargetEntry;
89    } catch (Exception e) {
90  0 LOG.error("BAM Failed to record service invocation error", e);
91    }
92    }
93  0 return null;
94    }
95   
 
96  0 toggle private void setThrowableOnBAMTargetEntry(Throwable throwable, BAMTargetEntry bamTargetEntry) {
97  0 if (throwable != null) {
98  0 bamTargetEntry.setExceptionMessage(throwable.getMessage());
99  0 bamTargetEntry.setExceptionToString(makeStringfit(throwable.toString()));
100    }
101    }
102   
 
103  0 toggle private BAMTargetEntry getBAMTargetEntry(Boolean serverInd, ServiceInfo entry, Object target, Method method, Object[] params) {
104  0 BAMTargetEntry bamEntry = new BAMTargetEntry();
105  0 bamEntry.setServerInvocation(serverInd);
106  0 bamEntry.setServiceName(entry.getQname().toString());
107  0 bamEntry.setServiceURL(entry.getEndpointUrl());
108  0 bamEntry.setTargetToString(makeStringfit(target.toString()));
109  0 bamEntry.setMethodName(method.getName());
110  0 bamEntry.setThreadName(Thread.currentThread().getName());
111  0 bamEntry.setCallDate(new Timestamp(System.currentTimeMillis()));
112  0 setBamParams(params, bamEntry);
113  0 return bamEntry;
114    }
115   
 
116  0 toggle private void setBamParams(Object[] params, BAMTargetEntry bamEntry) {
117  0 if (params == null) {
118  0 return;
119    }
120  0 for (int i = 0; i < params.length; i++) {
121  0 BAMParam bamParam = new BAMParam();
122  0 bamParam.setBamTargetEntry(bamEntry);
123  0 bamParam.setParam(params[i].toString());
124  0 bamEntry.addBamParam(bamParam);
125    }
126    }
127   
 
128  0 toggle private String makeStringfit(String string) {
129  0 if (string.length() > 1999) {
130  0 return string.substring(0, 1999);
131    }
132  0 return string;
133    }
134   
 
135  0 toggle public boolean isEnabled() {
136  0 return Boolean.valueOf(ConfigContext.getCurrentContextConfig().getProperty(Config.BAM_ENABLED));
137    }
138   
 
139  0 toggle public BAMDAO getDao() {
140  0 return this.dao;
141    }
142   
 
143  0 toggle public void setDao(BAMDAO dao) {
144  0 this.dao = dao;
145    }
146   
 
147  0 toggle public List<BAMTargetEntry> getCallsForService(QName serviceName) {
148  0 return getDao().getCallsForService(serviceName);
149    }
150   
 
151  0 toggle public List<BAMTargetEntry> getCallsForRemotedClasses(ObjectDefinition objDef) {
152  0 return getDao().getCallsForRemotedClasses(objDef);
153    }
154   
 
155  0 toggle public void clearBAMTables() {
156  0 getDao().clearBAMTables();
157    }
158   
 
159  0 toggle public List<BAMTargetEntry> getCallsForService(QName serviceName, String methodName) {
160  0 return getDao().getCallsForService(serviceName, methodName);
161    }
162   
 
163  0 toggle public List<BAMTargetEntry> getCallsForRemotedClasses(ObjectDefinition objDef, String methodName) {
164  0 return getDao().getCallsForRemotedClasses(objDef, methodName);
165    }
166    }
 
CloverReport generated by Clover Code Coverage v3.0.2
Wed Apr 13 2011 04:19:36 EDT.		   Clover: Open Source License registered to University of Arizona.