Test a get that queries by family string and qualifier string @throws Exception
()
| 134 | * @throws Exception |
| 135 | */ |
| 136 | @Test |
| 137 | public void getWithQualifierString() throws Exception { |
| 138 | final GetRequest get = new GetRequest(new String(TABLE), new String(KEY), |
| 139 | new String(FAMILY), new String(QUALIFIER)); |
| 140 | final ArrayList<KeyValue> row = new ArrayList<KeyValue>(1); |
| 141 | row.add(KV); |
| 142 | when(regionclient.isAlive()).thenReturn(true); |
| 143 | doAnswer(new Answer<Object>() { |
| 144 | public Object answer(final InvocationOnMock invocation) { |
| 145 | get.getDeferred().callback(row); |
| 146 | return null; |
| 147 | } |
| 148 | }).when(regionclient).sendRpc(get); |
| 149 | assertSame(row, client.get(get).joinUninterruptibly()); |
| 150 | } |
| 151 | |
| 152 | } |