Coverage Report

Coverage Report - org.apache.commons.workflow.util.ContextSupport

Classes in this File

Line Coverage

Branch Coverage

Complexity

ContextSupport

0/88

0/34

3.667

 /*
  * Copyright 1999-2001,2004 The Apache Software Foundation.
  * 
  * Licensed under the Apache 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.apache.org/licenses/LICENSE-2.0
  * 
  * 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.apache.commons.workflow.util;
 
 
 import java.util.Map;
 import org.apache.commons.workflow.Context;
 import org.apache.commons.workflow.ContextEvent;
 import org.apache.commons.workflow.ContextListener;
 import org.apache.commons.workflow.Step;
 import org.apache.commons.workflow.StepException;
 
 
 /**
  * <strong>ContextSupport</strong> is a convenience class for managing the
  * firing of <code>ContextEvents</code> to registered
  * <code>ContextListeners</code>.
  *
  * @version $Revision: 155475 $ $Date: 2005-02-26 13:31:11 +0000 (Sat, 26 Feb 2005) $
  * @author Craig R. McClanahan
  */
 
 public class ContextSupport {
 
 
     // ----------------------------------------------------------- Constructors
 
 
     /**
      * Construct a new ContextSupport object associated with the
      * specified Context.
      *
      * @param context Context for whom we will fire events
      */
     public ContextSupport(Context context) {
 
         super();
         this.context = context;
 
     }
 
 
     // ----------------------------------------------------- Instance Variables
 
 
     /**
      * The set of registered <code>ContextListener</code> event listeners.
      */
     protected ContextListener listeners[] = new ContextListener[0];
 
 
     /**
      * The <code>Context</code> for whom we will fire events.
      */
     protected Context context = null;
 
 
     // ------------------------------------------------- Event Listener Methods
 
 
     /**
      * Add a listener that is notified each time beans are added,
      * replaced, or removed in this context.
      *
      * @param listener The ContextListener to be added
      */
     public void addContextListener(ContextListener listener) {
 
       synchronized (listeners) {
           ContextListener results[] =
             new ContextListener[listeners.length + 1];
           System.arraycopy(listeners, 0, results, 0, listeners.length);
           results[listeners.length] = listener;
           listeners = results;
       }
 
     }
 
 
     /**
      * Remove a listener that is notified each time beans are added,
      * replaced, or removed in this context.
      *
      * @param listener The ContextListener to be removed
      */
     public void removeContextListener(ContextListener listener) {
 
         synchronized (listeners) {
             int n = -1;
             for (int i = 0; i < listeners.length; i++) {
                 if (listeners[i] == listener) {
                     n = i;
                     break;
                 }
             }
             if (n < 0)
                 return;
             ContextListener results[] =
               new ContextListener[listeners.length - 1];
             int j = 0;
             for (int i = 0; i < listeners.length; i++) {
                 if (i != n)
                     results[j++] = listeners[i];
             }
             listeners = results;
         }
 
     }
 
 
     // --------------------------------------------------- Event Firing Methods
 
 
     /**
      * Fire a <code>afterActivity</code> event to all registered listeners.
      *
      * @param step Step that was executed last
      */
     public void fireAfterActivity(Step step) {
 
         if (listeners.length == 0)
             return;
         ContextEvent event = new ContextEvent(context, step);
         ContextListener interested[] = null;
         synchronized (listeners) {
             interested = (ContextListener[]) listeners.clone();
         }
         for (int i = 0; i < interested.length; i++)
             interested[i].afterActivity(event);
 
     }
 
 
     /**
      * Fire a <code>afterActivity</code> event to all registered listeners.
      *
      * @param step Step that was executed last
      * @param exception StepException thrown by the last Step
      */
     public void fireAfterActivity(Step step, StepException exception) {
 
         if (listeners.length == 0)
             return;
         ContextEvent event = new ContextEvent(context, step, exception);
         ContextListener interested[] = null;
         synchronized (listeners) {
             interested = (ContextListener[]) listeners.clone();
         }
         for (int i = 0; i < interested.length; i++)
             interested[i].afterActivity(event);
 
     }
 
 
     /**
      * Fire a <code>afterStep</code> event to all registered listeners.
      *
      * @param step Step that was executed
      */
     public void fireAfterStep(Step step) {
 
         if (listeners.length == 0)
             return;
         ContextEvent event = new ContextEvent(context, step);
         ContextListener interested[] = null;
         synchronized (listeners) {
             interested = (ContextListener[]) listeners.clone();
         }
         for (int i = 0; i < interested.length; i++)
             interested[i].afterStep(event);
 
     }
 
 
     /**
      * Fire a <code>afterStep</code> event to all registered listeners.
      *
      * @param step Step that was executed
      * @param exception StepException thrown by the executed step
      */
     public void fireAfterStep(Step step, StepException exception) {
 
         if (listeners.length == 0)
             return;
         ContextEvent event = new ContextEvent(context, step, exception);
         ContextListener interested[] = null;
         synchronized (listeners) {
             interested = (ContextListener[]) listeners.clone();
         }
         for (int i = 0; i < interested.length; i++)
             interested[i].afterStep(event);
 
     }
 
 
     /**
      * Fire a <code>beforeActivity</code> event to all registered listeners.
      *
      * @param step Step that will be executed first
      */
     public void fireBeforeActivity(Step step) {
 
         if (listeners.length == 0)
             return;
         ContextEvent event = new ContextEvent(context, step);
         ContextListener interested[] = null;
         synchronized (listeners) {
             interested = (ContextListener[]) listeners.clone();
         }
         for (int i = 0; i < interested.length; i++)
             interested[i].beforeActivity(event);
 
     }
 
 
     /**
      * Fire a <code>beforeStep</code> event to all registered listeners.
      *
      * @param step Step that is about to be executed
      */
     public void fireBeforeStep(Step step) {
 
         if (listeners.length == 0)
             return;
         ContextEvent event = new ContextEvent(context, step);
         ContextListener interested[] = null;
         synchronized (listeners) {
             interested = (ContextListener[]) listeners.clone();
         }
         for (int i = 0; i < interested.length; i++)
             interested[i].beforeStep(event);
 
     }
 
 
 }

1		/*
2		* Copyright 1999-2001,2004 The Apache Software Foundation.
3		*
4		* Licensed under the Apache 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.apache.org/licenses/LICENSE-2.0
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.apache.commons.workflow.util;
18
19
20		import java.util.Map;
21		import org.apache.commons.workflow.Context;
22		import org.apache.commons.workflow.ContextEvent;
23		import org.apache.commons.workflow.ContextListener;
24		import org.apache.commons.workflow.Step;
25		import org.apache.commons.workflow.StepException;
26
27
28		/**
29		* <strong>ContextSupport</strong> is a convenience class for managing the
30		* firing of <code>ContextEvents</code> to registered
31		* <code>ContextListeners</code>.
32		*
33		* @version $Revision: 155475 $ $Date: 2005-02-26 13:31:11 +0000 (Sat, 26 Feb 2005) $
34		* @author Craig R. McClanahan
35		*/
36
37		public class ContextSupport {
38
39
40		// ----------------------------------------------------------- Constructors
41
42
43		/**
44		* Construct a new ContextSupport object associated with the
45		* specified Context.
46		*
47		* @param context Context for whom we will fire events
48		*/
49		public ContextSupport(Context context) {
50
51	0	super();
52	0	this.context = context;
53
54	0	}
55
56
57		// ----------------------------------------------------- Instance Variables
58
59
60		/**
61		* The set of registered <code>ContextListener</code> event listeners.
62		*/
63	0	protected ContextListener listeners[] = new ContextListener[0];
64
65
66		/**
67		* The <code>Context</code> for whom we will fire events.
68		*/
69	0	protected Context context = null;
70
71
72		// ------------------------------------------------- Event Listener Methods
73
74
75		/**
76		* Add a listener that is notified each time beans are added,
77		* replaced, or removed in this context.
78		*
79		* @param listener The ContextListener to be added
80		*/
81		public void addContextListener(ContextListener listener) {
82
83	0	synchronized (listeners) {
84	0	ContextListener results[] =
85		new ContextListener[listeners.length + 1];
86	0	System.arraycopy(listeners, 0, results, 0, listeners.length);
87	0	results[listeners.length] = listener;
88	0	listeners = results;
89	0	}
90
91	0	}
92
93
94		/**
95		* Remove a listener that is notified each time beans are added,
96		* replaced, or removed in this context.
97		*
98		* @param listener The ContextListener to be removed
99		*/
100		public void removeContextListener(ContextListener listener) {
101
102	0	synchronized (listeners) {
103	0	int n = -1;
104	0	for (int i = 0; i < listeners.length; i++) {
105	0	if (listeners[i] == listener) {
106	0	n = i;
107	0	break;
108		}
109		}
110	0	if (n < 0)
111	0	return;
112	0	ContextListener results[] =
113		new ContextListener[listeners.length - 1];
114	0	int j = 0;
115	0	for (int i = 0; i < listeners.length; i++) {
116	0	if (i != n)
117	0	results[j++] = listeners[i];
118		}
119	0	listeners = results;
120	0	}
121
122	0	}
123
124
125		// --------------------------------------------------- Event Firing Methods
126
127
128		/**
129		* Fire a <code>afterActivity</code> event to all registered listeners.
130		*
131		* @param step Step that was executed last
132		*/
133		public void fireAfterActivity(Step step) {
134
135	0	if (listeners.length == 0)
136	0	return;
137	0	ContextEvent event = new ContextEvent(context, step);
138	0	ContextListener interested[] = null;
139	0	synchronized (listeners) {
140	0	interested = (ContextListener[]) listeners.clone();
141	0	}
142	0	for (int i = 0; i < interested.length; i++)
143	0	interested[i].afterActivity(event);
144
145	0	}
146
147
148		/**
149		* Fire a <code>afterActivity</code> event to all registered listeners.
150		*
151		* @param step Step that was executed last
152		* @param exception StepException thrown by the last Step
153		*/
154		public void fireAfterActivity(Step step, StepException exception) {
155
156	0	if (listeners.length == 0)
157	0	return;
158	0	ContextEvent event = new ContextEvent(context, step, exception);
159	0	ContextListener interested[] = null;
160	0	synchronized (listeners) {
161	0	interested = (ContextListener[]) listeners.clone();
162	0	}
163	0	for (int i = 0; i < interested.length; i++)
164	0	interested[i].afterActivity(event);
165
166	0	}
167
168
169		/**
170		* Fire a <code>afterStep</code> event to all registered listeners.
171		*
172		* @param step Step that was executed
173		*/
174		public void fireAfterStep(Step step) {
175
176	0	if (listeners.length == 0)
177	0	return;
178	0	ContextEvent event = new ContextEvent(context, step);
179	0	ContextListener interested[] = null;
180	0	synchronized (listeners) {
181	0	interested = (ContextListener[]) listeners.clone();
182	0	}
183	0	for (int i = 0; i < interested.length; i++)
184	0	interested[i].afterStep(event);
185
186	0	}
187
188
189		/**
190		* Fire a <code>afterStep</code> event to all registered listeners.
191		*
192		* @param step Step that was executed
193		* @param exception StepException thrown by the executed step
194		*/
195		public void fireAfterStep(Step step, StepException exception) {
196
197	0	if (listeners.length == 0)
198	0	return;
199	0	ContextEvent event = new ContextEvent(context, step, exception);
200	0	ContextListener interested[] = null;
201	0	synchronized (listeners) {
202	0	interested = (ContextListener[]) listeners.clone();
203	0	}
204	0	for (int i = 0; i < interested.length; i++)
205	0	interested[i].afterStep(event);
206
207	0	}
208
209
210		/**
211		* Fire a <code>beforeActivity</code> event to all registered listeners.
212		*
213		* @param step Step that will be executed first
214		*/
215		public void fireBeforeActivity(Step step) {
216
217	0	if (listeners.length == 0)
218	0	return;
219	0	ContextEvent event = new ContextEvent(context, step);
220	0	ContextListener interested[] = null;
221	0	synchronized (listeners) {
222	0	interested = (ContextListener[]) listeners.clone();
223	0	}
224	0	for (int i = 0; i < interested.length; i++)
225	0	interested[i].beforeActivity(event);
226
227	0	}
228
229
230		/**
231		* Fire a <code>beforeStep</code> event to all registered listeners.
232		*
233		* @param step Step that is about to be executed
234		*/
235		public void fireBeforeStep(Step step) {
236
237	0	if (listeners.length == 0)
238	0	return;
239	0	ContextEvent event = new ContextEvent(context, step);
240	0	ContextListener interested[] = null;
241	0	synchronized (listeners) {
242	0	interested = (ContextListener[]) listeners.clone();
243	0	}
244	0	for (int i = 0; i < interested.length; i++)
245	0	interested[i].beforeStep(event);
246
247	0	}
248
249
250		}