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 <storeUsage limit="4 mb" name="foo"/>, 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 <[EMAIL PROTECTED]> 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 <[EMAIL PROTECTED]> wrote:
>>
>>>
>>> What does <storeUsage limit="4 mb" name="foo"/> signify ??? does the name
>>> attribute should be the name of the Topic ??? Not clear on that... Thanks
>>>
>>> On 7/28/08, Ramdas Sawant <[EMAIL PROTECTED]> wrote:
>>>
>>>>
>>>> Hi Rob,
>>>> I tried using the 5.2 snapshot, but still facing the same
>>>> issue. Below is my activemq.xml
>>>> ///////////////////////////////////
>>>>
>>>> <beans
>>>> 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";>
>>>>
>>>> <bean
>>>>
>>>> class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
>>>>
>>>> <broker xmlns="http://activemq.apache.org/schema/core";
>>>> brokerName="localhost" dataDirectory="${activemq.base}/data">
>>>>
>>>> <destinationPolicy>
>>>> <policyMap>
>>>> <policyEntries>
>>>> <policyEntry queue=">" memoryLimit="5mb"/>
>>>> <policyEntry topic=">" memoryLimit="1mb">
>>>> <dispatchPolicy>
>>>> <strictOrderDispatchPolicy/>
>>>> </dispatchPolicy>
>>>> <subscriptionRecoveryPolicy>
>>>> <lastImageSubscriptionRecoveryPolicy/>
>>>> </subscriptionRecoveryPolicy>
>>>> </policyEntry>
>>>> </policyEntries>
>>>> </policyMap>
>>>> </destinationPolicy>
>>>>
>>>> <managementContext>
>>>> <managementContext createConnector="false"/>
>>>> </managementContext>
>>>>
>>>> <networkConnectors>
>>>> <networkConnector name="default-nc"
>>>> uri="multicast://default"/>
>>>> </networkConnectors>
>>>>
>>>> <persistenceAdapter>
>>>> <amqPersistenceAdapter syncOnWrite="false"
>>>> directory="${activemq.base}/data" maxFileLength="2 mb"
>>>> maxReferenceFileLength="1mb"/>
>>>> </persistenceAdapter>
>>>>
>>>> <sslContext>
>>>> <sslContext keyStore="file:${activemq.base}/conf/broker.ks"
>>>> keyStorePassword="password"
>>>> trustStore="file:${activemq.base}/conf/broker.ts"
>>>> trustStorePassword="password"/>
>>>> </sslContext>
>>>>
>>>> <!-- The maximum about of space the broker will use before
>>>> slowing down producers -->
>>>> <systemUsage>
>>>> <systemUsage>
>>>> <memoryUsage>
>>>> <memoryUsage limit="3 mb"/>
>>>> </memoryUsage>
>>>> <storeUsage>
>>>> <storeUsage limit="4 mb" name="foo"/>
>>>> </storeUsage>
>>>> <tempUsage>
>>>> <tempUsage limit="5 mb"/>
>>>> </tempUsage>
>>>> </systemUsage>
>>>> </systemUsage>
>>>>
>>>>
>>>> <transportConnectors>
>>>> <transportConnector name="openwire"
>>>> uri="tcp://localhost:61616" discoveryUri="multicast://default"/>
>>>> <transportConnector name="ssl" uri="ssl://localhost:61617"/>
>>>> <transportConnector name="stomp"
>>>> uri="stomp://localhost:61613"/>
>>>> <transportConnector name="xmpp" uri="xmpp://localhost:61222"/>
>>>> </transportConnectors>
>>>>
>>>> </broker>
>>>>
>>>> <camelContext id="camel" xmlns="
>>>> http://activemq.apache.org/camel/schema/spring";>
>>>>
>>>> <package>org.foo.bar</package>
>>>>
>>>> <route>
>>>> <from uri="activemq:example.A"/>
>>>> <to uri="activemq:example.B"/>
>>>> </route>
>>>> </camelContext>
>>>>
>>>> <jetty xmlns="http://mortbay.com/schemas/jetty/1.0";>
>>>> <connectors>
>>>> <nioConnector port="8161"/>
>>>> </connectors>
>>>>
>>>> <handlers>
>>>> <webAppContext contextPath="/admin"
>>>> resourceBase="${activemq.base}/webapps/admin" logUrlOnStart="true"/>
>>>> <webAppContext contextPath="/demo"
>>>> resourceBase="${activemq.base}/webapps/demo" logUrlOnStart="true"/>
>>>> <webAppContext contextPath="/fileserver"
>>>> resourceBase="${activemq.base}/webapps/fileserver"
>>>> logUrlOnStart="true"/>
>>>> </handlers>
>>>> </jetty>
>>>>
>>>> </beans>
>>>> ///////////////////////////////////////////////////////
>>>>
>>>> I tried setting both "maxFileLength" and "<storeUsage limit", but i am
>>>> 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 <[EMAIL PROTECTED]> 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 <[EMAIL PROTECTED]> 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
