From activemq-users-return-487-apmail-geronimo-activemq-users-archive=geronimo.apache.org@geronimo.apache.org Wed Apr 05 18:40:22 2006
Return-Path: <activemq-users-return-487-apmail-geronimo-activemq-users-archive=geronimo.apache.org@geronimo.apache.org>
Delivered-To: apmail-geronimo-activemq-users-archive@www.apache.org
Received: (qmail 45251 invoked from network); 5 Apr 2006 18:40:21 -0000
Received: from hermes.apache.org (HELO mail.apache.org) (209.237.227.199)
  by minotaur.apache.org with SMTP; 5 Apr 2006 18:40:21 -0000
Received: (qmail 59606 invoked by uid 500); 5 Apr 2006 18:40:20 -0000
Delivered-To: apmail-geronimo-activemq-users-archive@geronimo.apache.org
Received: (qmail 59589 invoked by uid 500); 5 Apr 2006 18:40:20 -0000
Mailing-List: contact activemq-users-help@geronimo.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:activemq-users-help@geronimo.apache.org>
List-Unsubscribe: <mailto:activemq-users-unsubscribe@geronimo.apache.org>
List-Post: <mailto:activemq-users@geronimo.apache.org>
List-Id: <activemq-users.geronimo.apache.org>
Reply-To: activemq-users@geronimo.apache.org
Delivered-To: mailing list activemq-users@geronimo.apache.org
Received: (qmail 59436 invoked by uid 99); 5 Apr 2006 18:40:20 -0000
Received: from asf.osuosl.org (HELO asf.osuosl.org) (140.211.166.49)
    by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 05 Apr 2006 11:40:19 -0700
X-ASF-Spam-Status: No, hits=-0.0 required=10.0
	tests=SPF_HELO_PASS,SPF_PASS
X-Spam-Check-By: apache.org
Received-SPF: pass (asf.osuosl.org: domain of lists@nabble.com designates 72.21.53.35 as permitted sender)
Received: from [72.21.53.35] (HELO talk.nabble.com) (72.21.53.35)
    by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 05 Apr 2006 11:40:19 -0700
Received: from localhost ([127.0.0.1] helo=talk.nabble.com)
	by talk.nabble.com with esmtp (Exim 4.50)
	id 1FRCv8-0000CQ-JV
	for activemq-users@geronimo.apache.org; Wed, 05 Apr 2006 11:39:58 -0700
Message-ID: <3770296.post@talk.nabble.com>
Date: Wed, 5 Apr 2006 11:13:20 -0700 (PDT)
From: Jim Ronan <jms@ronans.us>
To: activemq-users@geronimo.apache.org
Subject: Store and Forward
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit
X-Nabble-Sender: jms@ronans.us
X-Nabble-From: Jim Ronan <jms@ronans.us>
X-Virus-Checked: Checked by ClamAV on apache.org
X-Spam-Rating: minotaur.apache.org 1.6.2 0/1000/N


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.