yurake/k8s-3tier-webapp

package webapp.tier.service;

import java.util.logging.Level;
import java.util.logging.Logger;

import javax.enterprise.context.ApplicationScoped;
import javax.jms.JMSConsumer;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.TextMessage;

import org.eclipse.microprofile.config.inject.ConfigProperty;

import webapp.tier.bean.MsgBean;
import webapp.tier.service.socket.ActiveMqSocket;
import webapp.tier.util.MsgUtils;

@ApplicationScoped
public class ActiveMqConsumer {

    @ConfigProperty(name = "activemq.split.key")
    String splitkey;

    private final Logger logger = Logger.getLogger(this.getClass().getSimpleName());
    ActiveMqSocket amqsock = new ActiveMqSocket();

    public void consume(JMSConsumer consumer) throws JMSException {
        logger.log(Level.INFO, "Ready for receive message...");
        Message message = consumer.receive();
        TextMessage textMessage = (TextMessage) message;
        MsgBean msgbean = MsgUtils.splitBody(textMessage.getText(), splitkey);
        msgbean.setFullmsg("Received");
        logger.log(Level.INFO, msgbean.getFullmsg());
        amqsock.onMessage(MsgUtils.createBody(msgbean, splitkey));
        msgbean.setFullmsg("Broadcast");
        logger.log(Level.INFO, msgbean.getFullmsg());
    }
}