On Tue, Jun 10, 2008 at 9:29 PM, Marnie McCormack < [EMAIL PROTECTED]> wrote:
> Hi Lahiru, > > I think I understand what you mean - basically the queues you're seeing via > jConsole are those that are set up by default in the > virtualhosts.xml/config.xml that come with the broker install. > > These queues are examples, and thus don't have many distinguishing > characteristics like selectors etc (so they look like they're just > differentiated by virtualhost). They also won't have consumers or messages > I > assume ? > Hopefully I was able to run samples in the directory qpid-1.0-incubating-M2-src/java/client/example/src/main/java using runSample.sh file. Is this the correct location..? Is that what you want me to do. If it is the thing could you please tell me how should I monitor those queues. Do I have to use jconsole or any other way to monitor those information. Regards Lahiru > > So, I think to get a real feel for the kind of data you'll see typically > you > possibly need to set up a client app to use the queues in a 'real life' way > ? This would mean publishing to them, consuming from them etc. > > What do you think - does thistalk to your question ? > > Thanks & Regards, > Marnie > > On 6/9/08, lahiru gunathilake <[EMAIL PROTECTED]> wrote: > > > > Hi marnie, > > > > Now I'm in a position of directly implementing list and info commands. > > First > > doing list command. I'm managing to do this as follows. > > > > list -o <object name> > > Ex: list -o queue > > > > I'm going to implement all the command using standard way which is like > for > > any command user can give options with a "minus""option letter" <option > > value> > > > > In here for all the queue objects there are number of properties so in > your > > example you are telling like > > queue-1 > > queue-2 > > queue-3 > > > > but more specifically what do you want to list. When I monitor using > > jconsole there were three different queues those three differ only from > > ObjectName all the other properties are same like ClassName / > Discription. > > In OjbectName there are few parts and from them VirtualHost is the only > one > > which differ. > > It's like this > > VirtualHost=development > > VirtualHost=localhost > > VirtualHost=test > > > > So when I list all the queues is it ok if I list those queue names like > > this(listing those using VirtualHost attribute) > > > > development > > localhost > > test > > > > If you can't understand my problem let me know I can explain it with more > > details. > > > > Thanks in advance > > > > > > Regards > > Lahiru > > > > On Thu, May 15, 2008 at 9:59 PM, Marnie McCormack < > > [EMAIL PROTECTED]> wrote: > > > > > Hi Lahiru, > > > > > > Martin & Aidan & I are just discussing your project and here are some > of > > > our > > > thoughts: > > > > > > - so we need a command line with options. Aidan suggests it looks like > > > this: > > > > > > > > > I was thinking something like > > > > > > $ qpid-admin --list-queues > > > queue-1 > > > queue-2 > > > queue-3 > > > > > > $ qpid-admin --queue-info queue-1 > > > Depth: 1 Count: 1 Subscribers: 0 > > > > > > $ qpid-admin --queue-info --depth queue-1 > > > 1 > > > > > > for timed reports for alerting you could put that in cron, or use > > > watch for top/vmstat-esque action. I think it's probably a more > > > natural interface than editing a properties file and would be > > > something that we could apply to the C++ broker as well, which would > > > be nice. Plus, it's quite UNIXy and lets people leverage things like > > > awk. > > > > > > > > > - I'd also like it to be configurable using a properties file, but it's > > > probably worth getting list views on this for consensus > > > > > > - I think you're mainly on the right track, but I'd focus more on the > > > useful attributes we expose rather than all variables of the objects > > > > > > Rgds, > > > Marnie > > > > > > On 5/14/08, lahiru gunathilake <[EMAIL PROTECTED]> wrote: > > > > > > > Hi all, > > > > Now I'm writing this output in to a file and this is running like a > > > > thread(daemon) and it write different files time to time as Aiden > > > discussed > > > > with me.When I run the program it monitor the broker time to time > (time > > > > interval can be configured). > > > > > > > > Honestly this is not the actual code I'm developing I'm just writing > > some > > > > sample code to test and informing you what I'm doing and expecting a > > feed > > > > from you. > > > > > > > > Thanks in advance > > > > > > > > Regards > > > > lahiru > > > > > > > > On Sun, May 11, 2008 at 9:00 AM, lahiru gunathilake < > [EMAIL PROTECTED] > > > > > > > wrote: > > > > > > > > > Hi Aiden, > > > > > > > > > > First thanks a lot for your reply I was waiting for a reply for few > > > days > > > > > hopefully. > > > > > I did some modification to my program and I'm listing all the > > > attributes > > > > of > > > > > all the mbeans which is having org.apache.qpid domain. > > > > > Here's the output of my program....(I'm printing the attribute name > > and > > > > > value and type in a single line and for now I haven't done any > > > > formattings > > > > > with the output. > > > > > > > > > ======================================================================== > > > > > Press <Enter> to continue... > > > > > > > > > > TOTAL MBEAN COUNT: 46 > > > > > > > > > > DOMAINS: > > > > > Domain[0] = JMImplementation > > > > > Domain[1] = com.sun.management > > > > > Domain[2] = org.apache.qpid > > > > > Domain[3] = java.lang > > > > > Domain[4] = java.util.logging > > > > > ALL THE EXPOSED CLASSES > > > > > 29 > > > > > > > ======================================================================= > > > > > > > > > > > > > > > > > > > > org.apache.qpid:type=VirtualHost.Exchange,VirtualHost=localhost,name=amq.direct,ExchangeType=direct > > > > > > > ======================================================================= > > > > > Name amq.direct java.lang.String > > > > > Durable true boolean > > > > > AutoDelete false boolean > > > > > ExchangeType direct java.lang.String > > > > > TicketNo 0 java.lang.Integer > > > > > > > ======================================================================= > > > > > org.apache.qpid:type=VirtualHost.Queue,VirtualHost=test,name=ping > > > > > > > ======================================================================= > > > > > Name ping java.lang.String > > > > > Owner null java.lang.String > > > > > Durable false boolean > > > > > AutoDelete false boolean > > > > > MessageCount 0 java.lang.Integer > > > > > QueueDepth 0 java.lang.Long > > > > > MaximumMessageSize 2117632 java.lang.Long > > > > > ConsumerCount 0 java.lang.Integer > > > > > ActiveConsumerCount 0 java.lang.Integer > > > > > ReceivedMessageCount 0 java.lang.Long > > > > > MaximumMessageCount 5000 java.lang.Long > > > > > MaximumQueueDepth 4136 java.lang.Long > > > > > MaximumMessageAge 600000 java.lang.Long > > > > > > > ======================================================================= > > > > > org.apache.qpid:type=VirtualHost.Queue,VirtualHost=test,name=queue > > > > > > > ======================================================================= > > > > > Name queue java.lang.String > > > > > Owner null java.lang.String > > > > > Durable false boolean > > > > > AutoDelete false boolean > > > > > MessageCount 0 java.lang.Integer > > > > > QueueDepth 0 java.lang.Long > > > > > MaximumMessageSize 2117632 java.lang.Long > > > > > ConsumerCount 0 java.lang.Integer > > > > > ActiveConsumerCount 0 java.lang.Integer > > > > > ReceivedMessageCount 0 java.lang.Long > > > > > MaximumMessageCount 5000 java.lang.Long > > > > > MaximumQueueDepth 4136 java.lang.Long > > > > > MaximumMessageAge 600000 java.lang.Long > > > > > > > ======================================================================= > > > > > > > > > > > > > > > > > > > > org.apache.qpid:type=VirtualHost.Exchange,VirtualHost=test,name=amq.match,ExchangeType=headers > > > > > > > ======================================================================= > > > > > Name amq.match java.lang.String > > > > > Durable true boolean > > > > > AutoDelete false boolean > > > > > ExchangeType headers java.lang.String > > > > > TicketNo 0 java.lang.Integer > > > > > > > ======================================================================= > > > > > > > > > org.apache.qpid:type=VirtualHost.Queue,VirtualHost=development,name=queue > > > > > > > ======================================================================= > > > > > Name queue java.lang.String > > > > > Owner null java.lang.String > > > > > Durable false boolean > > > > > AutoDelete false boolean > > > > > MessageCount 0 java.lang.Integer > > > > > QueueDepth 0 java.lang.Long > > > > > MaximumMessageSize 2117632 java.lang.Long > > > > > ConsumerCount 0 java.lang.Integer > > > > > ActiveConsumerCount 0 java.lang.Integer > > > > > ReceivedMessageCount 0 java.lang.Long > > > > > MaximumMessageCount 5000 java.lang.Long > > > > > MaximumQueueDepth 4136 java.lang.Long > > > > > MaximumMessageAge 600000 java.lang.Long > > > > > > > ======================================================================= > > > > > > > > > > > > > > > > > > > > org.apache.qpid:type=VirtualHost.Exchange,VirtualHost=test,name=amq.fanout,ExchangeType=fanout > > > > > > > ======================================================================= > > > > > Name amq.fanout java.lang.String > > > > > Durable true boolean > > > > > AutoDelete false boolean > > > > > ExchangeType fanout java.lang.String > > > > > TicketNo 0 java.lang.Integer > > > > > > > ======================================================================= > > > > > > > > > > > > > > > > > > > > org.apache.qpid:type=VirtualHost.Exchange,VirtualHost=development,name=<<default>>,ExchangeType=direct > > > > > > > ======================================================================= > > > > > Name <<default>> java.lang.String > > > > > Durable true boolean > > > > > AutoDelete false boolean > > > > > ExchangeType direct java.lang.String > > > > > TicketNo 0 java.lang.Integer > > > > > > > ======================================================================= > > > > > > > > > > > > > > > > > > > > org.apache.qpid:type=VirtualHost.Exchange,VirtualHost=localhost,name=amq.match,ExchangeType=headers > > > > > > > ======================================================================= > > > > > Name amq.match java.lang.String > > > > > Durable true boolean > > > > > AutoDelete false boolean > > > > > ExchangeType headers java.lang.String > > > > > TicketNo 0 java.lang.Integer > > > > > > > ======================================================================= > > > > > > > > > > > > > > > > > > > > org.apache.qpid:type=VirtualHost.Exchange,VirtualHost=test,name=amq.topic,ExchangeType=topic > > > > > > > ======================================================================= > > > > > Name amq.topic java.lang.String > > > > > Durable true boolean > > > > > AutoDelete false boolean > > > > > ExchangeType topic java.lang.String > > > > > TicketNo 0 java.lang.Integer > > > > > > > ======================================================================= > > > > > > org.apache.qpid:type=VirtualHost.VirtualHostManager,VirtualHost=test > > > > > > > ======================================================================= > > > > > > > ======================================================================= > > > > > > > > > > > > > > > > > > > > org.apache.qpid:type=VirtualHost.Exchange,VirtualHost=localhost,name=test.topic,ExchangeType=direct > > > > > > > ======================================================================= > > > > > Name test.topic java.lang.String > > > > > Durable false boolean > > > > > AutoDelete false boolean > > > > > ExchangeType direct java.lang.String > > > > > TicketNo 0 java.lang.Integer > > > > > > > ======================================================================= > > > > > > > > > > > > > > > > > > > > org.apache.qpid:type=VirtualHost.Exchange,VirtualHost=development,name=amq.direct,ExchangeType=direct > > > > > > > ======================================================================= > > > > > Name amq.direct java.lang.String > > > > > Durable true boolean > > > > > AutoDelete false boolean > > > > > ExchangeType direct java.lang.String > > > > > TicketNo 0 java.lang.Integer > > > > > > > ======================================================================= > > > > > > > > > > > > > > > > > > > > org.apache.qpid:type=VirtualHost.Exchange,VirtualHost=localhost,name=amq.topic,ExchangeType=topic > > > > > > > ======================================================================= > > > > > Name amq.topic java.lang.String > > > > > Durable true boolean > > > > > AutoDelete false boolean > > > > > ExchangeType topic java.lang.String > > > > > TicketNo 0 java.lang.Integer > > > > > > > ======================================================================= > > > > > org.apache.qpid:type=UserManagement,name=UserManagement > > > > > > > ======================================================================= > > > > > > > ======================================================================= > > > > > > > > > > > > > > > > > > > > org.apache.qpid:type=VirtualHost.Exchange,VirtualHost=development,name=amq.topic,ExchangeType=topic > > > > > > > ======================================================================= > > > > > Name amq.topic java.lang.String > > > > > Durable true boolean > > > > > AutoDelete false boolean > > > > > ExchangeType topic java.lang.String > > > > > TicketNo 0 java.lang.Integer > > > > > > > ======================================================================= > > > > > > > org.apache.qpid:type=VirtualHost.Queue,VirtualHost=localhost,name=ping > > > > > > > ======================================================================= > > > > > Name ping java.lang.String > > > > > Owner null java.lang.String > > > > > Durable false boolean > > > > > AutoDelete false boolean > > > > > MessageCount 0 java.lang.Integer > > > > > QueueDepth 0 java.lang.Long > > > > > MaximumMessageSize 2117632 java.lang.Long > > > > > ConsumerCount 0 java.lang.Integer > > > > > ActiveConsumerCount 0 java.lang.Integer > > > > > ReceivedMessageCount 0 java.lang.Long > > > > > MaximumMessageCount 0 java.lang.Long > > > > > MaximumQueueDepth 4136 java.lang.Long > > > > > MaximumMessageAge 600000 java.lang.Long > > > > > > > ======================================================================= > > > > > > > > > > > > > > > > > > > > org.apache.qpid:type=VirtualHost.Exchange,VirtualHost=localhost,name=<<default>>,ExchangeType=direct > > > > > > > ======================================================================= > > > > > Name <<default>> java.lang.String > > > > > Durable true boolean > > > > > AutoDelete false boolean > > > > > ExchangeType direct java.lang.String > > > > > TicketNo 0 java.lang.Integer > > > > > > > ======================================================================= > > > > > > > > > > > > > > > > > > > > org.apache.qpid:type=VirtualHost.Exchange,VirtualHost=development,name=amq.fanout,ExchangeType=fanout > > > > > > > ======================================================================= > > > > > Name amq.fanout java.lang.String > > > > > Durable true boolean > > > > > AutoDelete false boolean > > > > > ExchangeType fanout java.lang.String > > > > > TicketNo 0 java.lang.Integer > > > > > > > ======================================================================= > > > > > > > > > > > > > > > org.apache.qpid:type=VirtualHost.VirtualHostManager,VirtualHost=development > > > > > > > ======================================================================= > > > > > > > ======================================================================= > > > > > > > > > > > > > > > > > > > > org.apache.qpid:type=VirtualHost.Queue,VirtualHost=localhost,name=test-queue > > > > > > > ======================================================================= > > > > > Name test-queue java.lang.String > > > > > Owner null java.lang.String > > > > > Durable true boolean > > > > > AutoDelete false boolean > > > > > MessageCount 0 java.lang.Integer > > > > > QueueDepth 0 java.lang.Long > > > > > MaximumMessageSize 2117632 java.lang.Long > > > > > ConsumerCount 0 java.lang.Integer > > > > > ActiveConsumerCount 0 java.lang.Integer > > > > > ReceivedMessageCount 0 java.lang.Long > > > > > MaximumMessageCount 0 java.lang.Long > > > > > MaximumQueueDepth 4136 java.lang.Long > > > > > MaximumMessageAge 600000 java.lang.Long > > > > > > > ======================================================================= > > > > > > > > > org.apache.qpid:type=VirtualHost.VirtualHostManager,VirtualHost=localhost > > > > > > > ======================================================================= > > > > > > > ======================================================================= > > > > > > > org.apache.qpid:type=VirtualHost.Queue,VirtualHost=localhost,name=queue > > > > > > > ======================================================================= > > > > > Name queue java.lang.String > > > > > Owner null java.lang.String > > > > > Durable false boolean > > > > > AutoDelete false boolean > > > > > MessageCount 0 java.lang.Integer > > > > > QueueDepth 0 java.lang.Long > > > > > MaximumMessageSize 2117632 java.lang.Long > > > > > ConsumerCount 0 java.lang.Integer > > > > > ActiveConsumerCount 0 java.lang.Integer > > > > > ReceivedMessageCount 0 java.lang.Long > > > > > MaximumMessageCount 0 java.lang.Long > > > > > MaximumQueueDepth 4136 java.lang.Long > > > > > MaximumMessageAge 600000 java.lang.Long > > > > > > > ======================================================================= > > > > > > > > > > > > > > > > > > > > org.apache.qpid:type=VirtualHost.Exchange,VirtualHost=test,name=amq.direct,ExchangeType=direct > > > > > > > ======================================================================= > > > > > Name amq.direct java.lang.String > > > > > Durable true boolean > > > > > AutoDelete false boolean > > > > > ExchangeType direct java.lang.String > > > > > TicketNo 0 java.lang.Integer > > > > > > > ======================================================================= > > > > > > > > > > > > > > > org.apache.qpid:type=VirtualHost.Queue,VirtualHost=localhost,name=test-ping > > > > > > > ======================================================================= > > > > > Name test-ping java.lang.String > > > > > Owner null java.lang.String > > > > > Durable false boolean > > > > > AutoDelete false boolean > > > > > MessageCount 0 java.lang.Integer > > > > > QueueDepth 0 java.lang.Long > > > > > MaximumMessageSize 2117632 java.lang.Long > > > > > ConsumerCount 0 java.lang.Integer > > > > > ActiveConsumerCount 0 java.lang.Integer > > > > > ReceivedMessageCount 0 java.lang.Long > > > > > MaximumMessageCount 0 java.lang.Long > > > > > MaximumQueueDepth 4136 java.lang.Long > > > > > MaximumMessageAge 600000 java.lang.Long > > > > > > > ======================================================================= > > > > > > > > > > > > > > > > > > > > org.apache.qpid:type=VirtualHost.Exchange,VirtualHost=test,name=<<default>>,ExchangeType=direct > > > > > > > ======================================================================= > > > > > Name <<default>> java.lang.String > > > > > Durable true boolean > > > > > AutoDelete false boolean > > > > > ExchangeType direct java.lang.String > > > > > TicketNo 0 java.lang.Integer > > > > > > > ======================================================================= > > > > > > > > > > > > > > > > > > > > org.apache.qpid:type=VirtualHost.Exchange,VirtualHost=localhost,name=amq.fanout,ExchangeType=fanout > > > > > > > ======================================================================= > > > > > Name amq.fanout java.lang.String > > > > > Durable true boolean > > > > > AutoDelete false boolean > > > > > ExchangeType fanout java.lang.String > > > > > TicketNo 0 java.lang.Integer > > > > > > > ======================================================================= > > > > > > > > > > > > > > > > > > > > org.apache.qpid:type=VirtualHost.Exchange,VirtualHost=development,name=amq.match,ExchangeType=headers > > > > > > > ======================================================================= > > > > > Name amq.match java.lang.String > > > > > Durable true boolean > > > > > AutoDelete false boolean > > > > > ExchangeType headers java.lang.String > > > > > TicketNo 0 java.lang.Integer > > > > > > > ======================================================================= > > > > > > > > > > > > > > > > > > > > org.apache.qpid:type=VirtualHost.Exchange,VirtualHost=localhost,name=test.direct,ExchangeType=direct > > > > > > > ======================================================================= > > > > > Name test.direct java.lang.String > > > > > Durable false boolean > > > > > AutoDelete false boolean > > > > > ExchangeType direct java.lang.String > > > > > TicketNo 0 java.lang.Integer > > > > > > > ======================================================================= > > > > > > > > > org.apache.qpid:type=VirtualHost.Queue,VirtualHost=development,name=ping > > > > > > > ======================================================================= > > > > > Name ping java.lang.String > > > > > Owner null java.lang.String > > > > > Durable false boolean > > > > > AutoDelete false boolean > > > > > MessageCount 0 java.lang.Integer > > > > > QueueDepth 0 java.lang.Long > > > > > MaximumMessageSize 2117632 java.lang.Long > > > > > ConsumerCount 0 java.lang.Integer > > > > > ActiveConsumerCount 0 java.lang.Integer > > > > > ReceivedMessageCount 0 java.lang.Long > > > > > MaximumMessageCount 5000 java.lang.Long > > > > > MaximumQueueDepth 4136 java.lang.Long > > > > > MaximumMessageAge 600000 java.lang.Long > > > > > > > > > > Close the connection to the server > > > > > > > > > > Bye! Bye! > > > > > [EMAIL PROTECTED] > > > > :~/IdeaProjects/jmxpractice/classes/production/jmxpractice$ > > > > > > > > > > > > > > > > > > > ========================================================================= > > > > > On Fri, May 9, 2008 at 8:35 PM, Aidan Skinner <[EMAIL PROTECTED]> > > > wrote: > > > > > > > > > >> Hey Lahiru, > > > > >> > > > > >> the screenshot you sent was stripped by the mailing list, as it's > a > > > > >> command line it's probably best just to copy and paste the output > > into > > > > >> an email anyway. > > > > >> > > > > >> As for a next step, probably something quick like listing all the > > > > >> queues or the count on a specified queue. > > > > > > > > > > I think I have done what you are asking but I'm not sure if I'm > wrong > > > > > please let me know. > > > > > Could you please explain it some more and however I will try to > > > > understand > > > > > what you meant by that sentence. > > > > > > > > > > Thanks in advance > > > > > > > > > > > > > > > Regs > > > > > lahiru > > > > > > > > > > > > > > > > > > > > > -- > > > > East or West > > > > Mahindians are the > > > > Best... ! > > > > > > > > > > > > > > > -- > > East or West > > Mahindians are the > > Best... ! > > > -- East or West Mahindians are the Best... !
