import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.when;
+
import com.google.common.util.concurrent.SettableFuture;
import io.netty.util.concurrent.Future;
import java.util.concurrent.ExecutionException;
import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
/**
- * @author michal.polkorab
+ * UNit tests for SimpleRpcListener.
*
+ * @author michal.polkorab
*/
public class SimpleRpcListenerTest {
@Mock Future<Void> future;
/**
- * Initializes mocks
+ * Initializes mocks.
*/
@Before
public void startUp() {
}
/**
- * Test SimpleRpcListener creation
+ * Test SimpleRpcListener creation.
*/
@Test
public void test() {
}
/**
- * Test rpc success
+ * Test rpc success.
*/
@Test
public void testSuccessfulRpc() {
- SimpleRpcListener listener = new SimpleRpcListener("MESSAGE", "Failed to send message");
+ SimpleRpcListener<?> listener = new SimpleRpcListener("MESSAGE", "Failed to send message");
listener.operationSuccessful();
SettableFuture<RpcResult<?>> result = SettableFuture.create();
result.set(RpcResultBuilder.success((Void)null).build());
}
/**
- * Test rpc success
+ * Test rpc success.
*/
@Test
public void testOperationComplete() {
when(future.isSuccess()).thenReturn(false);
- SimpleRpcListener listener = new SimpleRpcListener("MESSAGE", "Failed to send message");
+ SimpleRpcListener<?> listener = new SimpleRpcListener("MESSAGE", "Failed to send message");
listener.operationComplete(future);
verify(future, times(1)).cause();
try {
}
/**
- * Test rpc success
+ * Test rpc success.
*/
@Test
public void testOperationComplete2() {
when(future.isSuccess()).thenReturn(true);
- SimpleRpcListener listener = new SimpleRpcListener("MESSAGE", "Failed to send message");
+ SimpleRpcListener<?> listener = new SimpleRpcListener("MESSAGE", "Failed to send message");
listener.operationComplete(future);
verify(future, times(0)).cause();
try {
Assert.fail();
}
}
-}
\ No newline at end of file
+}