代码格式调整

src/main/java/osc/git/eh3/springamq/mq/producer/queue/QueueSender.java

@@ -11,10 +11,7 @@ import javax.jms.Message;
 import javax.jms.Session;
 
 /**
- * 
- * @author liang
  * @description  队列消息生产者，发送消息到队列
- * 
  */
 @Component("queueSender")
 public class QueueSender {
@@ -36,5 +33,4 @@ public class QueueSender {
 			}
 		});
 	}
-	
+}
-}

src/main/java/osc/git/eh3/springamq/mq/producer/topic/TopicSender.java

@@ -11,31 +11,28 @@ import javax.jms.Message;
 import javax.jms.Session;
 
 /**
- * 
+ * @description Topic生产者发送消息到Topic
- * @author liang
- * @description   Topic生产者发送消息到Topic
- * 
  */
 
 @Component("topicSender")
 public class TopicSender {
-	
-	@Autowired
-	@Qualifier("jmsTopicTemplate")
-	private JmsTemplate jmsTemplate;
-	
-	/**
-	 * 发送一条消息到指定的队列（目标）
-	 * @param topicName 队列名称
-	 * @param message 消息内容
-	 */
-	public void send(String topicName,final String message){
-		jmsTemplate.send(topicName, new MessageCreator() {
-			@Override
-			public Message createMessage(Session session) throws JMSException {
-				return session.createTextMessage(message);
-			}
-		});
-	}
 
-}
+    @Autowired
+    @Qualifier("jmsTopicTemplate")
+    private JmsTemplate jmsTemplate;
+
+    /**
+     * 发送一条消息到指定的队列（目标）
+     *
+     * @param topicName 队列名称
+     * @param message   消息内容
+     */
+    public void send(String topicName, final String message) {
+        jmsTemplate.send(topicName, new MessageCreator() {
+            @Override
+            public Message createMessage(Session session) throws JMSException {
+                return session.createTextMessage(message);
+            }
+        });
+    }
+}