<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"); } }


上一篇:
下一篇:
切换中文