d 1:1
>
>
> Best regards,
> Leung Wang Hei
>
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Network-bridge-throughput-capped-at-default-Socket-buffer-size-tp4696643.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
twitter: @christianposta
http://www.christianposta.com/blog
http://fabric8.io
programmatically: BrokerService.isSlave()
JMX: There should be a corresponding JMX operation named "isSlave": [Line
119]:
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/BrokerViewMBean.java?view=markup
On Thu, Sep 20, 2012 at 12:53 AM, rmn1
Hi,
Yes, this is absolutely possible.
You can use Camel to bridge to the other JMS providers:
On Mon, Sep 24, 2012 at 12:54 AM, lukas_s wrote:
>
> Hi,
>
> I never use ActiveMQ, i have
> i have integrated JMS in Weblogic 10.3.0<=>Hornetq, now i want to configure
> environment in that
It's usually easier to do so since temp dests are propagated via
advisories, but if you don't use advisories you'll need to set up a static
network to propagate your temps.
This has been addressed in 5.6.x:
https://issues.apache.org/jira/browse/AMQ-3253
See here for static networks:
http://active
ivemq.2283324.n4.nabble.com/Maintenance-Mode-tp4657353p4657383.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
ow via c/c++ or it
> has to be Java ?
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Maintenance-Mode-tp4657353p4657385.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
this message in context:
> http://activemq.2283324.n4.nabble.com/ANNOUNCE-Apache-ActiveMQ-5-7-0-tp4657591p4657667.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
context:
> http://activemq.2283324.n4.nabble.com/dummies-question-how-to-create-few-instances-of-ActiveMq-tp4657605.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
e a way we can configure activemq to achieve this ?
>
> --
> Regards,
> Praveen Bysani
>
--
*Christian Posta*
http://www.christianposta.com/blog
NTCS JDBC internal queue
>
>
> /ntcs-telemetry/telemetry
>
>
>
>
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/On-disk-persisted-message-queues-on-consumer-failure-tp4657706.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
ng or I am doing
> something wrong, but my tests shed this behaviour.
> Thanks
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/On-disk-persisted-message-queues-on-consumer-failure-tp4657706p4657720.html
> Sent from the ActiveMQ - User
o JDBC tables and Message store. Are you referring to
> the section that explains about building custom security plugins ?
>
> On 11 October 2012 20:58, Christian Posta
> wrote:
>
> > Not sure if this is directly configurable out of the box, but it's
> > definitely
gt; View this message in context:
> http://activemq.2283324.n4.nabble.com/On-disk-persisted-message-queues-on-consumer-failure-tp4657706p4657730.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
t;
>
>
>
> class="tng.ntcs.camel.bean.NTCSInsertTransactedTelemetry">
>
>
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/On-disk-persisted-message-queues-on-consumer-failure-tp4657706p4657850.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
he first example is correct and works for me - the second doesn't.
>
> Is this an inaccuracy in the website? If so, is there anyone here who can
> correct the second set of pages? I've just spent a good few hours trying
> to troubleshoot my client :-)
>
> Cheers,
>
>
> Peter
>
--
*Christian Posta*
http://www.christianposta.com/blog
istian
On Wed, Oct 17, 2012 at 6:04 AM, Christian Posta
wrote:
> Peter,
> The correct header for durable subs is "activemq.subscriptionName"
>
> The header on the additional.html page is incorrect. I'll fix it.
>
> Thanks,
> Christian
>
>
> On Wed,
use either the ssl or the tcp connector, depending
> on client location:
>
> failover://tcp://primary:61616 if my client (producer or
> consumer) is within the LAN
>
>failover://ssl://primary:61616 if my client (producer or
> consumer) is outside the LAN
>
>
>
> Thank you for your answers!
>
>
>
> matteo
>
>
>
>
--
*Christian Posta*
http://www.christianposta.com/blog
r answer!
>
> Well, failover="true" is indeed a "cut and paste" idiosyncrasy of mine :)
>
> So, in the end I will use just one discoveryUri="multicast://default" for
> both ssl and tcp transports, right?
>
> Thank you again.
> matteo
>
>
ll
> [debug] o.a.a.b.r.Queue - queue://test expiring messages ..
> [trace] o.a.a.t.PooledTaskRunner - Run task done: queue://test,
> subscriptions=0, memory=0%, size=0, in flight groups=null
> [debug] o.a.a.b.r.Queue - test toPageIn: 0, Inflight: 0,
> pagedInMessages.size 0, enqueueCount: 0, dequeueCount: 0
> [trace] o.a.a.b.r.c.AbstractStor
light: 0,
> pagedInMessages.size 0, enqueueCount: 0, dequeueCount: 0
> [trace] o.a.a.b.r.c.AbstractStoreCursor -
> org.apache.activemq.broker.region.cursors.QueueStorePrefetch@a7fd9bb
> :test,batchResetNeeded=false,storeHasMessages=false,size=0,cacheEnabled=true,maxBatchSize:200
> - fillBatch
> [trace] o.a.a.b.r.c.AbstractStoreCursor -
> org.apache.activemq.broker.region.cursors.QueueStorePrefetch@a7fd9bb
> :test,batchResetNeeded=false,storeHasMessages=false,size=0,cacheEnabled=true,maxBatchSize:200
> - fillBatch
> [debug] o.a.a.b.r.Queue - queue://test expiring messages done.
> [trace] o.a.a.t.PooledTaskRunner - Running task iteration 0 - queue://test,
> subscriptions=0, memory=0%, size=0, in flight groups=null
> [trace] o.a.a.t.PooledTaskRunner - Run task done: queue://test,
> subscriptions=0, memory=0%, size=0, in flight groups=null
> ===
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/ActiveMQ-5-7-snapshot-and-MQTT-connection-times-out-while-still-connected-to-a-topic-for-receiving-tp4656976.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
onsole-Exception-No-broker-is-found-at-any-of-the-1-configured-urls-tp4657842p4658160.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
Try adding this to your Resource declaration:
Datasource =
Related to this:
https://issues.apache.org/jira/browse/TOMEE-474
On Wed, Oct 24, 2012 at 11:00 AM, Christian Posta wrote:
> Are you able to reliably get it to work without the ServerUrl param?
> I am getting some race-like be
mq.2283324.n4.nabble.com/5-7-doesn-t-consume-on-queue-tp4658025p4658045.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
for the help.
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/5-7-doesn-t-consume-on-queue-tp4658025p4658191.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
indicates the client fBroker IP to connect to.
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/5-7-doesn-t-consume-on-queue-tp4658025p4658195.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
you need a network of brokers for this use case?
On Wed, Oct 24, 2012 at 2:56 PM, Christian Posta
wrote:
> There seems to be an issue with the bridge getting established properly,
> probably due to the broker version mix and match. Like Torsten alluded to
> earlier, the subscription i
nd to these issues, or point me to articles that
> address these from the ActiveMQ point of view?
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
l? Now I have 5 queues declared but I only see Queue1
> because I didn't set connections to the others.
>
> Thanks for everything.
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Web-console-Exception-No-broker-is-found-at-a
24.n4.nabble.com/Multiple-Brokers-in-same-VM-tp4658063.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
gt;
> What am I missing for using the camel web console?
> thanx for your help
>
> josef
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/activemq-5-7-camel-web-console-not-working-from-camel-2-10-1-tp4658077.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
appen in 5.6.0 (displays of both webconsoles seemed identical)
>
> Is that the intended behavior ?
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Webconsole-s-in-Master-Slave-mode-not-refreshed-in-5-7-0-tp4658033.html
> Sent from the
it a little
more user friendly (eg, be able to get back to /admin by refreshing
/admin/slave.jsp when it's not in slave mode anymore).
On Thu, Oct 25, 2012 at 2:13 PM, Christian Posta
wrote:
> It should come back from slave mode to be in master mode.
> Can you open a JIRA for that?
>
; System.out.println(name + " Received: " + msg);
> }
>
> -Andrew
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Consumer-cannot-receive-ActiveMQ-Advisory-MasterBroker-messages-tp4657769.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
null} | org.apache.activemq.network.DemandForwardingBridgeSupport |
> ActiveMQ Transport: ssl:///n.n.n.n:32831
>
> I was expecting to see no traffic of any kind on our hub concerning
> Outbound.Account.>, yet sub requests are still flooding in.
>
> Is this normal? Can I get my desired result?
>
> Thanks,
>
> James
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
.n4.nabble.com/Idle-stomp-websockets-remain-connected-tp4658371.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
heartbeat conf RW[0,0]
> 2012-10-26 16:23:15,386 [0.1:57645@61612] DEBUG
> StompInactivityMonitor - Stomp Inactivity Monitor read check: 0,
> write check: 0
> 2012-10-26 16:23:15,386 [0.1:57645@61612] DEBUG
> ProtocolConverter - Stomp Connect heartbeat conf RW[0,0]
>
> Where are the frames?
>
> I need to understand why a consumer is being starved of messages after a
> while.
>
> Thanks,
>
> James
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
o.com-42823-1351217522424-7:2:1:1 dispatched:
> ID:vmnode-073.corp.attivio.com-42823-1351217522424-5:3:1:1:2 -
> queue://indexer.index-content-dispatcher, dispatched: 3, inflight: 3
> 2012-10-25 22:12:22,096 TRACE PrefetchSubscription -
> ID:vmnode-073.corp.attivio.com-42823-135121
[%-15.15t] %-5p
> %-30.30c{1} - %m%n
>
> # enable this line and disable the above if you just want the frame IO.
> #log4j.logger.org.apache.activemq.transport.stomp.StompIO=TRACE, stomp
> log4j.additivity.org.apache.activemq.transport.stomp=false
>
> Thanks again,
>
> James
>
> On 29 October 2012 23:07, Christian
d test and replaying it. It always has the bad set of
> messages.
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Message-sometimes-lost-when-transaction-open-and-broker-restarted-tp4658295p4658458.html
> Sent from the ActiveMQ - Us
On Tue, Oct 30, 2012 at 6:57 AM, Christian Posta
wrote:
> James,
>
> I was wrong. The correct log4j logger would be this...
>
> log4j.logger.org.apache.activemq.transport.stomp.StompIO=TRACE
>
> (therefore, your original setting would have been correct)
>
> but even s
Fixed in https://issues.apache.org/jira/browse/AMQ-4145
On Tue, Oct 30, 2012 at 8:30 AM, Christian Posta
wrote:
> James,
>
> so using ?transport.trace=true should work for your case here.
>
> There is a bug with our introspection utils class that sets trace on the
> transpo
headers.put("replyTo", "/queue/statsresults");
>
> StompConnection connection = new StompConnection();
> connection.open("localhost", 61613);
> connection.connect("system", "manager");
>
> connection.subscribe("/queue/statsresults");
>
> connection.send("/queue/ActiveMQ.Statistics.Broker", "", "",
> headers);
>
> StompFrame message = connection.receive();
> System.out.println(message.getBody());
>
> connection.disconnect();
> }
>
> }
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
.
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Message-sometimes-lost-when-transaction-open-and-broker-restarted-tp4658295p4658621.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
that. I'll investigate a little more tomorrow.
On Thu, Nov 1, 2012 at 1:13 PM, Fulko Hew wrote:
> On Thu, Nov 1, 2012 at 3:54 PM, Christian Posta
> wrote:
>
> > For your Java client, the header needs to be "reply-to" per the docs
> here:
> > http://acti
they've at
> least heard of), let alone Python which they haven't, or even less,
> Jython.]
>
> I've made progress on the Perl/STOMP front. The issue now is understanding
> the various 'transformation's that are available (from ActiveMQ?) and being
> abl
entioned)
> - "start" command e.g. ./INSTANCE1/bin/INSTANCE1 start
>
> Best regards,
> Peter
>
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/ActiveMQ-multiple-instances-start-problems-when-passing-config-file-
;
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Just-a-quick-one-tp4658764.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
message orientation'
> of the StatisticsPluginBroker?
>
> Or is there some way (using that broker and STOMP) to retrieve the
> 'list of queues' and then retrieve the data on each one singly
> and explicitly?
>
> TIA
> Fulko
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
t 8:05 AM, Fulko Hew wrote:
> On Mon, Nov 5, 2012 at 9:21 AM, Christian Posta
> wrote:
>
> > Can you post a snippet of the response you're getting from ActiveMQ?
> > It should be in JSON format, and if it is, it shouldn't be too difficult
> to
> > deal with in
This one
> has
> an ApolloRoles subtree whose nodes are the role names.
>
>
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Using-Apollo-with-LDAP-Active-Directory-tp4658601p4658809.html
> Sent from the ActiveMQ - User mailing list
You need to use a durable subscriber to the topic
http://forum.springsource.org/showthread.php?18281-JMS-Durable-Subscription-Example
On Nov 6, 2012, at 12:32 PM, Biscuit128 wrote:
> Hi,
>
> I am using Spring in conjunction with activemq. What happens when I turn
> activemq off in the middle of
4658860.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
58850p4658862.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
d.ActiveMQMessage.visit(ActiveMQMessage.java:681)
>
>
> >at
> org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:306)
>
>
> >at
> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179)
>
>
> >at
> org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69)
>
>
> >at
> org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)
>
>
> >at
> org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:227)
>
>
> >- locked <0x004ca288> (a
> org.apache.activemq.transport.InactivityMonitor$1)
>
> >at
> org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
>
>
> >at
> org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:220)
>
>
> >at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:202)*
> ***
>
> >at java.lang.Thread.run(Thread.java:662)
>
> >
>
> > Thanks & Regards,
>
> > Aravind Chennuru
>
> ** **
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
k up and running
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/activemq-won-t-start-with-jre-1-7-tp4658849p4658899.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
t; 54: Store percent used
>
>
> Stacktrace:] with root cause
> javax.el.PropertyNotFoundException: Property 'upTime' not found on type
> $Proxy4
> at
> javax.el.BeanELResolver$BeanProperties.get(BeanELResolver.java:237)
>
> Earle
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
at 8:36 AM, Aravind Chennuru <
aravind.chenn...@netboss.com> wrote:
> Hi All,
>
> Does anyone know how to kill a topic subscription from the producer, so
> that the consumer can report that the connection has been lost?
>
>
> Thanks & Regards,
> Aravind Chennuru
>
t on z/OS.
>
>
>
> -
> Stephen Vincent
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/HttpException-413-FULL-head-null-at-HttpParser-java-1030-tp4658147p4659134.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.
text:
> http://activemq.2283324.n4.nabble.com/activemq-won-t-start-with-jre-1-7-tp4658849p4658974.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
un
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Will-messages-in-DLQ-be-store-forwarded-in-network-of-broker-setting-tp4659196.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
Sat, Nov 10, 2012 at 11:54 AM, Mohit Anchlia <
> mohitanch...@gmail.com
> > >wrote:
> > >
> > >> Does anyone know why one would get this error?
> > >>
> > >>
> > >> javax.jms.InvalidClientIDException: Broker: p
gt; View this message in context:
> http://activemq.2283324.n4.nabble.com/Problems-deploying-AMQ-web-console-in-Tomcat-7-tp4659230.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
Average-ActiveMQ-Enqueue-Time-is-displayed-as-negative-value-in-the-jconsole-tp4659181.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
659299&code=bWFyY28ubGFwb25kZXJAZ21haWwuY29tfDQ2NTkyOTl8LTEwMTU2NjMyODA=
> >
> > .
> > NAML<
> http://activemq.2283324.n4.nabble.com/template/NamlServlet.jtp?macro=macro_viewer&id=instant_html%21nabble%3Aemail.naml&base=nabble.naml.namespaces.BasicN
om/ANNOUNCE-Apache-ActiveMQ-5-7-0-tp4657591p4659434.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
build-path-tp4659611.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
t; (apart
> >>>> > from disk since it's persistent), and all the rest that continues
> >>>> being fed
> >>>> > goes just to disk?
> >>>>
> >>>> This behavior is correct. For queues the default cursor is store
> >>>> cursor. It keeps any newly arrived msgs in memory as long as it does
> not
> >>>> reach the configured memory limit (either configured on the queue per
> >>>> destination or globally in memoryUsage settings).
> >>>> Once the cursor reaches 70% of the configured limit (in your case of
> >>>> the memoryUsage limit since you don't specify a per-destination
> limit), it
> >>>> will not keep any more messages in memory.
> >>>> Instead it will reload these messages from the store when its time to
> >>>> dispatch them. The broker anyway persists any msgs it receives before
> >>>> passing on to the cursor.
> >>>> This limit of 70% can be configured and raised to e..g 100%.
> >>>> This behavior is kind of an optimization. That way you run less often
> >>>> into producer-flow-control.
> >>>> As long as the persistence store is not running full, there is no need
> >>>> to block producers, since the cursor can also load the messages from
> the
> >>>> store and does not necessarily have to keep them in memory.
> >>>> If you configure the vmQueueCursor, then the behavior is different.
> >>>> This cursor will not be able to load msgs to the store but needs to
> keep
> >>>> them all in memory. The vmQueueCursor used to be the default cursor in
> >>>> older version of AMQ.
> >>>>
> >>>> Also note that topic msgs and non-persistent queue messages are not
> >>>> handled by the store cursor. These msgs are held in memory and if
> memory
> >>>> runs low, get swapped out to temp storage.
> >>>>
> >>>> > 2) If then I start feeding a 2nd queue, "Memory percent used"
> >>>> continues
> >>>> > growing until it reaches 140%. So it looks like memoryUsage does not
> >>>> apply
> >>>> > globally, but on a per queue basis?
> >>>>
> >>>> What version of AMQ do you use? The sum of the memory usage of all
> >>>> queues should not go any higher than the configured memoryUsage
> limit. If
> >>>> you're not on 5.5.1 or higher releases, then I suggest to upgrade.
> >>>>
> >>>> > Using memoryLimit on the queue's policyEntry gives more control over
> >>>> this,
> >>>> > but it's just a variation, "Memory percent used" can grow more than
> >>>> 100%
> >>>> > anyway.
> >>>>
> >>>> With the default store cursor this should not be the case from what I
> >>>> know.
> >>>>
> >>>>
> >>>> >
> >>>> > 3) If #2 is true, then how would I prevent the broker from running
> >>>> out of
> >>>> > memory in case queues would continue to be created?
> >>>>
> >>>> Just like above comment. I would expect the brokers MemoryPercentUsage
> >>>> won't grow over 100% and the destinations MemoryPercentUsage remains
> fairly
> >>>> much at 70%.
> >>>> Not sure why you would see a different behavior? Using an old version
> >>>> of AMQ perhaps? Or explicitly configuring for the vmQueueCursor?
> >>>> Could you perhaps also test with
> >>>>
> >>>> >
> >>>> >
> >>>> > Maybe I'm misunderstanding and some of these settings make no sense
> >>>> when
> >>>> > producerFlowControl is disabled?
> >>>> >
> >>>> > Thanks in advance.
> >>>> >
> >>>> > Juan
> >>>>
> >>>>
> >>>> Regards,
> >>>>
> >>>> Torsten Mielke
> >>>> tors...@fusesource.com
> >>>> tmielke.blogspot.com
> >>>>
> >>>>
> >>>>
> >>>>
> >>>>
> >>>
> >>
> >
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
dd some better credit than what i
> wrote, just ask :)
>
> *hugs*
>
>
> --
> Laurent "ker2x" Laborde
> Sysadmin & DBA at http://www.over-blog.com/
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
ollo.openwire.command.ConnectionControl :
>
> Any pointers would be greatly appreciated!
>
> Thanks,
> Dean
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Apollo-Openwire-Apache-NMS-ActiveMQ-and-Failover-Transport-tp4659721.html
&g
would the memory usage be 211% while temp usage is 0%.
> 2) The thread dump shows that send calls on producers are blocking. Why
> would they not throw exceptions when send fail if no space = true?
> 3) Would the issue with connection shutdown contribute to the memory usage?
>
> Thanks,
> Mark
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
ic prefetch set to 32766. I am trying to get logs from the client.
>
> The broker on the other end of the bridge uses the same configuration.
>
>
> On 27 November 2012 13:41, Christian Posta >wrote:
>
> > Answers to your questions:
> >
> > 1) Not sure yet
&g
workConnector extends DiscoveryNetworkConnector so I can fire
> listeners for onServiceAdd and onServiceRemove.
>
>
> On 27 November 2012 14:16, Christian Posta >wrote:
>
> > Okay good to know. I suppose this error happened just once randomly and
> you
>
ree.
http://activemq.apache.org/per-destination-policies.html
With PFC turned off, you're essentially telling the broker to take the
message no matter what. There is a point at which you will run out of
resources (memory, disk, etc). The trick is to find your use case and tune
for that.
324.n4.nabble.com/ActiveMQ-SSL-Error-No-X509TrustManager-implementation-avaiable-tp4659805p4659877.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
kup
> the Connection object in the Advisory onMessage callback?
>
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/How-can-I-retrieve-a-Stomp-username-when-a-new-Connection-is-made-tp4659949.html
> Sent from the ActiveMQ - User mailing list arc
View this message in context:
> http://activemq.2283324.n4.nabble.com/How-can-I-retrieve-a-Stomp-username-when-a-new-Connection-is-made-tp4659949p4659954.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
be immediately consumed, so having them store a lot into memory
> ended up slowing things up.
>
> So I just assigned enough memory to the broker so as not run into issues.
>
> Thanks again.
>
>
> On Tue, Nov 27, 2012 at 9:40 PM, Christian Posta
> wrote:
>
&
at org.xmlpull.mxp1.MXParser.fillBuf(MXParser.java:2991)
> at org.xmlpull.mxp1.MXParser.more(MXParser.java:2996)
> at org.xmlpull.mxp1.MXParser.parseEntityRef(MXParser.java:2151)
> at org.xmlpull.mxp1.MXParser.nextImpl(MXParser.java:1274)
> at org.xmlpull.mxp1.MXParser.next(MXParser.java:1092)
> at
> com.thoughtworks.xstream.io.xml.XppReader.pullNextEvent(XppReader.java:63)
> ... 37 more
>
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Large-message-failure-over-http-transport-tp4659891.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
is great
for some usecases, but for this one maybe not?? dunno... maybe the problem
you're trying to solve can be better solved a different way...
On Thu, Nov 29, 2012 at 4:17 PM, Christian Posta
wrote:
> Can you post your broker config?
>
> I have been trying 10MB payloads and
System.out.println("Unknown command: " + command);
> }
> }
>
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/How-can-I-retrieve-a-Stomp-username-when-a-new-Connection-is-made-tp4659949p4660019.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
networkTTL="5" dynamicOnly="true"
> decreaseNetworkConsumerPriority="false" prefetchSize="1000">
>
> plus some dynamically included destinations.
>
> Regards,
> Ron
>
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/ActiveMQ-5-8-SNAPSHOT-problems-connecting-to-older-versions-tp4660039.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
nothing. From mqtt to mqtt clients, everthing
> works perfect!
>
> Any ideas on that?
>
> Every little help is appreciated!
>
> Best regards,
> Christian
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
this message in context:
> http://activemq.2283324.n4.nabble.com/ActiveMQ-Send-Timeout-does-not-work-while-simulating-packetloss-tp4660111p4660126.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
this message in context:
> http://activemq.2283324.n4.nabble.com/ActiveMQ-5-8-SNAPSHOT-problems-connecting-to-older-versions-tp4660039p4660205.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
useJmx="true"
> persistent="true">
>
>
>
>
>
> enableAudit="false" expireMessagesPeriod="0">
> memoryLimit="50mb" enableAudit="false" expireMessagesPeriod="0">
>
>
>
>
>
>
>
>
> rmiServerPort="1399"/>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
Tim has this fixed for you:
On Wed, Dec 5, 2012 at 6:14 AM, Christian Posta
wrote:
> Nice find RonK. I'll take a look at how the HawtBuf lib gets distributed
> and see what makes sense for it.
> I've opened https://issues.apache.org/jira/browse/AMQ-4206 to track it.
>
Actually, your config *could* cause a problem.
If you have>100MB of messages in memory and you try to write them to temp
storage (let's say on a Topic) then you might have problems since temp
store is only 100MB (1/2 of what memory is).
On Wed, Dec 5, 2012 at 6:35 AM, Christian Pos
Not sure AMQ-4136 is related. That's for persistent messages. The only way
for FilePendingMessageCursor to be in the mix here is if you're doing
non-persistent messages over queues. Is that the case?
On Wed, Dec 5, 2012 at 2:39 AM, Tom Martinec wrote:
> AMQ-4136
--
*Christia
n OOM.
Hope that helps
On Thu, Dec 6, 2012 at 8:46 AM, Eugene Ong wrote:
>
> lets say that I set my -Xmx (heap size) to 1G. Is it a good idea to also
> set my activemq memoryUsage limit to 1G. Why or why not?
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
gt;> > destinations should be suppressed.
> > >> >> >
> > >> >> > On the hub we're seeing advisories for queues on that spoke. Is
> > there
> > >> >> > therefore a bug?
>
mq.2283324.n4.nabble.com/Stomp-ActiveMQ-tp4660366.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
nnectionFactory(failoverBrokerUrl);
> PooledConnectionFactory pcf = new PooledConnectionFactory(factory);
> pcf.setMaximumActive(500);
> pcf.setMaxConnections(5);
> JMSTemplate jmsTemplate = new JmsTemplate(pcf);
> jmsTemplate.setSessionAcknowledgeMode(Session.CLIENT_ACKNOWL
iveMQConnectionFactory(failoverBrokerUrl);
> >> PooledConnectionFactory pcf = new PooledConnectionFactory(factory);
> >> pcf.setMaximumActive(500);
> >> pcf.setMaxConnections(5);
> >> JMSTemplate jmsTemplate = new JmsTemplate(pcf);
> >> jmsTemplate.setSessionAcknowledgeMode(Session.
gt; http://activemq.2283324.n4.nabble.com/Producer-to-Topic-with-Consumer-down-the-broker-is-waiting-tp4660452p4660459.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
t; <
> http://activemq.2283324.n4.nabble.com/file/n4660465/SpringConsumerWithReply.java
> >
> Thanks, Jerry C
>
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Broker-Leak-tp4660437p4660465.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
ved the java-code that deals with the truststore and moved the
> functionality to JAVA_OPTS, but this is not what I want/expected. Using
> activemq-all-5.7-SNAPSHOT.jar.
>
> Thought this problem only occurs when using an SSL failover URI ?
>
> Thanks,
> Geurt
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
ry Tully wrote:
> you are looking at the need for a writeTimeoutFilter or inactivityMonitor
> or OS level tcp keepAlive to detect a half closed socket as the result of
> an abortive close of the client.
>
>
> On 11 December 2012 14:36, Christian Posta >wrote:
>
> &
sing the Session enough to purge
> ProducerExchange from the broker?
>
> -Jerry C
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Broker-Leak-tp4660437p4660513.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Broker-Leak-tp4660437p4660538.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
Bad choice of words.. not "destined" but could run out of memory if
consumers cannot keep up with producers
On Wed, Dec 12, 2012 at 5:51 PM, Christian Posta
wrote:
> So i guess in general i would think that a configuration with no PFC, vm
> cursors, and no persistence is destin
1 - 100 of 1020 matches
Mail list logo
