<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>com.ericsson.otp</groupId>
<artifactId>otp-java</artifactId>
<version>1.1.5</version>
</dependency>
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
spring.rabbitmq.virtual-host=/
@ErlangListener(queues = "myQueue")
public class MyErlangListener {
@RabbitHandler
public void processMessage(byte[] message) {
String msg = new String(message);
System.out.println("Received message: " + msg);
}
}
@Service
public class MyMessageSender {
private final RabbitTemplate rabbitTemplate;
public MyMessageSender(RabbitTemplate rabbitTemplate) {
this.rabbitTemplate = rabbitTemplate;
}
public void sendMessage(String message) {
byte[] bytes = message.getBytes();
rabbitTemplate.convertAndSend("myExchange", "myRoutingKey", bytes);
}
}
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
spring.rabbitmq.virtual-host=/
erlang.connection.host=localhost
erlang.connection.port=5672
erlang.connection.username=guest
erlang.connection.password=guest
@SpringBootApplication
@EnableErlangListeners
public class MyApplication {
public static void main(String[] args) {
SpringApplication.run(MyApplication.class, args);
}
}
@ErlangListener(queues = "myQueue")
public class MyErlangListener {
@RabbitHandler
public void processMessage(byte[] message) {
String msg = new String(message);
System.out.println("Received message: " + msg);
}
}
@Service
public class MyMessageSender {
private final RabbitTemplate rabbitTemplate;
public MyMessageSender(RabbitTemplate rabbitTemplate) {
this.rabbitTemplate = rabbitTemplate;
}
public void sendMessage(String message) {
byte[] bytes = message.getBytes();
rabbitTemplate.convertAndSend("myExchange", "myRoutingKey", bytes);
}
}
