From 0131ed198c179aa50143ce630ec85ff519f80153 Mon Sep 17 00:00:00 2001 From: jiangjiazhi Date: Thu, 8 Jun 2017 10:25:59 +0800 Subject: [PATCH] commit --- .../web/jms/producer/SimpleMessageProducer.java | 72 ---------------------- .../web/jms/receiver/SimpleMessageReceiver.java | 46 -------------- .../main/resources/spring/consumer-jms-context.xml | 25 -------- .../main/resources/spring/producer-jms-context.xml | 24 -------- 4 files changed, 167 deletions(-) delete mode 100644 platform-operate-api/src/main/java/com/lyms/platform/operate/web/jms/producer/SimpleMessageProducer.java delete mode 100644 platform-operate-api/src/main/java/com/lyms/platform/operate/web/jms/receiver/SimpleMessageReceiver.java delete mode 100644 platform-operate-api/src/main/resources/spring/consumer-jms-context.xml delete mode 100644 platform-operate-api/src/main/resources/spring/producer-jms-context.xml diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/jms/producer/SimpleMessageProducer.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/jms/producer/SimpleMessageProducer.java deleted file mode 100644 index 83229b8..0000000 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/jms/producer/SimpleMessageProducer.java +++ /dev/null @@ -1,72 +0,0 @@ -package com.lyms.platform.operate.web.jms.producer; - -import java.util.Date; - -import javax.jms.JMSException; -import javax.jms.Message; -import javax.jms.Session; -import javax.jms.TextMessage; - -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; -import org.springframework.jms.core.JmsTemplate; -import org.springframework.jms.core.MessageCreator; - -public class SimpleMessageProducer { - - private static final Logger LOG = LoggerFactory.getLogger(SimpleMessageProducer.class); - - protected JmsTemplate jmsTemplate; - - protected int numberOfMessages = 100; - - public void setNumberOfMessages(int numberOfMessages) { - this.numberOfMessages = numberOfMessages; - } - - public JmsTemplate getJmsTemplate() { - return jmsTemplate; - } - - public void setJmsTemplate(JmsTemplate jmsTemplate) { - this.jmsTemplate = jmsTemplate; - } - - public void sendMessages(String sendType) throws JMSException { - if ("jmsSend".equalsIgnoreCase(sendType)) { - jmsSendMessages(); - } else if ("convertAndSend".equalsIgnoreCase(sendType)) { - convertAndSendMessages(); - } - } - - public void convertAndSendMessages() throws JMSException { - final StringBuilder buffer = new StringBuilder(); - - for (int i = 0; i < numberOfMessages; ++i) { - buffer.append("Message '").append(i).append("' sent at: ").append(new Date()); - jmsTemplate.convertAndSend(buffer.toString()); - } - } - - public void jmsSendMessages() throws JMSException { - final StringBuilder buffer = new StringBuilder(); - - for (int i = 0; i < numberOfMessages; ++i) { - buffer.append("Message '").append(i).append("' sent at: ").append(new Date()); - - final int count = i; - final String payload = buffer.toString(); - - jmsTemplate.send(new MessageCreator() { - public Message createMessage(Session session) throws JMSException { - TextMessage message = session.createTextMessage(payload); - message.setIntProperty("messageCount", count); - LOG.info("Sending message number '{}'", count); - return message; - } - }); - } - } - -} diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/jms/receiver/SimpleMessageReceiver.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/jms/receiver/SimpleMessageReceiver.java deleted file mode 100644 index 864d39b..0000000 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/jms/receiver/SimpleMessageReceiver.java +++ /dev/null @@ -1,46 +0,0 @@ -package com.lyms.platform.operate.web.jms.receiver; - -import javax.jms.Message; -import javax.jms.MessageListener; - -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; -import org.springframework.jms.core.JmsTemplate; - -public class SimpleMessageReceiver implements MessageListener { - - private static final Logger LOG = LoggerFactory.getLogger(SimpleMessageReceiver.class); - - protected JmsTemplate jmsTemplate; - - public JmsTemplate getJmsTemplate() { - return jmsTemplate; - } - - public void setJmsTemplate(JmsTemplate jmsTemplate) { - this.jmsTemplate = jmsTemplate; - } - - public void receive(String receiveType) { - if ("jmsReceive".equalsIgnoreCase(receiveType)) { - jmsReceive(); - } else if ("receiveAndConvert".equalsIgnoreCase(receiveType)) { - receiveAndConvert(); - } - } - - public void jmsReceive() { - Message message = jmsTemplate.receive(); - LOG.debug("Received a JMS message: {}", message); - } - - public void receiveAndConvert() { - String message = (String) jmsTemplate.receiveAndConvert(); - LOG.debug("Received a text message: {}", message); - } - - @Override - public void onMessage(Message message) { - - } -} diff --git a/platform-operate-api/src/main/resources/spring/consumer-jms-context.xml b/platform-operate-api/src/main/resources/spring/consumer-jms-context.xml deleted file mode 100644 index 31f986e..0000000 --- a/platform-operate-api/src/main/resources/spring/consumer-jms-context.xml +++ /dev/null @@ -1,25 +0,0 @@ - - - - - - - - - - - - - - diff --git a/platform-operate-api/src/main/resources/spring/producer-jms-context.xml b/platform-operate-api/src/main/resources/spring/producer-jms-context.xml deleted file mode 100644 index ce588ae..0000000 --- a/platform-operate-api/src/main/resources/spring/producer-jms-context.xml +++ /dev/null @@ -1,24 +0,0 @@ - - - - - - - - - - - - - - -- 1.8.3.1