You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by go canal <go...@yahoo.com> on 2010/01/20 00:33:24 UTC

Configuring a topic in Spring with default ActiveMQ

Hi,
I am running the default ActiveMQ 5.3.0. Wanted to configure a publish-subscribe-channel in Spring. But I am not able to get any data, this is my Spring configuration, anything wrong :

<integration:publish-subscribe-channel id="STOCKS.BEAS"/>
<integration:service-activator input-channel="STOCKS.BEAS" ref="gatewayBean"/>

 appreciate your help,
canal

Re: Configuring a topic in Spring with default ActiveMQ

Posted by Rob Davies <ra...@gmail.com>.
Have you read this - http://codedependents.com/2009/10/16/efficient-lightweight-jms-with-spring-and-activemq/ 
  - it may help

On 20 Jan 2010, at 01:35, go canal wrote:

> I need to use message-driven-channel-adapter.
>
>
>
> ________________________________
> From: go canal <go...@yahoo.com>
> To: users@activemq.apache.org
> Sent: Wed, January 20, 2010 8:53:39 AM
> Subject: Re: Configuring a topic in Spring with default ActiveMQ
>
> I think I need to add:
> <bean id="requestTopic"  
> class="org.apache.activemq.command.ActiveMQTopic">
> <!-- wildcard -->
> <constructor-arg value="STOCKS.*"/>
> </bean>
> <jms:inbound-gateway id="jmsIn" request-destination="requestTopic"  
> request-channel="inChannel"/>
> Now I can receive messages but only the first one. I can not get  
> subsequent messages.
>
> This is my service activator:
>
> @ServiceActivator
> public void upperCase(String input) {
> System.out.println ("message received : " + input);
> }
>
>
> Anything I missed out ?rgds,
> canal
>
>
>
>
> ________________________________
> From: go canal <go...@yahoo.com>
> To: users@activemq.apache.org
> Sent: Wed, January 20, 2010 7:33:24 AM
> Subject: Configuring a topic in Spring with default ActiveMQ
>
> Hi,
> I am running the default ActiveMQ 5.3.0. Wanted to configure a  
> publish-subscribe-channel in Spring. But I am not able to get any  
> data, this is my Spring configuration, anything wrong :
>
> <integration:publish-subscribe-channel id="STOCKS.BEAS"/>
> <integration:service-activator input-channel="STOCKS.BEAS"  
> ref="gatewayBean"/>
>
> appreciate your help,
> canal
>
>

Rob Davies
http://twitter.com/rajdavies
I work here: http://fusesource.com
My Blog: http://rajdavies.blogspot.com/
I'm writing this: http://www.manning.com/snyder/

Re: Configuring a topic in Spring with default ActiveMQ

Posted by go canal <go...@yahoo.com>.
I need to use message-driven-channel-adapter.



________________________________
From: go canal <go...@yahoo.com>
To: users@activemq.apache.org
Sent: Wed, January 20, 2010 8:53:39 AM
Subject: Re: Configuring a topic in Spring with default ActiveMQ

I think I need to add:
<bean id="requestTopic" class="org.apache.activemq.command.ActiveMQTopic">
<!-- wildcard -->
<constructor-arg value="STOCKS.*"/>
</bean>
<jms:inbound-gateway id="jmsIn" request-destination="requestTopic" request-channel="inChannel"/>
Now I can receive messages but only the first one. I can not get subsequent messages. 

This is my service activator:

@ServiceActivator
public void upperCase(String input) {
System.out.println ("message received : " + input);
}


Anything I missed out ?rgds,
canal




________________________________
From: go canal <go...@yahoo.com>
To: users@activemq.apache.org
Sent: Wed, January 20, 2010 7:33:24 AM
Subject: Configuring a topic in Spring with default ActiveMQ

Hi,
I am running the default ActiveMQ 5.3.0. Wanted to configure a publish-subscribe-channel in Spring. But I am not able to get any data, this is my Spring configuration, anything wrong :

<integration:publish-subscribe-channel id="STOCKS.BEAS"/>
<integration:service-activator input-channel="STOCKS.BEAS" ref="gatewayBean"/>

appreciate your help,
canal

Re: Configuring a topic in Spring with default ActiveMQ

Posted by go canal <go...@yahoo.com>.
I think I need to add:
<bean id="requestTopic" class="org.apache.activemq.command.ActiveMQTopic">
<!-- wildcard -->
<constructor-arg value="STOCKS.*"/>
</bean>
<jms:inbound-gateway id="jmsIn" request-destination="requestTopic" request-channel="inChannel"/>
Now I can receive messages but only the first one. I can not get subsequent messages. 

This is my service activator:

@ServiceActivator
public void upperCase(String input) {
System.out.println ("message received : " + input);
}


Anything I missed out ?rgds,
canal




________________________________
From: go canal <go...@yahoo.com>
To: users@activemq.apache.org
Sent: Wed, January 20, 2010 7:33:24 AM
Subject: Configuring a topic in Spring with default ActiveMQ

Hi,
I am running the default ActiveMQ 5.3.0. Wanted to configure a publish-subscribe-channel in Spring. But I am not able to get any data, this is my Spring configuration, anything wrong :

<integration:publish-subscribe-channel id="STOCKS.BEAS"/>
<integration:service-activator input-channel="STOCKS.BEAS" ref="gatewayBean"/>

appreciate your help,
canal