Skip to content

tongyy/ibm-mq-spring-boot-jms

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

11 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

ibm-mq-spring-boot-jms

This project is used for hands-on workshop.

These demos are written with SPRING BOOT and JMS.

You will learn easily about "SPRINGBOOT,JMS,MQAPI,QUEUE,TOPIC,SENDER,RECEIVER,LISTENER" in my project.

IBM Websphere MQ Server in a Docker container

Just two commands.

docker run --name mq75 --publish 1415:1415 -idt tony0x00/trial-mq75:v1.0 /bin/bash docker exec mq75 strmqm ONE.QM

Message Driven POJO, MessageListener Application

It be configured by Application.yml to set queue and topic destination.

servers: mq: host: 127.0.0.1 port: 1415 queue-manager: ONE.QM channel: ONE.SVR.CONN queue: ONE.QUEUE topic: ONE/TOPIC timeout: 2000

Run as Java Application, then you will start to listen ONE.QUEUE and ONE/TOPIC.

@SpringBootApplication @EnableScheduling public class Application { public static void main(String[] args) { SpringApplication.run(Application.class, args);	} }

Run the QueueAndTopicTest and design your scenario.

@Test public void sendMessageToQueue() { queueTemplate.convertAndSend(queue, "hello world"); } @Test public void receiveMessageFromQueue() { queueTemplate.receiveAndConvert(queue); } @Test public void sendMessageToQueueWithSelector() { queueTemplate.convertAndSend(queue, "hello world",	(MessagePostProcessor)(message)-> {	{ message.setStringProperty("name", "tony"); return message;	}	}); } @Test public void receiveMessageFromQueueWithSelector() { queueTemplate.receiveSelected(queue, "name='tony'"); } @Test public void publishMessageToTopic() { topicTemplate.convertAndSend(topic, "hello world"); } 

About

Hands-on workshop for websphere MQ programming

Topics

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published