raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Migrated test to new API

Browse source
This commit is contained in:
Viktor Klang 2010-08-16 10:53:02 +02:00
parent b0a31bb683
commit 871e0799f0
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-camel/src/test/scala/ConsumerRegisteredTest.scala
View file

@ -26,19 +26,19 @@ class ConsumerRegisteredTest extends JUnitSuite {
}
@Test def shouldCreateSomeNonBlockingPublishRequestFromUntypedConsumer = {
val uc = UntypedActor.actorOf(classOf[SampleUntypedConsumer]).actorRef
val uc = UntypedActor.actorOf(classOf[SampleUntypedConsumer])
val event = ConsumerRegistered.forConsumer(uc)
assert(event === Some(ConsumerRegistered(uc, "direct:test-untyped-consumer", uc.uuid, false)))
}
@Test def shouldCreateSomeBlockingPublishRequestFromUntypedConsumer = {
val uc = UntypedActor.actorOf(classOf[SampleUntypedConsumerBlocking]).actorRef
val uc = UntypedActor.actorOf(classOf[SampleUntypedConsumerBlocking])
val event = ConsumerRegistered.forConsumer(uc)
assert(event === Some(ConsumerRegistered(uc, "direct:test-untyped-consumer-blocking", uc.uuid, true)))
}
@Test def shouldCreateNoneFromUntypedConsumer = {
val a = UntypedActor.actorOf(classOf[SampleUntypedActor]).actorRef
val a = UntypedActor.actorOf(classOf[SampleUntypedActor])
val event = ConsumerRegistered.forConsumer(a)
assert(event === None)
}