Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
0.5.0
-
None
Description
TCPEmitter is registering itself as a listener in its constructor: this.topology.addListener(this);
The topology is triggering a refresh before the TCPEmitter is fully constructed, so TCPEmitter.partitionNodeMap is still null during onChange() execution.
TCPEmitter shouldn't register itself as a listener until it's fully built, see http://www.ibm.com/developerworks/java/library/j-jtp0618/index.html#2 (Don't publish the "this" reference during construction)