package com.manager.controller;

import com.manager.jms.ConsumerService;
import com.manager.jms.ProducerService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;

import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.TextMessage;

/**
 * Created by static on 2017/4/10.
 */
@Controller
@RequestMapping("/jms")
public class JmsController {

    @Autowired
    private ProducerService producerService;
    @Autowired
    private ConsumerService consumerService;
    @Autowired
    private Destination queueDestination;



    @RequestMapping(value = "/sendJmsMsg" , method = RequestMethod.POST)
    public String sendJmsMsg(String msg){
        producerService.sendMessage(queueDestination,msg);
        return "person";
    }

    @RequestMapping(value = "getJmsMsg" , method = RequestMethod.GET)
    public String getJmsMsg(Model model) throws JMSException {
        TextMessage textMessage = consumerService.receive(queueDestination);
        model.addAttribute("msg",textMessage.getText());
        return "person";
    }
}