+ @SuppressWarnings("unchecked")
+ @Test
+ public void testSendSliceableMessageRequest() {
+ final ClientActorConfig config = AccessClientUtil.newMockClientActorConfig();
+ doReturn(5).when(config).getMaximumMessageSliceSize();
+ context = new ClientActorContext(contextProbe.ref(), PERSISTENCE_ID, system, CLIENT_ID, config);
+ connection = createConnection();
+
+ final Consumer<Response<?, ?>> callback = mock(Consumer.class);
+
+ final TransactionIdentifier identifier =
+ new TransactionIdentifier(new LocalHistoryIdentifier(CLIENT_ID, 0L), 0L);
+ ModifyTransactionRequestBuilder reqBuilder =
+ new ModifyTransactionRequestBuilder(identifier, replyToProbe.ref());
+ reqBuilder.addModification(new TransactionWrite(YangInstanceIdentifier.EMPTY, Builders.containerBuilder()
+ .withNodeIdentifier(YangInstanceIdentifier.NodeIdentifier.create(
+ QName.create("namespace", "localName"))).build()));
+ reqBuilder.setSequence(0L);
+ final Request<?, ?> request = reqBuilder.build();
+ connection.sendRequest(request, callback);
+
+ backendProbe.expectMsgClass(MessageSlice.class);
+ }
+}