<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-web</artifactId>

</dependency>

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-artemis</artifactId>

</dependency>

spring.application.name=artemisMq

server.servlet.context-path=/artemisMq

server.port=9090

blue.mq.in=blueQueue

spring.artemis.broker-url=tcp://localhost:61616

spring.artemis.user=blue

#spring.artemis.mode=native

#spring.artemis.host=localhost

#spring.artemis.port=61616

#spring.artemis.password=blue

#spring.artemis.pool.enabled=true

#spring.artemis.pool.max-connections=50

#spring.artemis.embedded.enabled=false

@Log4j2

@Service

public class BlueQueueSender {

@Autowired

JmsTemplate jmsTemplate;

@Value("${blue.mq.in}")

String queueName;

public void sendMsg(String msg) throws Exception {

jmsTemplate.convertAndSend(queueName, msg);

log.info("Msg is sent to queue[" + queueName + "] successfully!");

}

}

@Log4j2

@Component

@EnableJms

public class BlueQueueListener {

@Autowired

BlueQueueSender msgService;

@JmsListener(destination = "${blue.mq.in}")

public void onMsg(Message msg) {

try {

Thread.sleep(1000);

String msgBody = msg.getBody(String.class);

System.out.println("******************************receive msg :"+msgBody);

if (StringUtils.isBlank(msgBody)) {

throw new Exception("Message body is empty!");

}

} catch (Exception ex) {

ex.printStackTrace();

}

}

}

@RestController

@SpringBootApplication

public class ArtemisMqApplication {

@Autowired

BlueQueueSender msgSvc;

public static void main(String[] args) {

SpringApplication.run(ArtemisMqApplication.class, args);

}

@PostMapping("/sendMsg")

public String sendMsg(@RequestBody String msg) throws Exception {

msgSvc.sendMsg(msg);

return "success";

}

}