package uworkers.tests;

import trip.spi.Name;
import uworkers.api.Subscriber;
import uworkers.api.Worker;

public class Consumers {

	@Worker( "test.worker" )
	public void receiveWorker( SearchMessage message ) {
		System.out.println( message.query() );
	}

	@Name( "secret" )
	@Subscriber( "test.subscriber" )
	public void subscribeFor( SearchMessage message ) {
		System.out.println( message.query() );
	}
}

@@ -20,34 +20,9 @@
 sts;
-%0D%0A%0D%0Aimport trip.spi.Name;%0D
+%0A
 %0Aimp
@@ -49,17 +49,16 @@
 scriber;
-%0D
 %0Aimport 
@@ -77,19 +77,17 @@
 .Worker;
-%0D%0A%0D
+%0A
 %0Apublic 
@@ -103,19 +103,17 @@
 sumers %7B
-%0D%0A%0D
+%0A
 %0A%09@Worke
@@ -114,16 +114,23 @@
 @Worker(
+ name =
  %22test.w
@@ -133,25 +133,24 @@
 st.worker%22 )
-%0D
 %0A%09public voi
@@ -183,33 +183,32 @@
 sage message ) %7B
-%0D
 %0A%09%09System.out.pr
@@ -236,35 +236,12 @@
 ) );
-%0D
 %0A%09%7D
-%0D%0A%0D%0A%09@Name( %22secret%22 )%0D
+%0A
 %0A%09@S
@@ -250,16 +250,24 @@
 scriber(
+ topic =
  %22test.s
@@ -280,11 +280,26 @@
 ber%22
- )%0D
+, name = %22secret%22)
 %0A%09pu
@@ -347,17 +347,16 @@
 sage ) %7B
-%0D
 %0A%09%09Syste
@@ -392,13 +392,10 @@
 ) );
-%0D
 %0A%09%7D
-%0D
 %0A%7D
-%0D
 %0A

Change test consumers.