Jason Greene [http://community.jboss.org/people/jason.greene] created the discussion "Re: Messaging configuration in AS 7" To view the discussion, visit: http://community.jboss.org/message/614486#614486 -------------------------------------------------------------- Hi Andrew, Unfortunately we won't have MDB support in Final. We deproritized anything non-web profile once we found out that due to recent certification requirements, we have to do extra work to make sure that there is no way that a user can consume the feature in whatever our certified configuration (and distribution) is. It will be one of the first features we have in early 7.1 releases, however if there is enough demand we may be able to backport something in a 7.0.x update. In the meantime you could use a traditional JMS listener inside of an ejb singleton deployment. Unless you would rather wait. -------------------------------------------------------------- Reply to this message by going to Community [http://community.jboss.org/message/614486#614486] Start a new discussion in JBoss AS7 Development at Community [http://community.jboss.org/choose-container!input.jspa?contentType=1&...]

Tom Jenkinson [http://community.jboss.org/people/tomjenkinson] created the discussion "Re: Messaging configuration in AS 7" To view the discussion, visit: http://community.jboss.org/message/614825#614825 -------------------------------------------------------------- Is there an example of best practice for the route you suggested? Lets say I deployed a dummy EJB so that I could get an MDB: public interface MyFakeMDB extends javax.jms.MessageListener { } @Stateless @Singleton public class MyFakeMDBImpl MyFakeMDB {      public void onMessage(Message message) {      } } Assuming this is totally a fake EJB and I just want it to have MDB like behavior,  where should I put the JMS code to bind my message listener to the queue. I don't mean what code do I need to write: MessageConsumer mc = ((ConnectionFactory) new InitialContent().lookup("ConnectionFactory")).createConnection().createSession().createMessageConsumer((Destination)new InitialContext().lookup("foo")); mc.setMessageListener(this); What I mean is, where should this code go? I guess the constructor, but with AS7, will the EJB constructor only be called when someone accesses my the EJB through an interface, or is an instance of my EJB always created as soon as I deploy my ear/war? <quick grep of the internet/> Actually, I just checked online and can see that I can put this in the constructor,and put the following annotation as well: javax.ejb.Startup Which leads to the following: public interface MyFakeMDB extends javax.jms.MessageListener { } @Stateless @Singleton @Startup public class MyFakeMDBImpl implements MyFakeMDB {      @Inject      Context ic;      MessageConsumer mc;      public MyFakeMDBImpl() {           ConnectionFactory cf =  (ConnectionFactory) ic.lookup("ConnectionFactory");           Connection c = cf.createConnection();           Session s =  c.createSession();           Destination d =  (Destination)ic.lookup("foo");           mc = s.createMessageConsumer(d);           mc.setMessageListener(this);      }      public void onMessage(Message message) {      } } Does that look like the best way to do this? I suppose the only issue with this would be if I wanted JTA? In which case I would end up writing quite a bit more code to manage "XAConnectionFactory" code? -------------------------------------------------------------- Reply to this message by going to Community [http://community.jboss.org/message/614825#614825] Start a new discussion in JBoss AS7 Development at Community [http://community.jboss.org/choose-container!input.jspa?contentType=1&...]

Jason Stedman [http://community.jboss.org/people/jstedman] created the discussion "Re: Messaging configuration in AS 7" To view the discussion, visit: http://community.jboss.org/message/619727#619727 -------------------------------------------------------------- So, I tried the solution proposed by Tom, it seems very logical and "should" work... it would seem. Unfortunately I am doing something terribly wrong in my implementation somehow. You see, the EJB I am creating (pretty much copied from his code, very slight modification) actually compiles, gets "deployed" by the jboss7 server... sorta.. but does not actually attach to the queue. And I say it gets "deployed" sorta because it doesnt actually execute any code in the deployment, the log says it deployed, the admin web console shows it under deployments as being enabled, but adding logger statements in the constructor does not result in anything printing out. Even putting code specifically to throw exceptions does not result in any output from this bean, well except "12:53:07,084 INFO  [org.jboss.as.server.controller] (DeploymentScanner-threads - 2) Deployed "abean-ejb-0.0.1-SNAPSHOT.jar" JConsole shows queue/AQueue as being active and the web service that puts messages on the queue actually does increment the queue counter in JConsole, so it can't be a naming issue. This is further supported by the fact that putting a name that definitely is garbage into ABean does not result in a naming exception. Any ideas? {//Codeblock import javax.ejb.*; import javax.jms.Connection; import javax.jms.ConnectionFactory; import javax.jms.Destination; import javax.jms.JMSException; import javax.jms.Message; import javax.jms.MessageConsumer; import javax.jms.MessageListener; import javax.jms.Session; import javax.naming.Context; import javax.naming.NamingException; import org.apache.log4j.Logger; @Stateless @Singleton @Startup public class ABean implements MessageListener {     public void onMessage(Message aMsg)     {         LOGGER.info("Found a message!" + aMsg.toString());     }     public static final String JMS_QUEUE_NAME = "queue/AQueue";     private static final Logger LOGGER = Logger.getLogger(ABean.class);     Context ic;     MessageConsumer mc;     public ABean(){         LOGGER.info("ABean Constructor Called");         try {             ConnectionFactory cf =  (ConnectionFactory) ic.lookup("ConnectionFactory");             Connection c;             c = cf.createConnection();             Session s =  c.createSession(false, Session.AUTO_ACKNOWLEDGE);             Destination d =  (Destination)ic.lookup(JMS_QUEUE_NAME);             mc = s.createConsumer(d);             mc.setMessageListener(this);         } catch (JMSException e) {             // TODO Auto-generated catch block             e.printStackTrace();         } catch (NamingException e) {             // TODO Auto-generated catch block             e.printStackTrace();         }     } } }//end Codeblock -------------------------------------------------------------- Reply to this message by going to Community [http://community.jboss.org/message/619727#619727] Start a new discussion in JBoss AS7 Development at Community [http://community.jboss.org/choose-container!input.jspa?contentType=1&...]