Coverage Report

Coverage Report - org.kuali.rice.ksb.messaging.objectremoting.RemoteObjectCleanup

Classes in this File

0/21

 /*
  * Copyright 2005-2007 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.ksb.messaging.objectremoting;
 
 import javax.transaction.Synchronization;
 import javax.xml.namespace.QName;
 
 import org.apache.log4j.Logger;
 import org.kuali.rice.core.api.resourceloader.GlobalResourceLoader;
 import org.kuali.rice.core.api.resourceloader.GlobalResourceLoader;
 import org.springframework.transaction.support.TransactionSynchronization;
 
 /**
  * {@link Synchronization} to cleanup any remote objects created during the
  * current transaction.
  * 
  * @author Kuali Rice Team (rice.collab@kuali.org)
  */
 public class RemoteObjectCleanup implements TransactionSynchronization {
 
         private static final Logger LOG = Logger.getLogger(RemoteObjectCleanup.class);
 
         private QName objectRemoterName;
 
         private QName serviceToRemove;
 
         public RemoteObjectCleanup(QName objectRemoterName, QName serviceToRemove) {
                 this.setObjectRemoterName(objectRemoterName);
                 this.setServiceToRemove(serviceToRemove);
         }
 
         public void afterCompletion(int status) {
                 LOG.debug("Removing service: " + this.getServiceToRemove() + " from ObjectRemoter: " + this.getObjectRemoterName());
                 ObjectRemoterService objectRemoter = (ObjectRemoterService) GlobalResourceLoader.getService(this.getObjectRemoterName());
                 objectRemoter.removeService(this.getServiceToRemove());
         }
 
         public void beforeCompletion() {
             // template method
         }
 
         public QName getObjectRemoterName() {
                 return this.objectRemoterName;
         }
 
         public void setObjectRemoterName(QName objectRemoterName) {
                 this.objectRemoterName = objectRemoterName;
         }
 
         public QName getServiceToRemove() {
                 return this.serviceToRemove;
         }
 
         public void setServiceToRemove(QName serviceToRemove) {
                 this.serviceToRemove = serviceToRemove;
         }
 
         public void afterCommit() {
         }
 
         public void beforeCommit(boolean readOnly) {
         }
 
         public void resume() {
         }
 
         public void suspend() {
         }
         
         @Override
         public void flush() {
         }
 }

1		/*
2		* Copyright 2005-2007 The Kuali Foundation
3		*
4		*
5		* Licensed under the Educational Community License, Version 2.0 (the "License");
6		* you may not use this file except in compliance with the License.
7		* You may obtain a copy of the License at
8		*
9		* http://www.opensource.org/licenses/ecl2.php
10		*
11		* Unless required by applicable law or agreed to in writing, software
12		* distributed under the License is distributed on an "AS IS" BASIS,
13		* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14		* See the License for the specific language governing permissions and
15		* limitations under the License.
16		*/
17		package org.kuali.rice.ksb.messaging.objectremoting;
18
19		import javax.transaction.Synchronization;
20		import javax.xml.namespace.QName;
21
22		import org.apache.log4j.Logger;
23		import org.kuali.rice.core.api.resourceloader.GlobalResourceLoader;
24		import org.kuali.rice.core.api.resourceloader.GlobalResourceLoader;
25		import org.springframework.transaction.support.TransactionSynchronization;
26
27		/**
28		* {@link Synchronization} to cleanup any remote objects created during the
29		* current transaction.
30		*
31		* @author Kuali Rice Team (rice.collab@kuali.org)
32		*/
33		public class RemoteObjectCleanup implements TransactionSynchronization {
34
35	0	private static final Logger LOG = Logger.getLogger(RemoteObjectCleanup.class);
36
37		private QName objectRemoterName;
38
39		private QName serviceToRemove;
40
41	0	public RemoteObjectCleanup(QName objectRemoterName, QName serviceToRemove) {
42	0	this.setObjectRemoterName(objectRemoterName);
43	0	this.setServiceToRemove(serviceToRemove);
44	0	}
45
46		public void afterCompletion(int status) {
47	0	LOG.debug("Removing service: " + this.getServiceToRemove() + " from ObjectRemoter: " + this.getObjectRemoterName());
48	0	ObjectRemoterService objectRemoter = (ObjectRemoterService) GlobalResourceLoader.getService(this.getObjectRemoterName());
49	0	objectRemoter.removeService(this.getServiceToRemove());
50	0	}
51
52		public void beforeCompletion() {
53		// template method
54	0	}
55
56		public QName getObjectRemoterName() {
57	0	return this.objectRemoterName;
58		}
59
60		public void setObjectRemoterName(QName objectRemoterName) {
61	0	this.objectRemoterName = objectRemoterName;
62	0	}
63
64		public QName getServiceToRemove() {
65	0	return this.serviceToRemove;
66		}
67
68		public void setServiceToRemove(QName serviceToRemove) {
69	0	this.serviceToRemove = serviceToRemove;
70	0	}
71
72		public void afterCommit() {
73	0	}
74
75		public void beforeCommit(boolean readOnly) {
76	0	}
77
78		public void resume() {
79	0	}
80
81		public void suspend() {
82	0	}
83
84		@Override
85		public void flush() {
86	0	}
87		}