Revision 7419
Added by Chris Jones about 12 years ago
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
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.