You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by cmoulliard <cm...@gmail.com> on 2008/10/24 14:56:42 UTC
Camel & AJAX Activemq : Help requested !!!
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-tp20149622s22882p20149622.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel & AJAX Activemq : Help requested !!!
Posted by cmoulliard <cm...@gmail.com>.
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.