Like that:
def receive: Receive = {
case fullMsg @ Begin(msg, expectedReply, signalSuccessWith, replyTo, receiver, pause) => {
receiver ! msg
val cancelHandle = context.system.scheduler.schedule(pause, pause, context.self, Retry)
context.become(runtime(fullMsg, cancelHandle))
}
case _ =>
}