expectMsgClass(Messages.EventWrapper.class);
}
@Test
public void testNoImcompleteIfSentAllOnFristSubscribe() throws Exception {
for(int i = 0; i<3;i++)
<BUG>mongodbJournal.saveEvent(new AggEvent("agg"));
TestActorRef<Actor> actorTestActorRef = TestActorRef.create(_system, EventStore.mkProps(mongodbJournal));
actorTestActorRef.tell(new Subscription("agg",null),super.testActor());
for(int i = 0; i<3;i++)
expectMsgClass(AggEvent.class);

expectMsgClass(CompleteSubscriptionRegistered.class);
</BUG>
}

expectMsgClass(Messages.EventWrapper.class);
expectMsgClass(Messages.IncompleteSubscriptionPleaseSendNew.class);
actorTestActorRef.tell(Messages.Subscription.newBuilder().setAggregateType("agg").setFromJournalId(9).build(),super.testActor());
expectMsgClass(Messages.EventWrapper.class);
}
