activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From colomb <col...@gmail.com>
Subject Re: Embedded broker, non-persistent messages and store based cursor
Date Mon, 12 Mar 2012 17:34:34 GMT
Thanks for the help.  Works as expected now.

colomb


On Sat, Mar 10, 2012 at 7:29 AM, Rob Davies [via ActiveMQ] <
ml-node+s2283324n4462038h98@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.
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message