package com.mkl.message;

import javax.jms.*;
import javax.ejb.MessageDriven;
import javax.ejb.ActivationConfigProperty;

@MessageDriven(name="PhoneMessageBean", activationConfig = {
     @ActivationConfigProperty(propertyName="destinationType", propertyValue="javax.jms.Queue"),
     @ActivationConfigProperty(propertyName="destination", propertyValue="queue/phoneQueue")
 })
public class Phone implements MessageListener {

    @Override
    public void onMessage(Message msg) {
        TextMessage textMsg = (TextMessage) msg;
        try {
            System.out.println("Received Phone Call:" + textMsg.getText());
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}

<component name="phoneQueueSender"
          class="org.jboss.seam.jms.ManagedQueueSender">
    <property name="queueJndiName">queue/phoneQueue</property>
</component>

<jms:managed-queue-sender name="phoneQueueSender" auto-create="true" queue-jndi-name="queue/phoneQueue"/>

 @In(create=true)
 private transient QueueSender phoneQueueSender;
 @In(create=true)
 private transient QueueSession queueSession;

 public void make_a_call (){
       try
       {
          phoneQueueSender.send( queueSession.createTextMessage("You are in trouble"));
       }
       catch (Exception ex)
       {
       ex.printStackTrace();
          throw new RuntimeException(ex);
       }
    }

@In
private TopicPublisher stockTickerPublisher;
@In
private TopicSession topicSession;

public void publish(StockPrice price) {
    try    {
        stockTickerPublisher.publish( topicSession.createObjectMessage(price) );
    }
    catch (Exception ex){
        throw new RuntimeException(ex);
    }
}