/*
|
* JBoss, Home of Professional Open Source
|
* Copyright 2015, Red Hat, Inc. and/or its affiliates, and individual
|
* contributors by the @authors tag. See the copyright.txt in the
|
* distribution for a full listing of individual contributors.
|
*
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
* you may not use this file except in compliance with the License.
|
* You may obtain a copy of the License at
|
* http://www.apache.org/licenses/LICENSE-2.0
|
* Unless required by applicable law or agreed to in writing, software
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
* See the License for the specific language governing permissions and
|
* limitations under the License.
|
*/
|
package com.redhat.training.messaging;
|
|
import org.jboss.logging.Logger;
|
import javax.ejb.ActivationConfigProperty;
|
import javax.ejb.MessageDriven;
|
import javax.jms.JMSException;
|
import javax.jms.Message;
|
import javax.jms.MessageListener;
|
import javax.jms.TextMessage;
|
|
/**
|
* <p>
|
* A simple Message Driven Bean that asynchronously receives and processes the messages that are sent to the queue.
|
* </p>
|
*
|
* @author Serge Pagop (spagop@redhat.com)
|
*
|
*/
|
@MessageDriven(name = "QueueListener", activationConfig = {
|
@ActivationConfigProperty(propertyName = "destinationLookup", propertyValue = "queue/helloWorldQueue"),
|
@ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
|
@ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge") })
|
public class QueueListener implements MessageListener {
|
|
private final static Logger LOGGER = Logger.getLogger(QueueListener.class.getName());
|
|
/**
|
* @see MessageListener#onMessage(Message)
|
*/
|
public void onMessage(Message rcvMessage) {
|
TextMessage msg = null;
|
try {
|
if (rcvMessage instanceof TextMessage) {
|
msg = (TextMessage) rcvMessage;
|
LOGGER.info("Received Message from helloWorldQueue ===> " + msg.getText());
|
} else {
|
LOGGER.warn("Message of wrong type: " + rcvMessage.getClass().getName());
|
}
|
} catch (JMSException e) {
|
throw new RuntimeException(e);
|
}
|
}
|
}
|
