Re: Messages stuck in queue 5.9.0

Hi, I am unable to view messages in the queue through the JMX console when it is stuck I can browse other queues in the same broker though. lookers -- View this message in context: http://activemq.2283324.n4.nabble.com/Messages-stuck-in-queue-5-9-0-tp4679266p4679390.html Sent from the ActiveM

memoryLimit behavior (5.5.1)

Hi, I've configured a policy for my broker to have 20 mb memory limit for a certain queue and the PFC turned off. I was expecting that when the memory limit is reached, the client would be unable to publish messages to that queue and would receive exceptions while sending a message. But apparent

Message forwarding on two brokers not working for MQTT

Hi , I have setup two brokers A(sender) and B(receiver). both the brokers have been configured with transport connector for mqtt protocol. only broker A has been setup for network connector.AdvisorySupport is enabled. I have 2 clients ( producer) connecting to broker A and consumer connectin

Re: prefetch size in broker config (activemq.xml)

Thanks for the reply. "if you want to enforce a broker wide limit that ignores client values then implementing a broker plugin is the way to go. " - Will it be possible to have only specific configuration from broker configuration and others from client configuration ? e.g. enforce the prefetch

Re: Replicated LevelDB performance problem

hello,here is my scenario for test. I created a consumer using org.springframework.jms.listener.DefaultMessageListenerContainer which continually receive messages from a queue and the consumer is very fast.when the queue goes empty i use jmsTemplate to send messages concurrently using a pooled con

MQTT Apollo Unable to publish when to remote client when client reconnects

I have a server application which is using embedded Jetty 9 and the Apollo MQTT broker. I use the Paho MQTT client to talk to the broker from the server. A remote client also uses the Paho MQTT client to talk to the broker. The /remote/ connections use mutual TLS. It works fine. I bring up the ser

Re: Unable to find the REST API

Try /api/jolokia/ for access. For example, wget --user admin --password admin http://localhost:8161/api/jolokia/read/org.apache.activemq:type=Broker,brokerName=localhost/MemoryPercentUsage to retrieve Memory Usage. -- View this message in context: http://activemq.2283324.n4.nabble.com/Unable

Re: Messages stuck in queue 5.9.0

There are no message selectors on this queue. There are on others, but they are processed in a different thread. There is just one consumer and it consumes messages in FIFO manner. they are consumer using spring jms template. -- View this message in context: http://activemq.2283324.n4.nabbl

Re: Messages stuck in queue 5.9.0

any message selectors? Is it just one consumer that does not get messages? Are they stomp/operwire? I think the best bet to understand what is going is to capture full trace logging. Also trace=true on the openwire (or relevant) tcp transport url. Possibly a broker side thread dump. Any chance t

Re: Messages stuck in queue 5.9.0

There is no ttl on the messages. I have not tried browsing with JMS when they are stuck. I can try that when it fails again No there is nothing in the DLQ for this queue. It is happening quiet regularly. At lease twice a day. I have similar environment set up of different instance and it does not

Re: Messages stuck in queue 5.9.0

that looks fine. Is there a ttl on the messages, anything in the DLQ? Can you browse the messages via jmx? On 20 March 2014 14:36, lookers wrote: > Hi gtully > > Here is a line in the logs with > ReceiveQueue toPageIn: 200, Inflight: 0, pagedInMessages.size 0, > enqueueCount: 120149, dequeueCount

Re: Messages stuck in queue 5.9.0

Hi gtully Here is a line in the logs with ReceiveQueue toPageIn: 200, Inflight: 0, pagedInMessages.size 0, enqueueCount: 120149, dequeueCount: 113644 | org.apache.activemq.broker.region.Queue | ActiveMQ BrokerService[localhost] Task-619 This was when the messages are stuck Does this give you an

Re: Messages stuck in queue 5.9.0

is the inflight count 0 in the jconsole jmx view for your consumer? enable trace level logging for org.apache.activemq.broker in log4j and use jmx to have it refresh the log4j config - a broker operation. send another message to that dest and see what is in the logs. in other words, jmx and logg

Re: prefetch size in broker config (activemq.xml)

if you want to enforce a broker wide limit that ignores client values then implementing a broker plugin is the way to go. see examples at: https://github.com/apache/activemq/tree/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/util like the https://github.com/apache/activemq/blob/t

Re: prefetch size in broker config (activemq.xml)

the broker entries are overrides for the default values. so if the client does not specify a value it will have the default and then the broker policy will override that. so the client is in control if it wants to be. see the code: https://github.com/apache/activemq/blob/trunk/activemq-broker/src/

prefetch size in broker config (activemq.xml)

Hi, I want to set the topic prefetch limit such that it will be applied to all consumers of that topic. I tried to set the same -

Re: Multiple persistence adapters using levelDB

FYI: I am talking about this configuration:

Re: Multiple persistence adapters using levelDB

Hey, In KahaDB, we can have different persistent adapters and different directories for each destination. Can we do something like that using levelDB ? I am not at all want to use kahaDB. Only using levelDB can I create separate directories to store messages for each destination. Thanks, Anuj

Messages stuck in queue 5.9.0

Hi, I am having an issue with messages not being consumed in a queue with no errors generated. Restart of the broker resolves the issue. I was wondering of you could point me direction on how to resolve the issue. Here is my configuration file: The queue normally consumes 100K to 150K messag

Re: Setting redelivery properties on XaConnectionFactory

A follow up for others. It seems impossible to use the Activemq JCA adapter with ActivationSpecs pr. destination in a convenient way. There is also some talk about this here Instead I gave