camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cmoulliard <cmoulli...@gmail.com>
Subject Re: Camel & AJAX Activemq : Help requested !!!
Date Tue, 28 Oct 2008 13:15:55 GMT

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 client=org.apache.activemq.web.WebClient@7e80a
> session=DC707773062F22CFCDF8AE36863E92DF uri=/Tracker-web/amq
> query=timeout=0&_=
> 2008-10-24 12:20:25,824 [http-8080-1    ] DEBUG MessageListenerServlet        
> - GET client=org.apache.activemq.web.WebClient@7e80a
> 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 : cmoulliard@xpectis.com
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.


Mime
View raw message