You should really have a look at the configuration i pointed
you to.
It creates an embedded broker and several connection
factories that
communicate with it : the only difference is that the broker
is not created
by the connection factory, but started on its own.

I'll try to take a look at the problem and see what happens.

Cheers,
Guillaume

---------- Initial Header -----------

From      : Daniel Wiell <[EMAIL PROTECTED]>
To          : [email protected]
Cc          : 
Date      : Tue, 27 Sep 2005 22:26:27 +0200
Subject : Re: [jencks-user]  Re:[jencks-user] Outbound JMS
and a MessageDriven POJO (Try 2)

Thanks for looking in to it!

Everything works perfect when the "useEmbeddedBroker" and  
"brokerXmlConfig" properties of the resource adapter are not
set -  
both sending and receiving messages works just fine.

If I use an embedded broker and just uncomment the
"testConnector" it  
works - only one instance of ActiveMQ  is started.

If I leave the "testConnector", and start removing
components on the  
"outbound" side:
"jmsTemplate", "jmsConnectionFactory", "connectionManager",  
"transactionManager" - not until the "userTransaction" is
removed, it  
starts working.

The plan was to keep the broker embedded, having two ActiveMQ  
connectors configured - one over the vm and one over tcp
(see the  
config below), so I'm quite eager to get it working. I don't
know,  
but I get the feeling there are some problems on the Jencks
side of  
things - but I'm really lost on how to fix it or even where
to start  
digging....

/Daniel


<beans>
     <broker>
         <connector>
             <serverTransport uri="vm://localhost"/>
         </connector>
         <connector>
             <tcpServerTransport uri="tcp://localhost:61616"  
backlog="1000" useAsyncSend="true"
                                 maxOutstandingMessages="50"/>
         </connector>
         <persistence>
             <vmPersistence/>
         </persistence>
     </broker>

</beans>


On 27 sep 2005, at 21.36, [EMAIL PROTECTED] wrote:

> Hi Daniel !
>
> I think the problem is due to the way you try to configure
> the activemq broker.
> I'm not an activemq expert, but i do know that the
> useEmbeddedBroker flag tells activemq
> to start a broker in the jvm (see
>
http://activemq.org/How+do+I+embed+a+Broker+inside+a+Connection).
> But I do not know why in your config, two brokers try to
> start.
>
> There are working config like yours in jencks cvs (take a
> look at
>
http://cvs.jencks.codehaus.org/jencks/src/test/resources/org/jencks/

> spring-request-reply-jta.xml?rev=1.2&view=auto).
>
> Btw, are you experiencing any problems when the two lines
> are commented ? Maybe no broker is started ?
>
> Cheers,
> Guillaume Nodet
>
> ---------- Initial Header -----------
>
> From      : Daniel Wiell <[EMAIL PROTECTED]>
> To          : [email protected]
> Cc          :
> Date      : Tue, 27 Sep 2005 18:42:32 +0200
> Subject : [jencks-user] Outbound JMS and a MessageDriven
> POJO (Try 2)
>
> It seems like I messed up my last message pretty serious, so
> I'll
> giving it another shot - sorry!
>
> I'm having some trouble setting up an outbound JMS and a
> MessageDriven
> POJO in the same context.
> Everything works like a charm until uncommenting the two
> lines in the
> resource adapter - all the sudden two instances of the
broker is
> started.
>
> I'm running Java 1.5.0_02, spring-framework-1.2.5,
> activemq-3.1 and jencks-1.0.
>
> Could anyone give an pointers on what's happening? I'm quite
> new to
> the whole JCA thing, so maybe I'm misunderstanding
something...
>
> Thanks!
> Daniel
>
>
> <!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN"
> "http://www.springframework.org/dtd/spring-beans.dtd";>
> <beans>
>
>     <!--
>           ###### Transaction manager ######
>     -->
>
>     <bean id="transactionContextManager"
>
class="org.jencks.factory.TransactionContextManagerFactoryBean"/>
>
>     <bean id="userTransaction"
>
class="org.jencks.factory.GeronimoTransactionManagerFactoryBean"/>
>
>     <bean id="transactionManager"
>
class="org.springframework.transaction.jta.JtaTransactionManager">
>         <property name="userTransaction"
ref="userTransaction"/>
>     </bean>
>
>     <!--
>           ###### JCA ######
>     -->
>
>     <bean id="connectionManager"
> class="org.jencks.factory.ConnectionManagerFactoryBean">
>         <property name="transactionSupport">
>             <bean
> class="org.jencks.factory.XATransactionFactoryBean">
>                 <property name="useTransactionCaching"
> value="true"/>
>                 <property name="useThreadCaching"
> value="false"/>
>             </bean>
>         </property>
>         <property name="poolingSupport">
>             <bean
> class="org.jencks.factory.SinglePoolFactoryBean">
>                 <property name="maxSize" value="2"/>
>                 <property name="minSize" value="1"/>
>                 <property name="blockingTimeoutMilliseconds"
> value="60"/>
>                 <property name="idleTimeoutMinutes"
value="60"/>
>                 <property name="matchOne" value="true"/>
>                 <property name="matchAll" value="true"/>
>                 <property name="selectOneAssumeMatch"
> value="true"/>
>             </bean>
>         </property>
>     </bean>
>
>     <bean id="bootstrapContext"
> class="org.jencks.factory.BootstrapContextFactoryBean">
>         <property name="threadPoolSize" value="25"/>
>     </bean>
>
>     <bean id="jcaContainer" class="org.jencks.JCAContainer">
>         <property name="bootstrapContext"
> ref="bootstrapContext"/>
>         <property name="resourceAdapter"
ref="resourceAdapter"/>
>     </bean>
>
>     <bean id="resourceAdapter"
> class="org.activemq.ra.ActiveMQResourceAdapter">
>         <property name="serverUrl" value="vm://localhost"/>
>         <!--<property name="useEmbeddedBroker"
value="true"/>-->
>         <!--<property name="brokerXmlConfig"
> value="classpath:test/activemq.xml"/>-->
>     </bean>
>
>     <!--
>           ###### JMS ######
>     -->
>
>     <bean id="jmsConnectionFactory"
>
class="org.springframework.jca.support.LocalConnectionFactoryBean">
>         <property name="managedConnectionFactory">
>             <bean
> class="org.activemq.ra.ActiveMQManagedConnectionFactory">
>                 <property name="resourceAdapter"
> ref="resourceAdapter"/>
>             </bean>
>         </property>
>         <property name="connectionManager"
> ref="connectionManager"/>
>     </bean>
>
>     <bean id="jmsTemplate"
> class="org.springframework.jms.core.JmsTemplate">
>         <property name="connectionFactory"
> ref="jmsConnectionFactory"/>
>         <property name="pubSubDomain" value="false"/>
>     </bean>
>
>     <bean id="testConnector" factory-method="addConnector"
> factory-bean="jcaContainer">
>         <property name="activationSpec">
>             <bean
> class="org.activemq.ra.ActiveMQActivationSpec">
>                 <property name="destination"
> value="broker.jencks-test"/>
>                 <property name="destinationType"
> value="javax.jms.Queue"/>
>                 <property name="resourceAdapter"
> ref="resourceAdapter"/>
>             </bean>
>         </property>
>         <property name="ref" value="testReceiver"/>
>     </bean>
>
>     <bean id="testReceiver"
class="test.TestJmsMessageListener"
> singleton="true"/>
>
> </beans>
>
>
> 2005-09-25 18:29:10,507 [main           ] INFO
> SpringBrokerContainerFactory                       - Loading
> ActiveMQ
> broker from configuration: class path resource
> [test/activemq.xml]
> 2005-09-25 18:29:10,529 [main           ] INFO
> ActiveMQBeanDefinitionReader                       - Loading
> XML bean
> definitions from class path resource [test/activemq.xml]
> 2005-09-25 18:29:17,303 [main           ] INFO
> BrokerContainerImpl
>                             - ActiveMQ 3.1 JMS Message Broker
> (ID:Mini.local-57361-1127665750379-0:0) is starting
> 2005-09-25 18:29:17,304 [main           ] INFO
> BrokerContainerImpl
>                             - For help or more information
> please see:
> http://www.logicblaze.com
> 2005-09-25 18:29:17,599 [main           ] INFO
> VmTransportServerChannel                           -
> Listening for
> connections at: vm://localhost
> 2005-09-25 18:29:17,600 [main           ] INFO
> BrokerConnectorImpl
>                             - ActiveMQ connector started:
> [EMAIL PROTECTED]://localhost
> 2005-09-25 18:29:17,600 [main           ] INFO
> TcpTransportServerChannel                          -
> Listening for
> connections at: tcp://Mini.local:61616
> 2005-09-25 18:29:17,602 [main           ] INFO
> BrokerConnectorImpl
>                             - ActiveMQ connector started:
> [EMAIL PROTECTED]://Mini.local:61616
> 2005-09-25 18:29:17,602 [main           ] INFO
> BrokerContainerImpl
>                             - ActiveMQ JMS Message Broker
> (ID:Mini.local-57361-1127665750379-0:0) has started
> 2005-09-25 18:29:17,679 [main           ] INFO
> SpringBrokerContainerFactory                       - Loading
> ActiveMQ
> broker from configuration: class path resource
> [test/activemq.xml]
> 2005-09-25 18:29:17,687 [main           ] INFO
> ActiveMQBeanDefinitionReader                       - Loading
> XML bean
> definitions from class path resource [test/activemq.xml]
> java.net.BindException: Address already in use
>
>
> ------------ ALICE HAUT DEBIT A 29,95 EUR/MOIS ------------
> ALICEBOX, l'offre Internet tout en 1 : ADSL, téléphonie,
modem Wi- 
> Fi et en exclusivité
> la hotline gratuite 24h/24 ! Soumis à conditions. Pour en
profiter  
> cliquez ici http://abonnement.aliceadsl.fr
>
>
>



------------ ALICE HAUT DEBIT A 29,95 EUR/MOIS ------------
ALICEBOX, l'offre Internet tout en 1 : ADSL, téléphonie, modem Wi-Fi et en 
exclusivité
la hotline gratuite 24h/24 ! Soumis à conditions. Pour en profiter cliquez ici 
http://abonnement.aliceadsl.fr


Reply via email to