Asynchronous Programming in Grails 3

Grails has had support for asynchronous programming for some time now but it seems to have become more well-defined in Grails 3. It has Promises, Events, and even asynchronous processing in GORM. The article is focusing on some functionality in Event processing, most of the functionality coming from Reactor.

You can see my simple example on Github. It’s pretty straightforward on how it works — you enter a number into a form, and then check the server output for counting from 1 to that number. The numbers won’t be in order though — that is because a service is sending them to another service in an asynchronous manner.

The LoopService is really what starts this off — it gets a number and starts the loop:

Note that it doesn’t call another service directly — instead it calls this magic notify method that takes a string and the value. This is because services in Grails 3 have the Event trait which give you an interface into Reactor. The string is the name of the event to fire and the second parameter is the Object to send to the consumer of the event. Notice that I said Object… I first used type int to make this example and it took me awhile to figure out why I had a NullPointerExeception. Simply moving it to Integer made it start working.

The consumer of this event is the EchoNumberService.

The Consumer and Selector annotations come from Reactor. Consumer simply signifies that this class consumes events and Selector lets you give the name of the event that method consumes. Note that the echo method consumes the int.echo event we used above. I think the other important thing to note is that there is nothing else do to! There is nothing in the method itself that signifies that it’s running in an asynchronous matter. And you could use the same method in a synchronous scenario if need be by calling the method directly.

About the Author

Object Partners profile.

One thought on “Asynchronous Programming in Grails 3

  1. Bruno says:

    Very nice post Mike! I recently started using asynchronous programming, and I have a doubt. What is the best (or most viable) way to test those situations when one service emit an event, and one or more services ?


Leave a Reply to Bruno Cancel reply

Your email address will not be published.

Related Blog Posts
Kafka Schema Evolution With Java Spring Boot and Protobuf
In this blog I will be demonstrating Kafka schema evolution with Java, Spring Boot and Protobuf.  This app is for tutorial purposes, so there will be instances where a refactor could happen. I tried to […]
Redis Bitmaps: Storing state in small places
Redis is a popular open source in-memory data store that supports all kinds of abstract data structures. In this post and in an accompanying example Java project, I am going to explore two great use […]
Let’s build a WordPress & Kernel updated AMI with Packer
First, let’s start with What is an AMI? An Amazon Machine Image (AMI) is a master image for the creation of virtual servers in an AWS environment. The machine images are like templates that are configured with […]
Single Node Kubernetes on Raspberry Pi 4
In this post, I will go through the steps I used to create a single node Kubernetes combination master and worker node on a Raspberry Pi 4. The heavy lifting in this post is done […]