Return-Path: Delivered-To: apmail-geronimo-activemq-users-archive@www.apache.org Received: (qmail 39035 invoked from network); 20 Nov 2006 06:58:17 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 20 Nov 2006 06:58:17 -0000 Received: (qmail 33606 invoked by uid 500); 20 Nov 2006 06:58:25 -0000 Delivered-To: apmail-geronimo-activemq-users-archive@geronimo.apache.org Received: (qmail 33409 invoked by uid 500); 20 Nov 2006 06:58:25 -0000 Mailing-List: contact activemq-users-help@geronimo.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: activemq-users@geronimo.apache.org Delivered-To: mailing list activemq-users@geronimo.apache.org Received: (qmail 33400 invoked by uid 99); 20 Nov 2006 06:58:25 -0000 Received: from herse.apache.org (HELO herse.apache.org) (140.211.11.133) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 19 Nov 2006 22:58:25 -0800 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 (herse.apache.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; Sun, 19 Nov 2006 22:58:11 -0800 Received: from [72.21.53.38] (helo=jubjub.nabble.com) by talk.nabble.com with esmtp (Exim 4.50) id 1Gm36F-0001af-08 for activemq-users@geronimo.apache.org; Sun, 19 Nov 2006 22:57:51 -0800 Message-ID: <7437938.post@talk.nabble.com> Date: Sun, 19 Nov 2006 22:57:50 -0800 (PST) From: samahome To: activemq-users@geronimo.apache.org Subject: Re: Need help in understanding Broker Process communication classes in ActiveMQ source code In-Reply-To: <7435888.post@talk.nabble.com> MIME-Version: 1.0 Content-Type: text/plain; charset=us-ascii Content-Transfer-Encoding: 7bit X-Nabble-From: sreenivas.sama@boeing.com References: <7413963.post@talk.nabble.com> <7435888.post@talk.nabble.com> X-Virus-Checked: Checked by ClamAV on apache.org Thanks Marlon for the reply. I am looking in the activeMQ/broker source directory for the class(es) which contains the code for the functionality where the broker reads from the transport layer and writes back to the transport layer for subscribers consumption. I could not find the specific classes and have difficulty in constituting the end-to-end message flow once the messages are handed off to tcp transport layer by the producer. I would greatly appreciate if i can get help in the names of specific classes for the above functionality. - Sreenivas Marlon Santos wrote: > > Hi, > > You can start to look at the source files in this directory, > activemq-core\src\main\java\org\apache\activemq\broker, which is inside > your activemq directory... > > Regards, > Marlon > > > > samahome wrote: >> >> Could some one explain me the classes in ActiveMQ source which enqueues >> and dequeues the messages. I am particularly interested in the classes >> specific to the broker process. >> >> Once the producer client hands off the messages to TCP transport layer, >> how the broker puts in to different lists based on each topic and each >> priority. Which source classes in ActiveMQ i should look at to get more >> understanding. >> >> - Sreenivas >> > > -- View this message in context: http://www.nabble.com/Need-help-in-understanding-Broker-Process-communication-classes--in-ActiveMQ-source-code-tf2657900.html#a7437938 Sent from the ActiveMQ - User mailing list archive at Nabble.com.