OneForOneStreamManager

FIXME

registerStream Method

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