ps.setStartSeqno(DcpDeletionMessage.revisionSeqno(event));
<BUG>sessionState.set(partition, ps);
</BUG>
} else if (DcpExpirationMessage.is(event)) {
short partition = DcpExpirationMessage.partition(event);
<BUG>PartitionState ps = sessionState.get(partition);
</BUG>
ps.setStartSeqno(DcpExpirationMessage.revisionSeqno(event));
<BUG>sessionState.set(partition, ps);
</BUG>
}

ps.setStartSeqno(DcpDeletionMessage.revisionSeqno(event));
sessionState().set(partition, ps);
} else if (DcpExpirationMessage.is(event)) {
short partition = DcpExpirationMessage.partition(event);
PartitionState ps = sessionState().get(partition);
ps.setStartSeqno(DcpExpirationMessage.revisionSeqno(event));
sessionState().set(partition, ps);
}
