You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@activemq.apache.org by samahome <sr...@boeing.com> on 2006/11/18 02:14:41 UTC

Need help in understanding Broker Process communication classes in ActiveMQ source code

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#a7413963
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Need help in understanding Broker Process communication classes in ActiveMQ source code

Posted by Hiram Chirino <hi...@hiramchirino.com>.

Hi..

best bet to learn the flow is to run the broker under a debugger and
step though a message send action.  I would break point the
processMessage() method in the TransportConnection class.

On 11/20/06, samahome <sr...@boeing.com> wrote:
>
> 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.
>
>


-- 
Regards,
Hiram

Blog: http://hiramchirino.com

Re: Need help in understanding Broker Process communication classes in ActiveMQ source code

Posted by samahome <sr...@boeing.com>.

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.

Re: Need help in understanding Broker Process communication classes in ActiveMQ source code

Posted by Marlon Santos <ms...@exist.com>.

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#a7435888
Sent from the ActiveMQ - User mailing list archive at Nabble.com.