[jboss-user] [JBoss Messaging] - Servlet as a topic listener
rolmovel
do-not-reply at jboss.com
Thu Apr 12 06:22:20 EDT 2007
Hi, I,m trying to subscribe a servlet to a topic for event notifying to clients (with lazy loading technology) but when i instance the servlet from the IExplorer i get next exception:
| 12:25:58,989 ERROR [STDERR] javax.jms.IllegalStateException: This method is not applicable inside the application server. See the J2EE spec, e.g. J2EE1.4 Section 6.6
| 12:25:58,989 ERROR [STDERR] at org.jboss.resource.adapter.jms.JmsSession.checkStrict(JmsSession.java:542)
| 12:25:58,989 ERROR [STDERR] at org.jboss.resource.adapter.jms.JmsMessageConsumer.setMessageListener(JmsMessageConsumer.java:136)
| 12:25:58,989 ERROR [STDERR] at elimina.ServletPrueba.service(ServletPrueba.java:79)
| 12:25:58,989 ERROR [STDERR] at javax.servlet.http.HttpServlet.service(HttpServlet.java:810)
| 12:25:58,989 ERROR [STDERR] at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:252)
| 12:25:58,989 ERROR [STDERR] at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:173)
| 12:25:58,989 ERROR [STDERR] at org.jboss.web.tomcat.filters.ReplyHeaderFilter.doFilter(ReplyHeaderFilter.java:96)
| 12:25:58,989 ERROR [STDERR] at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:202)
| 12:25:58,989 ERROR [STDERR] at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:173)
| 12:25:58,989 ERROR [STDERR] at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:213)
| 12:25:58,989 ERROR [STDERR] at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:178)
| 12:25:58,989 ERROR [STDERR] at org.jboss.web.tomcat.security.SecurityAssociationValve.invoke(SecurityAssociationValve.java:175)
| 12:25:58,989 ERROR [STDERR] at org.jboss.web.tomcat.security.JaccContextValve.invoke(JaccContextValve.java:74)
| 12:25:58,989 ERROR [STDERR] at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:126)
| 12:25:58,989 ERROR [STDERR] at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:105)
| 12:25:58,989 ERROR [STDERR] at org.jboss.web.tomcat.tc5.jca.CachedConnectionValve.invoke(CachedConnectionValve.java:156)
| 12:25:58,989 ERROR [STDERR] at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:107)
| 12:25:58,989 ERROR [STDERR] at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:148)
| 12:25:58,989 ERROR [STDERR] at org.apache.coyote.http11.Http11Processor.process(Http11Processor.java:869)
| 12:25:58,989 ERROR [STDERR] at org.apache.coyote.http11.Http11BaseProtocol$Http11ConnectionHandler.processConnection(Http11BaseProtocol.java:664)
| 12:25:58,989 ERROR [STDERR] at org.apache.tomcat.util.net.PoolTcpEndpoint.processSocket(PoolTcpEndpoint.java:527)
| 12:25:58,989 ERROR [STDERR] at org.apache.tomcat.util.net.MasterSlaveWorkerThread.run(MasterSlaveWorkerThread.java:112)
| 12:25:58,989 ERROR [STDERR] at java.lang.Thread.run(Unknown Source)
| 12:25:59,005 INFO [CachedConnectionManager] Closing a connection for you. Please close them yourself: org.jboss.resource.adapter.jms.JmsSession at ed7f5c
| java.lang.Throwable: STACKTRACE
| at org.jboss.resource.connectionmanager.CachedConnectionManager.registerConnection(CachedConnectionManager.java:290)
| at org.jboss.resource.connectionmanager.BaseConnectionManager2.allocateConnection(BaseConnectionManager2.java:417)
| at org.jboss.resource.connectionmanager.BaseConnectionManager2$ConnectionManagerProxy.allocateConnection(BaseConnectionManager2.java:842)
| at org.jboss.resource.adapter.jms.JmsSessionFactoryImpl.allocateConnection(JmsSessionFactoryImpl.java:389)
| at org.jboss.resource.adapter.jms.JmsSessionFactoryImpl.createTopicSession(JmsSessionFactoryImpl.java:166)
| at elimina.ServletPrueba.service(ServletPrueba.java:75)
| at javax.servlet.http.HttpServlet.service(HttpServlet.java:810)
| at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:252)
| at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:173)
| at org.jboss.web.tomcat.filters.ReplyHeaderFilter.doFilter(ReplyHeaderFilter.java:96)
| at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:202)
| at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:173)
| at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:213)
| at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:178)
| at org.jboss.web.tomcat.security.SecurityAssociationValve.invoke(SecurityAssociationValve.java:175)
| at org.jboss.web.tomcat.security.JaccContextValve.invoke(JaccContextValve.java:74)
| at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:126)
| at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:105)
| at org.jboss.web.tomcat.tc5.jca.CachedConnectionValve.invoke(CachedConnectionValve.java:156)
| at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:107)
| at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:148)
| at org.apache.coyote.http11.Http11Processor.process(Http11Processor.java:869)
| at org.apache.coyote.http11.Http11BaseProtocol$Http11ConnectionHandler.processConnection(Http11BaseProtocol.java:664)
| at org.apache.tomcat.util.net.PoolTcpEndpoint.processSocket(PoolTcpEndpoint.java:527)
| at org.apache.tomcat.util.net.MasterSlaveWorkerThread.run(MasterSlaveWorkerThread.java:112)
| at java.lang.Thread.run(Unknown Source)
|
|
Here is the code ...
|
| package elimina;
|
| import javax.jms.Message;
| import javax.jms.Session;
| import javax.jms.TextMessage;
| import javax.jms.Topic;
| import javax.jms.TopicConnection;
| import javax.jms.TopicConnectionFactory;
| import javax.jms.TopicSession;
| import javax.jms.TopicSubscriber;
| import javax.management.ObjectName;
| import javax.naming.Context;
| import javax.naming.InitialContext;
| import javax.servlet.http.HttpServlet;
|
| import java.io.IOException;
| import java.util.Hashtable;
|
| import javax.servlet.ServletException;
| import javax.servlet.http.HttpServletRequest;
| import javax.servlet.http.HttpServletResponse;
|
| /**
| * Servlet Class
| *
| * @web.servlet name="ServletPrueba"
| * display-name="Name for ServletPrueba"
| * description="Description for ServletPrueba"
| * @web.servlet-mapping url-pattern="/ServletPrueba"
| * @web.servlet-init-param name="A parameter"
| * value="A value"
| */
| public class ServletPrueba extends HttpServlet implements javax.jms.MessageListener {
|
| public ServletPrueba() {
| // TODO Auto-generated constructor stub
| }
|
| public void onMessage (Message message) {
| try {
| TextMessage textMessage = (TextMessage) message;
| System.out.println("Mensaje recibido");
| } catch (Exception e) {
| // Ver excepciones y tratamiento
| System.out.println(e);
| }
| }
|
| protected void service(HttpServletRequest req, HttpServletResponse resp)
| throws ServletException,
| IOException {
| // TODO Auto-generated method stub
| Topic topic = null;
| TopicConnectionFactory topicConnectionFactory = null;
| TopicConnection topicConnection = null;
|
| super.service(req, resp);
| try {
| Hashtable props = new Hashtable();
| props.put(
| Context.INITIAL_CONTEXT_FACTORY,
| "org.jnp.interfaces.NamingContextFactory");
| props.put(
| Context.URL_PKG_PREFIXES,
| "org.jboss.naming:org.jnp.interfaces");
| props.put(Context.PROVIDER_URL, "jnp://localhost:1099");
| Context ctx = new InitialContext(props);
|
| topicConnectionFactory = (TopicConnectionFactory)ctx.lookup("TopicConnectionFactory");
| topic = (Topic)ctx.lookup("topic/testTopic");
| ctx.close();
|
| // conectamos
| topicConnection = topicConnectionFactory.createTopicConnection();
| TopicSession topicSession = topicConnection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
|
|
| TopicSubscriber topicSubscriber = topicSession.createSubscriber(topic);
| topicSubscriber.setMessageListener(this);
|
| topicConnection.start();
| for (;;) {
| java.io.OutputStream out = resp.getOutputStream();
| out.write("1".getBytes());
| out.write(new byte[450]);
| out.flush();
| Thread.sleep(100);
| }
|
| } catch (Exception e) {
| // Ver que excepciones lanza y el trataimento
| e.printStackTrace();
| }
|
|
| }
|
| }
Thanks in advanced
View the original post : http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4036664#4036664
Reply to the post : http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&p=4036664
More information about the jboss-user
mailing list