@Test
public void exceptionThrownIfCannotFindNewOriginator() throws TbNodeException {

    init();
    AssetId assetId = new AssetId(UUIDs.timeBased());
    CustomerId customerId = new CustomerId(UUIDs.timeBased());
    Asset asset = new Asset();
    asset.setCustomerId(customerId);
    RuleChainId ruleChainId = new RuleChainId(UUIDs.timeBased());
    RuleNodeId ruleNodeId = new RuleNodeId(UUIDs.timeBased());
    TbMsg msg = new TbMsg(UUIDs.timeBased(), "ASSET", assetId, new TbMsgMetaData(), "{}", ruleChainId, ruleNodeId, 0L);
    when(ctx.getAssetService()).thenReturn(assetService);
    when(assetService.findAssetByIdAsync(assetId)).thenReturn(Futures.immediateFuture(null));
    node.onMsg(ctx, msg);
    verify(ctx).tellNext(same(msg), same(FAILURE));
}