Does anybody have an idea what we can do about this?
Am 18.01.2014 14:12, schrieb Thorsten Höger:
Hi,
We use ActiveMQ 5.9.0 and are getting warn logs every 30 minutes in all our
applications
using Spring ListenerContainers
WARN crest Sat Jan 18 13:16:00 CET 2014
I think little bit confusion here; let me elaborate:
I am running ActiveMQ broker as a separate java process. And clients are
connecting from different hosts and client have different java process and
connecting to the broker using transport connectors (TCP).
I am using this code in my own
On 01/23/2014 10:21 PM, HellKnight wrote:
I read a related post at stackoverflow.com , and you said IKVM could help in
this situation ,I want to write a java program that could delete specific
message as I wanted and then convert it to a dll by IKVM ,do you think this
solution worth trying ?
I've setup Apollo 1.6 and I've enabled the web admin interface over http
and https:
web_admin bind=http://0.0.0.0:8161; /
web_admin bind=https://0.0.0.0:8162; /
If I access the interface over HTTP, I get the login form, which I fill-out
and can then access the page.
If I logout of the HTTP
You don't need a plugin for that. Use JMX.
On Friday, January 24, 2014, khandelwalanuj khandelwal.anu...@gmail.com
wrote:
I think little bit confusion here; let me elaborate:
I am running ActiveMQ broker as a separate java process. And clients are
connecting from different hosts and client
Hey,
I don't know how to use JMX for broker. Is there any APIs of JMX I should
use ?
Thanks,
Anuj
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Current-Connection-Count-for-ActiveMQ-broker-tp4676635p4676741.html
Sent from the ActiveMQ - User mailing list archive at
Hi all,
I have couple of questions regarding memory configurations. I read the docs
and couple of blog posts, but still cannot figure it out completely.
In my case I have only persistent queues.
1. For memoryUsage, the docs say: for non-persistent messages, specifies
the maximum amount of
Ohh. I explored a little bit and got to know this.
Does your mean by saying JMX is:
*BrokerViewMBean brokerView = (BrokerViewMBean)
getBrokerService().getManagementContext().newProxyInstance(brokerName,
BrokerViewMBean.class, true);*
and I can get transport connector by:
Ohh. I explored a little bit and got to know this.
IS your mean by saying JMX is:
*BrokerViewMBean brokerView = (BrokerViewMBean)
getBrokerService().getManagementContext().newProxyInstance(brokerName,
BrokerViewMBean.class, true);*
and I can get transport connector by:
What about the use of zookeeper for levelDB replication? If you have a
physical server, then you have a dedicated NIC that can handle the throughput
by the use of quad ports (primary/secondary channeling) for improved
performance. With a VM, you do not have a dedicated NIC.
-Original
Fire up jconsole.
On Friday, January 24, 2014, khandelwalanuj khandelwal.anu...@gmail.com
wrote:
Hey,
I don't know how to use JMX for broker. Is there any APIs of JMX I should
use ?
Thanks,
Anuj
--
View this message in context:
hi luoping,
You can have HA network of brokers.
Here are some documents explaining how to do it:
http://fusesource.com/docs/broker/5.5/clustering/FuseMBClusterFaultTolerenceNetwork.html
Also if you are using Fuse, here are some examples showing how easy it is
to create different topologies
I am not able to understand. Will you please tell me how to get connections
from JMX ?
Or what is wrong with my approach (It is working fine even if I am not using
embedded broker)
Thanks,
Anuj
--
View this message in context:
How about you tell us what exactly it is you are trying to accomplish?
On Friday, January 24, 2014, khandelwalanuj khandelwal.anu...@gmail.com
wrote:
I am not able to understand. Will you please tell me how to get connections
from JMX ?
Or what is wrong with my approach (It is working fine
I have a simple requirement where I want to log current number of connections
established to the ActiveMQ broker.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Current-Connection-Count-for-ActiveMQ-broker-tp4676635p4676752.html
Sent from the ActiveMQ - User mailing
sorry, supplement version:
Spring 3.2.5.RELEASE
ActiveMq 5.9.0
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Why-the-Spring-DataSourceTransactionManager-suppress-the-concurrent-number-of-ActiveMQ-consumer-tp4676736p4676738.html
Sent from the ActiveMQ - User mailing
hi,guys
I got one strange problem.
when I config a DataSourceTransactionManager with spring xml, the concurrent
consumers of ActiveMQ were suppressed whatever I change
maxConcurrentConsumers property value. I have 5 queues, the concurrent
consumers always kept at 8.
if I remove
Thanks for the clarification on the embedded broker question.
A broker filter will do the job, as you described.
On the other hand, you could have written a tool that connects to the broker
JVM via JMX and gets the counts that way, without putting custom code into
the broker JVM. Such a tool
Yes it was! I must have added this by mistake when adding the logging plugins
(from a cut and past!). Removing this solved the problem. Thank you very
much for this!
Regards,
John
--
View this message in context:
Thanks you for the explaination
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Current-Connection-Count-for-ActiveMQ-broker-tp4676635p4676764.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Interesting question (dedicatd NIC) - that's more a VM question than an
ActiveMQ question. With sharing the NIC with other load, the issue becomes,
what other loads are sharing and how much? Very much a question outside of
ActiveMQ itself.
Is it possible for a VM host to dedicate a physical NIC
artnaseef wrote
Is the embedded broker looking for messages on the Topic?
Yes.
artnaseef wrote
Keep in mind messages sent to a Topic are only ever dispatched to either
active subscriptions, or durable subscriptions. In fact, the broker never
stores messages for a Topic, but instead stores
Cool - you're welcome.
Note that plugin may be valuable if your broker clocks ever get far
out-of-sync, so you might want to look more closely at why the plugin was
whacking the timeouts. Note that I'm saying this with only a brief look at
that code, so I can't say for sure right now that it can
artnaseef wrote
Cool - you're welcome.
Note that plugin may be valuable if your broker clocks ever get far
out-of-sync, so you might want to look more closely at why the plugin was
whacking the timeouts. Note that I'm saying this with only a brief look
at that code, so I can't say for sure
Wish I knew the internals there well enough to solve your problem.
If I had this problem, I would pull down the sources for the Spring DMLC and
ActiveMQ connection pools and debug it. My first question is what logic
can cause the log message 'The Session is closed'?
--
View this message in
Nope. That's a bit odd please raise a JIRA issue so we can track this down.
On Fri, Jan 24, 2014 at 7:03 AM, craig w codecr...@gmail.com wrote:
I've setup Apollo 1.6 and I've enabled the web admin interface over http
and https:
web_admin bind=http://0.0.0.0:8161; /
web_admin
Okay, but for what purpose? What are you trying to do with this
information?
On Friday, January 24, 2014, khandelwalanuj khandelwal.anu...@gmail.com
wrote:
I have a simple requirement where I want to log current number of
connections
established to the ActiveMQ broker.
--
View this
Hello Vatsal,
sorry for may long delay of reply. It seems as if I was mistaken. At least,
I tracked down my issue to a different kind of problem.
Therefore, I will delete my current post.
However, thank You very much for Your reply and Your proposal to help.
--
View this message in
I try to craft a client which sends MQTT messages as binary Websocket frames.
The client is based on Java/Paho http://www.eclipse.org/paho/ for the
MQTT part and on Netty 4.0.14 http://netty.io/index.html for the
Websocket part. The server side is an unmodified Apollo 1.6.
Upon a successful
I've created an issue: https://issues.apache.org/jira/browse/APLO-347
thanks
On Fri, Jan 24, 2014 at 10:03 AM, Hiram Chirino hi...@hiramchirino.comwrote:
Nope. That's a bit odd please raise a JIRA issue so we can track this
down.
On Fri, Jan 24, 2014 at 7:03 AM, craig w
Like with pretty much any Java app, you end up running a VM in a VM.
Performance on IO, CPU sharing and so on will be impacted.
That doesn't mean that you couldn't scale in different ways with more VM
instances instead.
On Jan 24, 2014, at 6:37 AM, artnaseef a...@artnaseef.com wrote:
Awesome - you're welcome.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/How-to-use-embedded-and-standalone-broker-bridged-together-tp4676540p4676786.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Awesome. Knowing the final outcome helps in case this ever pops up again.
Sent from my iPhone
On Jan 24, 2014, at 7:51 AM, johnd [via ActiveMQ]
ml-node+s2283324n4676768...@n4.nabble.com wrote:
artnaseef wrote
Cool - you're welcome.
Note that plugin may be valuable if your broker
I have some consumers, each one has a unique queue on broker. Every message
will be send to each consumer,which means I will send the same message to
every existing queue on broker. And I use individual ack mode because I want
client app do some work to process the msg before ack it. And I want
Do you ever want more than one consumer to receive a message? If not, what
you need is a single queue and let the consumers compete for messages.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Can-I-delete-a-message-from-a-queue-in-c-code-tp4676691p4676800.html
Sent
Hi artnaseef. Thanks for your reply. The short answer is Yes , I want
more than one consumers getting the same message.
The long answer : the messages I sent is notifications for future work
in a workflow system. Everyone who is responsible for doing the work should
receive notifications ,
36 matches
Mail list logo
