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-tp20149622s22882p20149622.html Sent from the Camel - Users mailing list archive at Nabble.com.
