Thanks for the help. Works as expected now. colomb
On Sat, Mar 10, 2012 at 7:29 AM, Rob Davies [via ActiveMQ] < ml-node+s2283324n4462038...@n4.nabble.com> wrote: > Unfortunately - when you disable persistence in the broker, it also > prevents any use of storage to disk. I suggest you don't set persistence to > false and make sure the messages you send are non-persistent. You should > then get the behaviour you want. > > On 10 Mar 2012, at 03:43, colomb wrote: > > > We are using an embedded broker producing non persistent messages. The > > producer is quite fast and the consumers are usually able to keep up. > > Sometimes, a consumer may slow down, and we would like to try ensure > that > > the producer isn't told to slow down if the broker fills up with > messages. > > \http://activemq.apache.org/message-cursors.html says the store based > cursor > > has an embedded file cursor. Our understanding is that the broker > should > > queue messages in memory until it reaches the watermark (70%) and then > start > > queue messages in the store or temp. Once the store has been filled, > then > > it should slow down the producer. Unfortunately, we aren't seeing that > > behavior. The queue just fills up in memory until it reaches its limit > and > > it starts slowing / blocking the producer. How do we get an embedded > broker > > to store non-persistent messages to disk when memory fills up? Should > we be > > attacking this problem with a different configuration? Our broker > > configuration is below. Thanks for the help > > > > Active MQ 5.3.1 > > Java 1.6 > > > > broker = new BrokerService(); > > broker.setPersistent( false ); > > broker.addConnector( "tcp://0.0.0.0:61616" ); > > > > PolicyEntry policyEntry = new PolicyEntry(); > > policyEntry.setQueue( ">" ); > > policyEntry.setProducerFlowControl( true ); > > > > PolicyMap policyMap = new PolicyMap(); > > policyMap.setDefaultEntry( policyEntry ); > > broker.setDestinationPolicy( policyMap ); > > > > SystemUsage systemUsage = broker.getSystemUsage(); > > systemUsage.setSendFailIfNoSpace( true ); > > systemUsage.getMemoryUsage().setLimit( 1024 * BYTES_IN_MEG ); > > systemUsage.getStoreUsage().setLimit( 1024 * BYTES_IN_MEG ); > > systemUsage.getTempStorage().setLimit( 1024 * BYTES_IN_MEG ); > > > > -- > > View this message in context: > http://activemq.2283324.n4.nabble.com/Embedded-broker-non-persistent-messages-and-store-based-cursor-tp4461429p4461429.html > > Sent from the ActiveMQ - User mailing list archive at Nabble.com. > > > > ------------------------------ > If you reply to this email, your message will be added to the discussion > below: > > http://activemq.2283324.n4.nabble.com/Embedded-broker-non-persistent-messages-and-store-based-cursor-tp4461429p4462038.html > To unsubscribe from Embedded broker, non-persistent messages and store > based cursor, click > here<http://activemq.2283324.n4.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_code&node=4461429&code=Y29sb21iQGdtYWlsLmNvbXw0NDYxNDI5fDE4ODk4Mzg1MDM=> > . > NAML<http://activemq.2283324.n4.nabble.com/template/NamlServlet.jtp?macro=macro_viewer&id=instant_html%21nabble%3Aemail.naml&base=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespace&breadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml> > -- View this message in context: http://activemq.2283324.n4.nabble.com/Embedded-broker-non-persistent-messages-and-store-based-cursor-tp4461429p4466749.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
