Return-Path: Delivered-To: apmail-activemq-dev-archive@www.apache.org Received: (qmail 11755 invoked from network); 16 Apr 2007 12:57:58 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 16 Apr 2007 12:57:58 -0000 Received: (qmail 42182 invoked by uid 500); 16 Apr 2007 12:58:04 -0000 Delivered-To: apmail-activemq-dev-archive@activemq.apache.org Received: (qmail 42162 invoked by uid 500); 16 Apr 2007 12:58:03 -0000 Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list dev@activemq.apache.org Received: (qmail 42149 invoked by uid 99); 16 Apr 2007 12:58:03 -0000 Received: from herse.apache.org (HELO herse.apache.org) (140.211.11.133) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 16 Apr 2007 05:58:03 -0700 X-ASF-Spam-Status: No, hits=-100.0 required=10.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO brutus.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 16 Apr 2007 05:57:57 -0700 Received: from brutus (localhost [127.0.0.1]) by brutus.apache.org (Postfix) with ESMTP id D03FA714081 for ; Mon, 16 Apr 2007 05:57:35 -0700 (PDT) Message-ID: <19444711.1176728255849.JavaMail.jira@brutus> Date: Mon, 16 Apr 2007 05:57:35 -0700 (PDT) From: "Manuel Teira (JIRA)" To: dev@activemq.apache.org Subject: [jira] Commented: (AMQ-895) JMS to JMS Bridge never reconnects under remote broker restarts. MIME-Version: 1.0 Content-Type: text/plain; charset=ISO-8859-1 Content-Transfer-Encoding: 7bit X-Virus-Checked: Checked by ClamAV on apache.org [ https://issues.apache.org/activemq/browse/AMQ-895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#action_39009 ] Manuel Teira commented on AMQ-895: ---------------------------------- I think you don't need to wrap STCQueueConnectionFactory, as it provides a constructor with the required arguments, and spring is able to handle that directly. That is not the case for imq, that doesn't have such a constructor neither the required setters. It should be enough for you to use: localhost 18007 About the error you get, it seems you're trying to handle directly a STC message implementation using AMQ. That's not the right way. The bridge should automatically convert incoming messages to the AMQ native types. You shouldn't need to use directly the STC nor AMQ Message classes, just ask for java.jmx.Message or javax.jms.TextMessage to your consumers. The AMQ broker will redirect incoming messages from the bridged foreign broker to your program, and they will internally be AMQ* types, but you shouln't need to be aware of that. > JMS to JMS Bridge never reconnects under remote broker restarts. > ---------------------------------------------------------------- > > Key: AMQ-895 > URL: https://issues.apache.org/activemq/browse/AMQ-895 > Project: ActiveMQ > Issue Type: Bug > Components: Broker > Affects Versions: 4.0 RC2, 4.0.1 > Reporter: Manuel Teira > Attachments: test_patch.diff > > > I'm using ActiveMQ (4.0.1) JMS to JMS Bridge functionality to connect to a SunMQ JMS Broker (3.6 SP3 (Build 02-A)). I'm using two queues, an input and an output one, with the following configuration: > > > > > > > > > > > The system works really well until the SunMQ broker needed to be restarted. This is what I found: > 1.-ActiveMQ is not aware of the remote broker shutdown. I waited for a while, but no log on ActiveMQ indicates knowledge about the new situation. > 2.-When I send a message to the output queue SUNRECV, ActiveMQ complains that the producer is closed: > [ERROR][2006/08/25.09:47:12.039][ActiveMQ Session Task]failed to forward message: ActiveMQTextMessage {commandId = 5, responseRequired = false, messageId = ID:trabucco-43457-1156491843149-3:4:1:1:1, originalDestination = null, originalTransactionId = null, producerId = ID:trabucco-43457-1156491843149-3:4:1:1, destination = queue://SUNRECV, transactionId = null, expiration = 0, timestamp = 1156492032027, arrival = 0, correlationId = null, replyTo = null, persistent = false, type = null, priority = 0, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = null, marshalledProperties = null, dataStructure = null, redeliveryCounter = 0, size = 2, properties = null, readOnlyProperties = true, readOnlyBody = true, text = 1}([C4064]: Cannot perform operation, producer is closed.) > After this, it is automatically queueing messages without sending them, showing the log: > [DEBUG][2006/08/25.09:47:42.721][RMI TCP Connection(4)-10.95.89.20]No subscriptions registered, will not dispatch message at this time. > Even if SunMQ is started again, ActiveMQ is not detecting the new situation, and continues queueing messages sent to SUNRECV. > Please, make me know if more information is needed to understand the situation. -- This message is automatically generated by JIRA. - You can reply to this email to add a comment to the issue online.