public class DemoApp {
	public static void main(String[] _) throws Exception {
		JobService celeryService = new CeleryService();
      		celeryService.setInvokeHandler( new TaskHandler<InvokeJob>()
      		{
      			@Override
      			public void handle( InvokeJob t ) throws IOException
      			{
      				switch( t.getMethod() )
      				{
      					case "tasks.add":
      						t.complete( Job.Status.SUCCESS, add( t ) );
      				}
      			}
      		} );

      		celeryService.setRevokeHandler( new TaskHandler<InvokeJob>()
      		{
      			@Override
      			public void handle( InvokeJob t ) throws IOException
      			{
      				switch( t.getMethod() )
      				{
      					case "revoke":
      						t.complete( Job.Status.REVOKED );
      				}
      			}
      		} );

      		celeryService.startService();

		// ...
	}

	private static long add(CeleryTask t) {
		long x = (long) t.args.get(0);
		long y = (long) t.args.get(1);
		return x + y;
	}
}