Diffa Diffa

This (as yet unexplained) NPE seems to pop up in some itests:

Running net.lshift.diffa.agent.itest.events.ExampleEventFormatMapperIntegrationTest
15:20:40.931 [qtp1405988211-199] INFO JsonAmqpMessagingRegistrar:57 - Starting consumer for endpoint: Endpoint(upstream,null,null,null,application/json,amqp://localhost//queues/exampleChanges,application/example+json,{bizDate=RangeCategoryDescriptor{dataType='datetime', lower='null', upper='null'}})
15:20:41.022 [qtp1405988211-199] INFO PairActorSupervisor:64 - Started actor for key: pair
15:20:45.408 [akka:event-driven:dispatcher:global-25] WARN PairActor:397 - Upstream scan on pair pair-9d9d0370-aeed-11e0-87bf-0022192d0d03 was cancelled
[ERROR]   [7/15/11 3:20 PM] [akka:event-driven:dispatcher:global-25] [LocalActorRef] Spawn
java.lang.NullPointerException
    at net.lshift.diffa.kernel.actors.PairActor$$anonfun$handleScanMessage$1.apply$mcV$sp(PairActor.scala:398)
    at akka.actor.Actor$$anon$1$$anonfun$receive$1.apply(Actor.scala:232)
    at akka.actor.Actor$$anon$1$$anonfun$receive$1.apply(Actor.scala:231)
    at akka.actor.Actor$class.apply(Actor.scala:476)
    at akka.actor.Actor$$anon$1.apply(Actor.scala:229)
    at akka.actor.LocalActorRef.invoke(ActorRef.scala:861)
    at akka.dispatch.MessageInvocation.invoke(MessageHandling.scala:26)
    at akka.dispatch.ExecutableMailbox$class.processMailbox(ExecutorBasedEventDrivenDispatcher.scala:209)
    at akka.dispatch.ExecutorBasedEventDrivenDispatcher$$anon$4.processMailbox(ExecutorBasedEventDrivenDispatcher.scala:120)
    at akka.dispatch.ExecutableMailbox$class.run(ExecutorBasedEventDrivenDispatcher.scala:182)
    at akka.dispatch.ExecutorBasedEventDrivenDispatcher$$anon$4.run(ExecutorBasedEventDrivenDispatcher.scala:120)
    at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
    at java.lang.Thread.run(Thread.java:662)
    at akka.dispatch.MonitorableThread.run(ThreadPoolBuilder.scala:182)

[ERROR]   [7/15/11 3:20 PM] [akka:event-driven:dispatcher:global-25] [LocalActorRef] Spawn
java.lang.NullPointerException
    at akka.dispatch.ExecutorBasedEventDrivenDispatcher.suspend(ExecutorBasedEventDrivenDispatcher.scala:163)
    at akka.actor.LocalActorRef.handleExceptionInDispatch(ActorRef.scala:1039)
    at akka.actor.LocalActorRef.invoke(ActorRef.scala:867)
    at akka.dispatch.MessageInvocation.invoke(MessageHandling.scala:26)
    at akka.dispatch.ExecutableMailbox$class.processMailbox(ExecutorBasedEventDrivenDispatcher.scala:209)
    at akka.dispatch.ExecutorBasedEventDrivenDispatcher$$anon$4.processMailbox(ExecutorBasedEventDrivenDispatcher.scala:120)
    at akka.dispatch.ExecutableMailbox$class.run(ExecutorBasedEventDrivenDispatcher.scala:182)
    at akka.dispatch.ExecutorBasedEventDrivenDispatcher$$anon$4.run(ExecutorBasedEventDrivenDispatcher.scala:120)
    at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
    at java.lang.Thread.run(Thread.java:662)
    at akka.dispatch.MonitorableThread.run(ThreadPoolBuilder.scala:182)