The problem is solved so forget my post. It was due to a typo error in the queue name syntax topic:STOCK:* instead of topic:STOCKS:* between Camel and ActiveMQ.
cmoulliard wrote: > > Hi, > > I try to implement the portfolio example provided under the sub-project > activemq-web and demo in combination with Camel but unfortunately, I > cannot receive any result from the JMS queues called by the > MessageListener Servlet ? > > Remark : > - The only modification that I made to the code is to by pass the > PortfolioServlet and to replace the stock price generator by a spring bean > component called by camel through a timer endpoint. > - The stock price object generated is marshalled using Xstream > - The xml created by Xstream is send to JMS topic though a recipient > processor > - Messages are well published onto the topic://STOCK.* queues because I > can see them through JConsole > - A request is send from the web client to the MessageListenerServlet but > no feedback is returned > - The message broker is created by Camel instead of ActiveMQ > > Here is the trace of my log in DEBUG : > > Launch of the application + queue creation > > 2008-10-24 12:18:59,480 [00&period=60000] INFO BrokerService > - ActiveMQ 5.1.0 JMS Message Broker (localhost) is starting > 2008-10-24 12:18:59,480 [00&period=60000] INFO BrokerService > - ActiveMQ 5.1.0 JMS Message Broker (localhost) is starting > 2008-10-24 12:18:59,480 [00&period=60000] INFO BrokerService > - For help or more information please see: http://activemq.apache.org/ > 2008-10-24 12:18:59,480 [00&period=60000] INFO BrokerService > - For help or more information please see: http://activemq.apache.org/ > 2008-10-24 12:18:59,636 [JMX connector ] INFO ManagementContext > - JMX consoles can connect to > service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi > 2008-10-24 12:18:59,636 [JMX connector ] INFO ManagementContext > - JMX consoles can connect to > service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi > 2008-10-24 12:18:59,840 [00&period=60000] INFO BrokerService > - ActiveMQ JMS Message Broker (localhost, > ID:dell-charles-1929-1224843539621-0:0) started > 2008-10-24 12:18:59,840 [00&period=60000] INFO BrokerService > - ActiveMQ JMS Message Broker (localhost, > ID:dell-charles-1929-1224843539621-0:0) started > 2008-10-24 12:18:59,840 [00&period=60000] DEBUG VMTransportFactory > - binding to broker: localhost > 2008-10-24 12:18:59,840 [00&period=60000] DEBUG VMTransportFactory > - binding to broker: localhost > 2008-10-24 12:18:59,855 [00&period=60000] INFO TransportConnector > - Connector vm://localhost Started > 2008-10-24 12:18:59,855 [00&period=60000] INFO TransportConnector > - Connector vm://localhost Started > 2008-10-24 12:18:59,996 [VMTransport ] DEBUG TransportConnection > - Setting up new connection: vm://localhost#0 > 2008-10-24 12:18:59,996 [VMTransport ] DEBUG TransportConnection > - Setting up new connection: vm://localhost#0 > 2008-10-24 12:19:00,027 [VMTransport ] DEBUG AbstractRegion > - Adding destination: topic://ActiveMQ.Advisory.Connection > 2008-10-24 12:19:00,027 [VMTransport ] DEBUG AbstractRegion > - Adding destination: topic://ActiveMQ.Advisory.Connection > 2008-10-24 12:19:00,090 [VMTransport ] DEBUG AbstractRegion > - Adding consumer: ID:dell-charles-1929-1224843539621-2:0:-1:1 > 2008-10-24 12:19:00,090 [VMTransport ] DEBUG AbstractRegion > - Adding consumer: ID:dell-charles-1929-1224843539621-2:0:-1:1 > 2008-10-24 12:19:00,480 [00&period=60000] DEBUG ActiveMQSession > - ID:dell-charles-1929-1224843539621-2:0:1 sending message: > ActiveMQTextMessage {commandId = 0, responseRequired = false, messageId = > ID:dell-charles-1929-1224843539621-2:0:1:1:1, originalDestination = null, > originalTransactionId = null, producerId = > ID:dell-charles-1929-1224843539621-2:0:1:1, destination = > topic://STOCK.MSFT, transactionId = null, expiration = 0, timestamp = > 1224843540480, arrival = 0, brokerInTime = 0, brokerOutTime = 0, > correlationId = null, replyTo = null, persistent = true, type = null, > priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, > compressed = false, userID = null, content = null, marshalledProperties = > null, dataStructure = null, redeliveryCounter = 0, size = 0, properties = > {org_apache_camel_splitSize=1, org_apache_camel_splitCounter=0}, > readOnlyProperties = true, readOnlyBody = true, droppable = false, text = > <price bid="97.1730797767862" movement="down" offer="97.27025285656298" > stock="MSFT"/>} > 2008-10-24 12:19:00,480 [00&period=60000] DEBUG ActiveMQSession > - ID:dell-charles-1929-1224843539621-2:0:1 sending message: > ActiveMQTextMessage {commandId = 0, responseRequired = false, messageId = > ID:dell-charles-1929-1224843539621-2:0:1:1:1, originalDestination = null, > originalTransactionId = null, producerId = > ID:dell-charles-1929-1224843539621-2:0:1:1, destination = > topic://STOCK.MSFT, transactionId = null, expiration = 0, timestamp = > 1224843540480, arrival = 0, brokerInTime = 0, brokerOutTime = 0, > correlationId = null, replyTo = null, persistent = true, type = null, > priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, > compressed = false, userID = null, content = null, marshalledProperties = > null, dataStructure = null, redeliveryCounter = 0, size = 0, properties = > {org_apache_camel_splitSize=1, org_apache_camel_splitCounter=0}, > readOnlyProperties = true, readOnlyBody = true, droppable = false, text = > <price bid="97.1730797767862" movement="down" offer="97.27025285656298" > stock="MSFT"/>} > 2008-10-24 12:19:00,496 [VMTransport ] DEBUG AbstractRegion > - Adding destination: topic://STOCK.MSFT > 2008-10-24 12:19:00,496 [VMTransport ] DEBUG AbstractRegion > - Adding destination: topic://STOCK.MSFT > 2008-10-24 12:19:00,511 [VMTransport ] DEBUG AbstractRegion > - Adding destination: topic://ActiveMQ.Advisory.Topic > 2008-10-24 12:19:00,511 [VMTransport ] DEBUG AbstractRegion > - Adding destination: topic://ActiveMQ.Advisory.Topic > 2008-10-24 12:19:58,418 [VMTransport ] DEBUG TransportConnection > - Setting up new connection: vm://localhost#2 > 2008-10-24 12:19:58,418 [VMTransport ] DEBUG TransportConnection > - Setting up new connection: vm://localhost#2 > 2008-10-24 12:19:58,418 [VMTransport ] DEBUG AbstractRegion > - Adding consumer: ID:dell-charles-1929-1224843539621-2:1:-1:1 > 2008-10-24 12:19:58,418 [VMTransport ] DEBUG AbstractRegion > - Adding consumer: ID:dell-charles-1929-1224843539621-2:1:-1:1 > 2008-10-24 12:19:58,418 [00&period=60000] DEBUG ActiveMQSession > - ID:dell-charles-1929-1224843539621-2:1:1 sending message: > ActiveMQTextMessage {commandId = 0, responseRequired = false, messageId = > ID:dell-charles-1929-1224843539621-2:1:1:1:1, originalDestination = null, > originalTransactionId = null, producerId = > ID:dell-charles-1929-1224843539621-2:1:1:1, destination = > topic://STOCK.SUNW, transactionId = null, expiration = 0, timestamp = > 1224843598418, arrival = 0, brokerInTime = 0, brokerOutTime = 0, > correlationId = null, replyTo = null, persistent = true, type = null, > priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, > compressed = false, userID = null, content = null, marshalledProperties = > null, dataStructure = null, redeliveryCounter = 0, size = 0, properties = > {org_apache_camel_splitSize=1, org_apache_camel_splitCounter=0}, > readOnlyProperties = true, readOnlyBody = true, droppable = false, text = > <price bid="34.9326573510917" movement="up" offer="34.967590008442784" > stock="SUNW"/>} > 2008-10-24 12:19:58,418 [00&period=60000] DEBUG ActiveMQSession > - ID:dell-charles-1929-1224843539621-2:1:1 sending message: > ActiveMQTextMessage {commandId = 0, responseRequired = false, messageId = > ID:dell-charles-1929-1224843539621-2:1:1:1:1, originalDestination = null, > originalTransactionId = null, producerId = > ID:dell-charles-1929-1224843539621-2:1:1:1, destination = > topic://STOCK.SUNW, transactionId = null, expiration = 0, timestamp = > 1224843598418, arrival = 0, brokerInTime = 0, brokerOutTime = 0, > correlationId = null, replyTo = null, persistent = true, type = null, > priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, > compressed = false, userID = null, content = null, marshalledProperties = > null, dataStructure = null, redeliveryCounter = 0, size = 0, properties = > {org_apache_camel_splitSize=1, org_apache_camel_splitCounter=0}, > readOnlyProperties = true, readOnlyBody = true, droppable = false, text = > <price bid="34.9326573510917" movement="up" offer="34.967590008442784" > stock="SUNW"/>} > 2008-10-24 12:19:58,433 [VMTransport ] DEBUG AbstractRegion > - Adding destination: topic://STOCK.SUNW > 2008-10-24 12:19:58,433 [VMTransport ] DEBUG AbstractRegion > - Adding destination: topic://STOCK.SUNW > > Everything is ok and messages are published on JMS:topic queues > > Here is the log after the call from my web client : > > 2008-10-24 12:20:25,824 [http-8080-1 ] DEBUG MessageListenerServlet > - GET [EMAIL PROTECTED] > session=DC707773062F22CFCDF8AE36863E92DF uri=/Tracker-web/amq > query=timeout=0&_= > 2008-10-24 12:20:25,824 [http-8080-1 ] DEBUG MessageListenerServlet > - GET [EMAIL PROTECTED] > session=DC707773062F22CFCDF8AE36863E92DF uri=/Tracker-web/amq > query=timeout=0&_= > 2008-10-24 12:20:25,840 [http-8080-1 ] DEBUG MessageListenerServlet > - doMessage timeout=0 > 2008-10-24 12:20:25,840 [http-8080-1 ] DEBUG MessageListenerServlet > - doMessage timeout=0 > > Nothing is returned to the web browser > > Normally, the following traffic should be generated after doMessage > timeout=0 : > > 43133453 [Persistence Adaptor Task] DEBUG > org.apache.activemq.store.amq.AMQPersistenceAdapter - Checkpoint started. > 43133453 [Persistence Adaptor Task] DEBUG > org.apache.activemq.store.amq.AMQPersistenceAdapter - Checkpoint started. > 43133453 [Persistence Adaptor Task] DEBUG > org.apache.activemq.store.amq.AMQPersistenceAdapter - Checkpoint done. > 43133453 [Persistence Adaptor Task] DEBUG > org.apache.activemq.store.amq.AMQPersistenceAdapter - Checkpoint done. > 4324-oct.-2008 14:33:21 org.apache.catalina.core.ApplicationContext log > 135703 [http-8080-2] DEBUG org.apache.activemq.ActiveMQSession - > ID:dell-charles-1487-1224851539746-2:0:1 sending message: > ActiveMQTextMessage {commandId = 0, responseRequired = false, messageId = > ID:dell-charles-1487-1224851539746-2:0:1:1:2, originalDestination = null, > originalTransactionId = null, producerId = > ID:dell-charles-1487-1224851539746-2:0:1:1, destination = > topic://STOCKS.MSFT, transactionId = null, expiration = 0, timestamp = > 1224851601886, arrival = 0, brokerInTime = 0, brokerOutTime = 0, > correlationId = null, replyTo = null, persistent = false, type = null, > priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, > compressed = false, userID = null, content = null, marshalledProperties = > null, dataStructure = null, redeliveryCounter = 0, size = 0, properties = > null, readOnlyProperties = true, readOnlyBody = true, droppable = false, > text = <price stock='MSFT' bid='40.11145307967294' > offer='40.15156453275261' movement='up'/>} > 43135703 [http-8080-2] DEBUG org.apache.activemq.ActiveMQSession - > ID:dell-charles-1487-1224851539746-2:0:1 sending message: > ActiveMQTextMessage {commandId = 0, responseRequired = false, messageId = > ID:dell-charles-1487-1224851539746-2:0:1:1:2, originalDestination = null, > originalTransactionId = null, producerId = > ID:dell-charles-1487-1224851539746-2:0:1:1, destination = > topic://STOCKS.MSFT, transactionId = null, expiration = 0, timestamp = > 1224851601886, arrival = 0, brokerInTime = 0, brokerOutTime = 0, > correlationId = null, replyTo = null, persistent = false, type = null, > priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, > compressed = false, userID = null, content = null, marshalledProperties = > null, dataStructure = null, redeliveryCounter = 0, size = 0, properties = > null, readOnlyProperties = true, readOnlyBody = true, droppable = false, > text = <price stock='MSFT' bid='40.11145307967294' > offer='40.15156453275261' movement='up'/>} > 43135703 [http-8080-2] DEBUG org.apache.activemq.web.WebClient - Sent! to > destination: topic://STOCKS.MSFT message: ActiveMQTextMessage {commandId = > 0, responseRequired = false, messageId = > ID:dell-charles-1487-1224851539746-2:0:1:1:2, originalDestination = null, > originalTransactionId = null, producerId = null, destination = > topic://STOCKS.MSFT, transactionId = null, expiration = 0, timestamp = > 1224851601886, arrival = 0, brokerInTime = 0, brokerOutTime = 0, > correlationId = null, replyTo = null, persistent = false, type = null, > priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, > compressed = false, userID = null, content = null, marshalledProperties = > null, dataStructure = null, redeliveryCounter = 0, size = 0, properties = > null, readOnlyProperties = false, readOnlyBody = false, droppable = false, > text = <price stock='MSFT' bid='40.11145307967294' > offer='40.15156453275261' movement='up'/>} > 43135703 [http-8080-2] DEBUG org.apache.activemq.web.WebClient - Sent! to > destination: topic://STOCKS.MSFT message: ActiveMQTextMessage {commandId = > 0, responseRequired = false, messageId = > ID:dell-charles-1487-1224851539746-2:0:1:1:2, originalDestination = null, > originalTransactionId = null, producerId = null, destination = > topic://STOCKS.MSFT, transactionId = null, expiration = 0, timestamp = > 1224851601886, arrival = 0, brokerInTime = 0, brokerOutTime = 0, > correlationId = null, replyTo = null, persistent = false, type = null, > priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, > compressed = false, userID = null, content = null, marshalledProperties = > null, dataStructure = null, redeliveryCounter = 0, size = 0, properties = > null, readOnlyProperties = false, readOnlyBody = false, droppable = false, > text = <price stock='MSFT' bid='40.11145307967294' > offer='40.15156453275261' movement='up'/>} > > Question : Could the issue be coming from the fact that Camel instantiates > the message broker instead of ActiveMQ ? > > KR, > > Charles Moulliard > ----- Enterprise Architect Xpectis 12, route d'Esch L-1470 Luxembourg Phone +352 25 10 70 470 Mobile +352 621 45 36 22 e-mail : [EMAIL PROTECTED] web site : www.xpectis.com www.xpectis.com My Blog : http://cmoulliard.blogspot.com/ http://cmoulliard.blogspot.com/ -- View this message in context: http://www.nabble.com/Camel---AJAX-Activemq-%3A-Help-requested-%21%21%21-tp20149622s22882p20206998.html Sent from the Camel - Users mailing list archive at Nabble.com.
