Return-Path: Delivered-To: apmail-activemq-users-archive@www.apache.org Received: (qmail 50234 invoked from network); 29 Jul 2008 07:08:48 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 29 Jul 2008 07:08:48 -0000 Received: (qmail 15908 invoked by uid 500); 29 Jul 2008 07:08:46 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 15891 invoked by uid 500); 29 Jul 2008 07:08:46 -0000 Mailing-List: contact users-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@activemq.apache.org Delivered-To: mailing list users@activemq.apache.org Received: (qmail 15880 invoked by uid 99); 29 Jul 2008 07:08:46 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 29 Jul 2008 00:08:46 -0700 X-ASF-Spam-Status: No, hits=2.0 required=10.0 tests=HTML_MESSAGE,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of replyramdas@gmail.com designates 209.85.128.187 as permitted sender) Received: from [209.85.128.187] (HELO fk-out-0910.google.com) (209.85.128.187) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 29 Jul 2008 07:07:49 +0000 Received: by fk-out-0910.google.com with SMTP id z22so3653580fkz.6 for ; Tue, 29 Jul 2008 00:07:57 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=domainkey-signature:received:received:message-id:date:from:to :subject:in-reply-to:mime-version:content-type:references; bh=rGgA3hnPTGoVk3sEgHr5LDGnHiqvTmFyDeRhJh4lwiQ=; b=gjBe12xqgWiwJtAzuGe7oUa/rwFD7zKeeDjfb88GAGPLBpGGYIxE//Y7W23YIqHlEL DsvsInIuUyWN2k0xPuperqCvWMg/KoGEsbUKwOrZZD1VWLPsG7CmdlLdpvfZOpd8egaW GVtWl+2ATIL+6rWj7tx5HT/ntW7IPmh4nSI7I= DomainKey-Signature: a=rsa-sha1; c=nofws; d=gmail.com; s=gamma; h=message-id:date:from:to:subject:in-reply-to:mime-version :content-type:references; b=G5keF21OQKzqnuNLriHP6uQOfQceN8O5G4jrLjUqbQ3G0m9RSFjg0te1FqS1e5+lGz PlCNbuPp7LzD6AYibmiNf27piiNNWDFFKsrPQpe7ltDGscos2r/bgDINznXgLTWpkuqK 3pVTN1X2ln0XFOcfbD3btt8ebWXkU99GHJVQI= Received: by 10.187.237.12 with SMTP id o12mr113816far.56.1217315276860; Tue, 29 Jul 2008 00:07:56 -0700 (PDT) Received: by 10.187.162.20 with HTTP; Tue, 29 Jul 2008 00:07:56 -0700 (PDT) Message-ID: <634f15930807290007x77527b5cof36908fd2055a7ba@mail.gmail.com> Date: Tue, 29 Jul 2008 12:37:56 +0530 From: "Ramdas Sawant" To: users@activemq.apache.org Subject: Re: AMQ Message Store setting In-Reply-To: MIME-Version: 1.0 Content-Type: multipart/alternative; boundary="----=_Part_8350_27101427.1217315276853" References: <634f15930807272320v78ad8ec2r48f11262611f940a@mail.gmail.com> <634f15930807272335k3e4d312ej5146178e6e748b74@mail.gmail.com> <634f15930807280429i6d57ee39sc554293b6becb539@mail.gmail.com> <634f15930807280431u861c20p4192f4b2d09fdf4b@mail.gmail.com> <634f15930807282130q44842531x2a5d89b9387a016d@mail.gmail.com> X-Virus-Checked: Checked by ClamAV on apache.org ------=_Part_8350_27101427.1217315276853 Content-Type: text/plain; charset=ISO-8859-1 Content-Transfer-Encoding: 7bit Content-Disposition: inline Hi Rob, Thanks Rob for your reply. Below is the method i am using for generating messages /////////////////////////////////////////////////////////// *public* *void* startPublishing(String protocol, String host, String port)* throws* JMSException { hostString = protocol + "://" + host + ":" + port; System.*out*.println("Connecting to " + hostString); connectionFactory = *new* ActiveMQConnectionFactory(user, pwd, hostString); conn = (TopicConnection) connectionFactory.createTopicConnection(); tSession = conn.createTopicSession(*false*,javax.jms.Session.* AUTO_ACKNOWLEDGE*); String topicName = System.*getProperty*("topic", "IQBridge"); eventTopic = tSession.createTopic(topicName); //tSubscriber = tSession.createSubscriber(eventTopic); tPublisher = tSession.createPublisher(eventTopic); conn.start(); *int* i = 0; *boolean* b = *true*; *while*(b){ i++; //if(i==10) b= false; TextMessage m = tSession.createTextMessage(); m.setText("Pl. find attached the CX Events to IQ messages detail mapping i Pl. find attached the CX Events to IQ messages detail mapping i Pl. find attached the CX Events to IQ messages detail mapping i Pl. find attached the CX Events to IQ messages detail mapping i Pl. find attached the CX Events to IQ messages detail mapping i Pl. find attached the CX Events to IQ messages detail mapping i Pl. find attached the CX Events to IQ messages detail mapping i Pl. find attached the CX Events to IQ messages detail mapping i Pl. find attached the CX Events to IQ messages detail mapping i Pl. find attached the CX Events to IQ messages detail mapping i Pl. find attached the CX Events to IQ messages detail mapping i Pl. find attached the CX Events to IQ messages detail mapping i Pl. find attached the CX Events to IQ messages detail mapping i Pl. find attached the CX Events to IQ messages detail mapping i Pl. find attached the CX Events to IQ messages detail mapping i Pl. find attached the CX Events to IQ messages detail mapping i Pl. find attached the CX Events to IQ messages detail mapping i Pl. find attached the CX Events to IQ messages detail mapping i Pl. find attached the CX Events to IQ messages detail mapping i Pl. find attached the CX Events to IQ messages detail mapping i Pl. find attached the CX Events to IQ messages detail mapping i Pl. find attached the CX Events to IQ messages detail mapping i Pl. find attached the CX Events to IQ messages detail mapping i Pl. find attached the CX Events to IQ messages detail mapping i Pl. find attached the CX Events to IQ messages detail mapping i = "+i); *try* { System.*out*.println("trying to publish " + i); //m.setJMSExpiration(600000); tPublisher.publish(m,DeliveryMode.*PERSISTENT*,Message.*DEFAULT_PRIORITY* ,600000); System.*out*.println("Published " + i); } *catch* (Exception e) { b = *false*; System.*out*.println("\n i = " + i + "\n"); e.printStackTrace(); }*catch*(Throwable t ){ b = *false*; System.*out*.println("\nThrowabel i = " + i + "\n"); t.printStackTrace(); } } // tSubscriber.setMessageListener(listener); tSession.close(); tPublisher.close(); conn.stop(); conn.close(); } ///////////////////////////////////////////////////////////// I have already attached the activemq.xml of my broker in the current mail thread. What is happening is the data files of size 2mb are getting created as i have set the "maxFileLength" to 2mb. what i assumed/thought is due to setting of , only 2 data files should get generated as i have set the maxFileLength to 2 mb and my storage usage limit is 4 mb. Am i missing some thing here... i am not sure. Let me know if you need any more clarification. Thanks in advance. On 7/29/08, Rob Davies wrote: > > That name attribute IS confusing - it doesn't do anything - as the store > usage limit is broker wide - you don't need to use a name btw. > So with the limit set to 4mb - this hint is sent to the Message Store - but > only the default store - the AMQPersistence Adaptor will use it currently - > so its maximum size will be 4mb. > Maybe you can submit a test case - so we can better understand why the > store limit is working for your case ? > > cheers, > > Rob > > On 29 Jul 2008, at 05:30, Ramdas Sawant wrote: > > Guys, ant thoughts on this mail thread ??? I am really stuck and need some >> help here .... Waiting for inputs... Thanks in advance >> >> On 7/28/08, Ramdas Sawant wrote: >> >>> >>> What does signify ??? does the name >>> attribute should be the name of the Topic ??? Not clear on that... Thanks >>> >>> On 7/28/08, Ramdas Sawant wrote: >>> >>>> >>>> Hi Rob, >>>> I tried using the 5.2 snapshot, but still facing the same >>>> issue. Below is my activemq.xml >>>> /////////////////////////////////// >>>> >>>> >>> xmlns="http://www.springframework.org/schema/beans" >>>> xmlns:amq="http://activemq.apache.org/schema/core" >>>> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" >>>> xsi:schemaLocation="http://www.springframework.org/schema/beans >>>> http://www.springframework.org/schema/beans/spring-beans-2.0.xsd >>>> http://activemq.apache.org/schema/core >>>> http://activemq.apache.org/schema/core/activemq-core.xsd >>>> http://activemq.apache.org/camel/schema/spring >>>> http://activemq.apache.org/camel/schema/spring/camel-spring.xsd"> >>>> >>>> >>> >>>> class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/> >>>> >>>> >>> brokerName="localhost" dataDirectory="${activemq.base}/data"> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>> uri="multicast://default"/> >>>> >>>> >>>> >>>> >>> directory="${activemq.base}/data" maxFileLength="2 mb" >>>> maxReferenceFileLength="1mb"/> >>>> >>>> >>>> >>>> >>> keyStorePassword="password" >>>> trustStore="file:${activemq.base}/conf/broker.ts" >>>> trustStorePassword="password"/> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>> uri="tcp://localhost:61616" discoveryUri="multicast://default"/> >>>> >>>> >>> uri="stomp://localhost:61613"/> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> org.foo.bar >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>>> >>> resourceBase="${activemq.base}/webapps/admin" logUrlOnStart="true"/> >>>> >>> resourceBase="${activemq.base}/webapps/demo" logUrlOnStart="true"/> >>>> >>> resourceBase="${activemq.base}/webapps/fileserver" >>>> logUrlOnStart="true"/> >>>> >>>> >>>> >>>> >>>> /////////////////////////////////////////////////////// >>>> >>>> I tried setting both "maxFileLength" and ">>> still facing the same issue. My topic is accepting more messages and the >>>> broker is creating more data files. It is creating datafiles of the size >>>> specified in the "maxFileLength" attribute. Please help me out with >>>> issue. >>>> Let me know if you neeed any more clarification. Thanks in advance. >>>> >>>> regards >>>> Ramdas >>>> >>>> On 7/28/08, Ramdas Sawant wrote: >>>> >>>>> >>>>> Thanks a lot Rob, will get back to you after testing, in case i need >>>>> any >>>>> help. Thanks >>>>> >>>>> regards >>>>> Ramdas >>>>> >>>>> >>>>> On 7/28/08, Rob Davies wrote: >>>>> >>>>>> >>>>>> >>>>>> On 28 Jul 2008, at 07:20, Ramdas Sawant wrote: >>>>>> >>>>>> Hi all, >>>>>> >>>>>>> I am exploring AMQ Message Store of ActiveMQ. I need to know >>>>>>> can >>>>>>> i limit the storage size of message store. I mean my topic should not >>>>>>> accept >>>>>>> messages if a certain size of stored messages is reached on disk. How >>>>>>> can i >>>>>>> configure this ? >>>>>>> The attribute maxFileLength of tag "amqPersistenceAdapter" >>>>>>> only >>>>>>> limits the size of one file. I am getting multiple files of the size >>>>>>> specified by maxFileLength attribute. How can i limit this >>>>>>> continuous >>>>>>> file >>>>>>> generation. Let me know if the question is not that clear, or need >>>>>>> any >>>>>>> more >>>>>>> explaination. I am really stuck here... Thanks in advance.... >>>>>>> >>>>>>> >>>>>>> regards >>>>>>> Ramdas >>>>>>> >>>>>>> -- >>>>>>> If you think, "you can", you can >>>>>>> If you think, "you can't", you are right >>>>>>> >>>>>>> >>>>>> You can set the limit using store limit in the ActiveMQ configuration. >>>>>> There was a bug in this that's been fixed in trunk - so use a 5.2 >>>>>> snapshot >>>>>> >>>>>> >>>>>> cheers, >>>>>> >>>>>> Rob >>>>>> >>>>>> http://open.iona.com/products/enterprise-activemq >>>>>> http://rajdavies.blogspot.com/ >>>>>> >>>>>> >>>>>> >>>>>> >>>>>> >>>>>> >>>>> >>>>> -- >>>>> If you think, "you can", you can >>>>> If you think, "you can't", you are right >>>>> >>>>> >>>> >>>> >>>> -- >>>> If you think, "you can", you can >>>> If you think, "you can't", you are right >>>> >>>> >>> >>> >>> -- >>> If you think, "you can", you can >>> If you think, "you can't", you are right >>> >>> >> >> >> -- >> If you think, "you can", you can >> If you think, "you can't", you are right >> > > -- If you think, "you can", you can If you think, "you can't", you are right ------=_Part_8350_27101427.1217315276853--