activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Rob Davies <rajdav...@gmail.com>
Subject Re: Store and Forward
Date Wed, 05 Apr 2006 19:18:37 GMT
can you say which version you are using ? - and if it's not  
activemq-4.0-RC2 - would you mind trying with that version - from  
here: http://cvs.apache.org/repository/incubator-activemq/distributions/
as it's the most stable at the moment.

cheers,

Rob

On 5 Apr 2006, at 19:13, Jim Ronan wrote:

>
> I'm using the example producer/consumer applications to configure a  
> scenario
> where I have multiple web applications which use a local broker to  
> route
> messages to a central server.  Should the central broker be down or
> unreachable, the web app brokers should store the messages locally and
> forward to the central server when it comes back up.
>
> I've configured my brokers as below:
>
> Central:
>     <beans xmlns="http://activemq.org/config/1.0">
>       <broker name="central" useJmx="true">
>         <persistenceAdapter>
>           <journaledJDBC journalLogFiles="5"
> dataDirectory="../activemq-central-data"/>
>         </persistenceAdapter>
>         <transportConnectors>
>            <transportConnector uri="tcp://localhost:61616"/>
>         </transportConnectors>
>       </broker>
>     </beans>
>
> Web App:
>     <beans xmlns="http://activemq.org/config/1.0">
>       <broker name="wf1" useJmx="false">
>         <persistenceAdapter>
>           <journaledJDBC journalLogFiles="5"
> dataDirectory="../activemq-data-wf"/>
>         </persistenceAdapter>
>         <transportConnectors>
>            <transportConnector uri="tcp://localhost:61617">
>         </transportConnectors>
>         <networkConnectors>
>           <networkConnector uri="static:failover:tcp://localhost: 
> 61616">
>           </networkConnector>
>         </networkConnectors>
>       </broker>
>     </beans>
>
> It kind of works, I can use the example producer program to submit  
> messages
> to the web app broker and the consumer program will pull them from the
> central broker.
>
> However, both the producer and consumer end with this message:
>
>    WARN  ActiveMQConnection - Cleanup failed   
> javax.jms.JMSException: Cannot
> write to the stream any more it has already been closed
>
> AND - if I restart the consumer it will pull the same messages from  
> the
> central broker.
>
> I've tried experimenting with durable and transacted settings in the
> consumer/producer build.xml.  I get different behavior, but not  
> what I want.
>
> Any suggestions?
>
> Thanks in advance - Jim Ronan
>
> --
> View this message in context: http://www.nabble.com/Store-and- 
> Forward-t1401236.html#a3770296
> Sent from the ActiveMQ - User forum at Nabble.com.
>


Mime
View raw message