WSN2005 and Activemq for message persistence

[Massimiliano Guillaro <m....@gmail.com>]

Hi to all,
i have a little (or big) problem. I have created the following architecture:

producer -> broker (servicemix WSN2005) -> consumer (web service)

i'm able to send and receive a notification from producer to receiver.
Now i should configure activemq to implement the persistence of message.
This is my activemq.xml:

<beans>
<!-- ActiveMQ JMS Broker configuration -->
−
<amq:broker id="broker" depends-on="jmxServer" persistent="true"
useShutdownHook="false">
−
<!--
 Disable creation of the jmx connector
         which is created in the jmx.xml configuration file
-->
−
<amq:managementContext>
−
<bean class="org.apache.activemq.broker.jmx.ManagementContext">
<property name="createConnector" value="false"/>
</bean>
</amq:managementContext>
−
<!--
 Use AMQ Message Store as default broker persistence adapter
-->
−
<amq:persistenceAdapter>
<amq:journaledJDBC journalLogFiles="5" dataDirectory="../data"
dataSource="#mysql-ds"/>
</amq:persistenceAdapter>
<!-- Examples for journaledJDBC if JDBC is required -->
−
<!--

      <amq:journaledJDBC journalLogFiles="5" dataDirectory="./data/amq"/>
-->
−
<amq:transportConnectors>
−
<!--
 Activate a TCP connector with multicast discovery.
            Note that multicast may be disabled if your computer
            is not on a network, which may prevent the broker to start.
            In such a case, just remove the discoveryUri attribute.  
         
-->
<amq:transportConnector uri="tcp://localhost:61616"
discoveryUri="multicast://default"/>
</amq:transportConnectors>
−
<amq:networkConnectors>
<!-- by default just auto discover the other brokers -->
<amq:networkConnector uri="multicast://default"/>
−
<!--
 
      <amq:networkConnector
uri="static://(tcp://host1:61616,tcp://host2:61616)"/>
     
-->
</amq:networkConnectors>
</amq:broker>

<!--
 MySql DataSource  Setup using the Commons DBCP pooler
(http://jakarta.apache.org/commons/dbcp/)
-->

−
<bean id="mysql-ds" class="org.apache.commons.dbcp.BasicDataSource"
destroy-method="close">
<property name="driverClassName" value="com.mysql.jdbc.Driver"/>
<property name="url" value="jdbc:mysql://10.20.102.78:3306/activemq"/>
<property name="username" value="activemqUser"/>
<property name="password" value="Password123"/>
<property name="poolPreparedStatements" value="true"/>
</bean>



</beans>

and this is my servicemix.xml

<beans xsi:schemaLocation="         
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-2.0.xsd         
http://servicemix.apache.org/config/1.0
http://servicemix.apache.org/schema/servicemix-core.xsd         
http://servicemix.apache.org/audit/1.0
http://servicemix.apache.org/schema/servicemix-audit.xsd">
<!-- System properties -->
−
<sm:systemProperties>
−
<property name="properties">
−
<map>
−
<entry key="java.security.auth.login.config">
−
<bean class="org.springframework.util.ResourceUtils"
factory-method="getFile">
<constructor-arg value="classpath:login.properties"/>
</bean>
</entry>
</map>
</property>
</sm:systemProperties>
−
<bean id="propertyConfigurer"
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
<property name="location" value="classpath:servicemix.properties"/>
</bean>
<!-- Include other resources -->
<import resource="classpath:security.xml"/>
<import resource="classpath:jmx.xml"/>
<import resource="classpath:activemq.xml"/>
<import resource="classpath:tx.xml"/>
<import resource="classpath:jndi.xml"/>
<!-- the JBI container -->
−
<sm:container id="jbi" rootDir="./data/smx" persistent="true"
MBeanServer="#jmxServer" installationDirPath="./hotdeploy"
monitorDeploymentDirectory="false" monitorInterval="1"
transactionManager="#transactionManager" createJmxConnector="false">
<sm:activationSpecs/>
−
<!--
 Use a secured broker (see security.xml)
         and define the 3 standard flows
-->
−
<sm:broker>
−
<sm:securedBroker authorizationMap="#authorizationMap">
−
<sm:flows>
<sm:sedaFlow/>
<sm:jmsFlow jmsURL="${activemq.url}"/>
<sm:jcaFlow connectionManager="#connectionManager"
jmsURL="${activemq.url}"/>
</sm:flows>
</sm:securedBroker>
</sm:broker>
−
<sm:executorFactory>
−
<bean class="org.apache.servicemix.executors.impl.ExecutorFactoryImpl">
−
<property name="defaultConfig">
−
<bean class="org.apache.servicemix.executors.impl.ExecutorConfig">
<property name="corePoolSize" value="${servicemix.corePoolSize}"/>
<property name="maximumPoolSize" value="${servicemix.maximumPoolSize}"/>
<property name="queueSize" value="${servicemix.queueSize}"/>
</bean>
</property>
</bean>
</sm:executorFactory>
−
<sm:services>
<sm:statistics statsInterval="10" dumpStats="true"/>
</sm:services>
</sm:container>
−
<audit:jdbcAuditor container="#jbi" autoStart="false">
−
<audit:dataSource>
−
<bean class="org.apache.derby.jdbc.EmbeddedDataSource">
<property name="databaseName" value="servicemixDB"/>
<property name="createDatabase" value="create"/>
</bean>
</audit:dataSource>
</audit:jdbcAuditor>
<sm:dotViewService container="#jbi" autoStart="true"/>
<sm:logService container="#jbi" autoStart="true" refreshPeriod="60"/>
</beans>

I've introduced persistent="true" in either to obtain the persistence of
message in the database.
My problem is that i don't receive messages in the consumer but they are
only saved in the db.

Where i wrong?

SECOND QUESTION
If i set persistence=true in the the jbi part in the servicemix.xml, in my
db i can see all message delivered by JBI WSN2005: notification and
subscription (i suppose). What is the way to change wsn2005 component to set
persistence=true in the notification message?

THANKS
MG 
-- 
View this message in context: http://servicemix.396122.n5.nabble.com/WSN2005-and-Activemq-for-message-persistence-tp3368012p3368012.html
Sent from the ServiceMix - User mailing list archive at Nabble.com.

Re: WSN2005 and Activemq for message persistence

[Jean-Baptiste Onofré <jb...@nanthrax.net>]

Hi TJ,

did you take a look on:
http://servicemix.apache.org/servicemix-wsn2005.html
?

Regards
JB

On 02/18/2011 01:34 PM, TJ wrote:
>
> Hi MQ,
>
> i need to prepare WS-NOTIFICATION using ServiceMix 4.2.0/Fuse 4.3.0.
>
> i can observe that you have achieved it using WSN2005. :)
>
> Can you please to please give steps to achieve it.
>
> i have a Producer and Consumer and External Service Providers. Producer can
> send message to consumer based on active Subscription.
>
> Please let me know if you need more information.
>
> Thanks for your time.
>
> TJ

Re: WSN2005 and Activemq for message persistence

[TJ <tj...@gmail.com>]

Hi MQ,

i need to prepare WS-NOTIFICATION using ServiceMix 4.2.0/Fuse 4.3.0. 

i can observe that you have achieved it using WSN2005. :)

Can you please to please give steps to achieve it. 

i have a Producer and Consumer and External Service Providers. Producer can
send message to consumer based on active Subscription.

Please let me know if you need more information.

Thanks for your time.

TJ
-- 
View this message in context: http://servicemix.396122.n5.nabble.com/WSN2005-and-Activemq-for-message-persistence-tp3368012p3391013.html
Sent from the ServiceMix - User mailing list archive at Nabble.com.