Project

General

Profile

« Previous | Next » 

Revision 7419

To attempt to address performance and stability WRT Hazelcast communication, we're upgrading to the 2.x series of Hazelcast. remove the 1.9.x jar files, and add the 2.4.1-SNAPSHOT jars. Modify HazelcastService to handle the minor change in the ItemListener interface (now passes ItemEvent<Identifier> as an argument).

Many methods have been deprecated from the Hazelcast class, including init(), and so those changes will be addressed next, but this commit compiles while still using the deprecated calls.

View differences:

src/edu/ucsb/nceas/metacat/dataone/hazelcast/HazelcastService.java
52 52
import com.hazelcast.core.ILock;
53 53
import com.hazelcast.core.IMap;
54 54
import com.hazelcast.core.ISet;
55
import com.hazelcast.core.ItemEvent;
55 56
import com.hazelcast.core.ItemListener;
56 57
import com.hazelcast.core.LifecycleEvent;
57 58
import com.hazelcast.core.LifecycleListener;
......
664 665
	 * @param pid   the identifier of the event
665 666
	 */
666 667
	@Override
667
	public void itemAdded(Identifier pid) {
668
	public void itemAdded(ItemEvent<Identifier> event) {
669
		
670
		Identifier pid = (Identifier) event.getItem();
668 671
		// publish the SM for the pid if we have it locally
669 672
		logMetacat.debug("Responding to itemAdded for pid: " + pid.getValue());
670 673
		
......
706 709
   * @param pid   the identifier of the event
707 710
   */
708 711
	@Override
709
	public void itemRemoved(Identifier pid) {
712
	public void itemRemoved(ItemEvent<Identifier> event) {
710 713
		// do nothing since someone probably handled the wanted PID
711 714
		
712 715
	}

Also available in: Unified diff