<dependency>
<groupId>org.springframework.erlang</groupId>
<artifactId>spring-erlang</artifactId>
<version>1.0.0</version>
</dependency>
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.erlang.core.ErlangTemplate;
import org.springframework.stereotype.Component;
@Component
public class MessageSender {
private final ErlangTemplate erlangTemplate;
@Autowired
public MessageSender(ErlangTemplate erlangTemplate) {
this.erlangTemplate = erlangTemplate;
}
public void sendMessage(String message) {
erlangTemplate.send("remoteNode", "myQueue", message);
}
}
@Component
public class MessageReceiver {
private final ErlangTemplate erlangTemplate;
@Autowired
public MessageReceiver(ErlangTemplate erlangTemplate) {
this.erlangTemplate = erlangTemplate;
}
public String receiveMessage() {
return erlangTemplate.receive("myQueue");
}
}