Context Navigation

Changeset 307 for kraken-filter

Timestamp:

06/15/09 00:22:04 (14 months ago)

Author:

xeraph

Message:

Added missing event callback notifications.

Location:

kraken-filter/src/main/java/org/krakenapps/filter

Files:

r306	r307
43	43
44	44	/**
45		* Initialize ~~an active filter instance. ActiveFilterRunner calls this~~
46		* ~~method before the run loop~~.
	45	* Initialize callback. ActiveFilterRunner calls this method before the run
	46	* loop. Override this.
47	47	*
48	48	* @throws ConfigurationException
…	…
53	53
54	54	/**
55		* Finalize ~~an active filter instance. ActiveFilterRunner calls this method~~
56		* ~~after the run loop~~.
	55	* Finalize callback. ActiveFilterRunner calls this method after the run
	56	* loop. Override this.
57	57	*/
58	58	public void close() {
…	…
60	60
61	61	/**
62		* ActiveFilterRunner calls this ~~method in each loop. Thread will sleep some~~
63		* milliseconds after run.
	62	* ActiveFilterRunner calls this callback in each loop. Thread will sleep
	63	* some milliseconds after run.
64	64	*
65	65	* @throws InterruptedException

r306	r307
40	40
41	41	/**
42		* No input message specifications are supported.
	42	* No input message specifications are supported by default. Override this.
43	43	*/
44	44	@Override
…	…
48	48
49	49	/**
50		* No output message specification is supported.
	50	* No output message specification is supported by default. Override this.
51	51	*/
52	52	@Override
…	…
56	56
57	57	/**
58		* Empty message processing.
	58	* Empty message processing by default. Override this.
59	59	*/
60	60	@Override
…	…
79	79
80	80	/**
81		*
	81	* Sets a property.
82	82	*/
83	83	@Override
…	…
86	86	}
87	87
	88	/**
	89	* Removes the property.
	90	*/
88	91	@Override
89	92	public void unsetProperty(String key) {
…	…
91	94	}
92	95
	96	/**
	97	* Validates current configuration. No check by default. Override this.
	98	*/
93	99	@Override
94	100	public void validateConfiguration() throws ConfigurationException {

r306	r307
24	24	public interface FilterEventListener {
25	25	/**
26		* Invoked when a filter is loaded.
	26	* Invoked synchronously when a filter is loaded.
27	27	*/
28	28	void onFilterLoaded(String filterId);
29	29
30	30	/**
31		* Invoked when a filter is unloading.
	31	* Invoked synchronously when a filter is unloading.
32	32	*/
33	33	void onFilterUnloading(String filterId);
34	34
35	35	/**
36		* Invoked when filters are bound.
	36	* Invoked synchronously when filters are bound.
37	37	*
38	38	* @param fromFilterId
…	…
44	44
45	45	/**
46		* Invoked when filters are unbounding.
	46	* Invoked synchronously when filters are unbounding.
47	47	*
48	48	* @param fromFilterId
…	…
54	54
55	55	/**
56		* Invoked when a property is set.
	56	* Invoked synchronously when a property is set.
57	57	*
58	58	* @param filterId
…	…
66	66
67	67	/**
68		* Invoked when a property is removed.
	68	* Invoked synchronously when a property is removed.
69	69	*
70	70	* @param filterId

r306	r307
414	414	FilterHandler handler = handlerMap.get(fromFilterId);
415	415	handler.stateChanged(convertToArray(bindedFilters));
	416
	417	// notify event handlers
	418	for (FilterEventListener listener : listeners) {
	419	listener.onFilterBound(fromFilterId, toFilterId);
	420	}
416	421	}
417	422	}
…	…
440	445	// validation
441	446	Filter toFilter = getFilterInstance(toFilterId);
	447
	448	// notify event handlers
	449	for (FilterEventListener listener : listeners) {
	450	listener.onFilterUnbinding(fromFilterId, toFilterId);
	451	}
442	452
443	453	// unbind it.
…	…
526	536	throw new FilterNotFoundException(filterId);
527	537	}
	538
	539	// notify event handlers
	540	for (FilterEventListener listener : listeners) {
	541	listener.onFilterSet(filterId, key, value);
	542	}
528	543	}
529	544	}
…	…
541	556	} else {
542	557	throw new FilterNotFoundException(filterId);
	558	}
	559
	560	// notify event handlers
	561	for (FilterEventListener listener : listeners) {
	562	listener.onFilterUnset(filterId, key);
543	563	}
544	564	}