OneForOneStreamManager Caution FIXME registerStream Method long registerStream(String appId, Iterator<ManagedBuffer> buffers) Caution FIXME