Para que el presente "Messaging EJB" sea ejecutado correctamente 
  en su ambiente, debe agregar un usuario capaz de publicar mensajes 
  al proveedor JMS de JBoss.Este proceso es realizado a través de la 
  misma Base de Datos que ha venido utilizando para "Entity EJB": 
  Hypersonic. 
 
  Seguramente habrá notado que además de las tablas generadas en sus 
  diseños, Hypersonic ya incluye algunas otras por "default", estas 
  corresponden precisamente al proveedor JMS de JBoss. 

  De la misma consola administrativa de Hypersonic , ejecute los 
  siguientes comandos :  

     INSERT INTO JMS_USERS (USERID, PASSWD) VALUES ('bmv', 'a7y7fg');
     INSERT INTO JMS_ROLES (ROLEID, USERID) VALUES ('guest','bmv');
     INSERT INTO JMS_ROLES (ROLEID, USERID) VALUES ('subscriber','bmv');
     INSERT INTO JMS_ROLES (ROLEID, USERID) VALUES ('publisher','bmv');

  Esto genera el usuario bmv -- empleado en este diseño de Messaging EJB-- 
  y le asigna varios roles de ejecución. 

 Como alterantiva, puede optar por colocar esta misma secuencia de 
 ejecucion en el archivo hsqldb-jdbc-state-service.xml para
 que los valores sean cargados automaticamente al inicialiarse JBoss. 
 Dicho archivo esta ubicado en $JBOSS_HOME/server/default/deploy/jms/, 
 donde $JBOSS_HOME es el directorio raíz de instalación.

package com.osmosislatina.ejb.bolsa;

import javax.ejb.MessageDrivenBean;
import javax.ejb.MessageDrivenContext;
import javax.ejb.EJBException;


import javax.jms.MessageListener;
import javax.jms.Message;
import javax.jms.TextMessage;
import javax.jms.JMSException;


public class BancaDeInversion implements MessageDrivenBean, MessageListener { 

 
    private MessageDrivenContext ctx;

    public void ejbCreate() { } 
    
    public void ejbRemove() { ctx = null; } 


    public void setMessageDrivenContext(MessageDrivenContext ctx) {
	 this.ctx = ctx;
    }

 
    public void onMessage(Message message)  { 
	
	TextMessage textmessage = null;
	if (message instanceof TextMessage) { 
	    textmessage = (TextMessage)message;
	} else { 
	    return;
	}

	try { 
	    String s = textmessage.getText();
	     System.out.println("Valores de Acciones Recibidos : " + s);
	 } catch (JMSException ex) { 
	     ex.printStackTrace();
	 }
     }
    
}