@Test
public void integrationTest() throws Exception{
+ // System.setProperty("shard.persistent", "true");
// This test will
// - create a Shard
// - initiate a transaction
final ActorRef transactionActorRef = watchActor(transaction);
transaction.tell(new WriteData(TestModel.TEST_PATH,
- ImmutableNodes.containerNode(TestModel.TEST_QNAME), TestModel.createTestContext()),
+ ImmutableNodes.containerNode(TestModel.TEST_QNAME), TestModel.createTestContext()).toSerializable(),
getRef());
Boolean writeDone = new ExpectMsg<Boolean>("WriteDataReply") {