public interface MessageReceiver<T>
T
poll()
take()
T take() throws InterruptedException
InterruptedException
T poll()
Copyright © 2011-2012. All Rights Reserved.