Hello John,
You should either set a timeToLive on your message
http://activemq.apache.org/how-do-i-set-the-message-expiration.html
or live with the fact that messages don't expire in the broker.
There should not be a need for another broker plugin.
If a message with a timeToLive expires, the
Hello,
Are you using broker networks? If yes, please have a read over
http://tmielke.blogspot.de/2012/03/i-have-messages-on-queue-but-they-dont.html
The fact that you cannot even browse the messages got me wonder if you use
broker networks.
Do your consumers use message selectors by any
Hello,
I'm not using network brokers but I see a network connector that might have
something to do. This is my ActiveMQ configuration:
amq:broker id=broker brokerName=activemq persistent=true
depends-on=jmxServer useShutdownHook=false advisorySupport=false
amq:managementContext
I double checked the TTL and it seems that the producer doesn't set a value
for TTL before sending the message, so I guess it's the default value 0.
If I have 2 messages stuck in one topic, which don't go away even after we
restart the broker, can they cause problems with the kahadb and lead to
Hello guys,
I have same problem too.
I'm getting below error on the client side (ubuntu 13.04 -same machine with
the client)
Error occurred while accessing an OpenSSL library method:
error:14077438:SSL routines:SSL23_GET_SERVER_HELLO:tlsv1 alert internal
error
I'm also getting below error from
use sample-vendor properties for activemq as follows:
# Do not change this unless SPECjms provides a specific class to use here.
providerClass = JNDI
initialContextFactory = org.apache.activemq.jndi.ActiveMQInitialContextFactory
# Fill in the correct hostname and port for your jms server here
Hello,
I'm running ActiveMQ 5.8. I'm trying to use advisory topics to monitore the
processing of the messages by the clients, I have enabled the following
advisory in the configuration file:
/destinationPolicy
policyMap
policyEntries
policyEntry
Hi,
I have installed a Replicated LevelDB Store with 3 zookeeper Server and 3
activemq Server. It works well, but if I test it with jmeter and kill a
activemq-master with kill -9 ( simulate power blackout ), often it works
well but at two times following message was logged endless to the logfile
We have configured ssl using certificate authentication. And followed the
steps given in this link.
http://activemq.apache.org/how-do-i-use-ssl.html.
Activemq started successfully.
Issues faced :
1. A call to the SSPI failed exception raised.
2. If we change the port from 61616 to 61617,
Hello Techies,
We have a setup where there is a data flow from ActiveMQ to JNBridge and
vice versa. We are able to successfully send the data from ActiveMQ to
JNBridge but the reverse condition is not working. We did some analysis and
found that this was due to port on firewall.
We have opened
We have configured ssl using certificate authentication. And followed the
steps given in this link.
http://activemq.apache.org/how-do-i-use-ssl.html.
Activemq started successfully.
Issues faced :
1. A call to the SSPI failed exception raised.
2. If we change the port from 61616 to 61617,
Thanks! Some guys already gave their advices to me and it worked. This
dynamicQueues and dynamicTopics made it work properly.
gtully wrote
org.spec.jms.jndi.template.queue=dynamicQueues/${__name__}
org.spec.jms.jndi.template.topic=dynamicTopics/${__name__}
--
View this message in
Thank you Gary :)
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Message-Expiration-thorugh-broker-tp4672873p4674010.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
The broker camel component should make it easier to do - see
http://activemq.apache.org/broker-camel-component.html
On 7 Nov 2013, at 14:59, Sophia Wright sophiawrigh...@gmail.com wrote:
Thank you Gary :)
--
View this message in context:
Hi,
I am using multi kahaDb in my broker. I am filtering kahadb files for some
destinations and rest other are going to the default folder.
I want to log for each message that in which Kahadb folder it is going. Is
there a way to log this information ?
Thanks,
Sophia
--
View this message in
On 11/07/2013 05:13 AM, darkrwe wrote:
Hello guys,
I have same problem too.
I'm getting below error on the client side (ubuntu 13.04 -same machine with
the client)
Error occurred while accessing an OpenSSL library method:
error:14077438:SSL routines:SSL23_GET_SERVER_HELLO:tlsv1 alert internal
Hi Tim,
thank you for answer.
I installed oracle JDK7 and now i don't get below problems.
Now I just want to summarize what i do.. Because my pem file is problematic
in client side.
Maybe another configuration i could miss.
I'm getting below error on the client side (ubuntu 13.04 -same machine
On 11/07/2013 12:12 PM, darkrwe wrote:
Hi Tim,
thank you for answer.
I installed oracle JDK7 and now i don't get below problems.
Now I just want to summarize what i do.. Because my pem file is problematic
in client side.
Maybe another configuration i could miss.
I'm getting below error on the
I export the below environment parameter.
export ACTIVEMQ_OPTS=-Djava.net.debug=ssl
But i have not seen any ssl handshake between client and broker in the
activeMQBase/data/activemq.log file.
is there another log file that i trace the result?
Thanks.
--
View this message in context:
I think my problem is about below issue:
mikmela wrote
It turned out that the PEM file that was configured as keystore didn't
have a private key.
So, to answer own question
decaf::lang::System::setProperty( decaf.net.ssl.trustStore,
pathToClientTrustStoreInPemFormat);
It is my understanding that expired messages are stored on the ActiveMQ.DLQ
queue. When I start the ActiveMQ broker, I do not see the DLQ defined. If
this is where the expired messages go to, wouldn't it be a default queue for
the default configuration? If not, then do I need to define it
*error:0906D06C:PEM routines:PEM_read_bio:no start line
error:140B0009:SSL routines:SSL_CTX_use_PrivateKey_file:PEM lib
*
appears if a private key is not found during SSL handshake
Overall, looks like you're on a right path...
You enabled client auth... Therefore for successful handshake you
Barry,
ActiveMQ by default auto-creates destinations as it needs/requires
them. You don't have to define the DLQ explicitly. If a message goes
to the ActiveMQ.DLQ, or if a consumer listens to the ActiveMQ.DLQ
queue, then the broker will create it.
You can set up queues ahead of time if you'd
Not sure what you mean. For each message that comes in to the broker,
you want to log which store file it goes in to?
On Thu, Nov 7, 2013 at 8:10 AM, Sophia Wright sophiawrigh...@gmail.com wrote:
Hi,
I am using multi kahaDb in my broker. I am filtering kahadb files for some
destinations and
Would it be possible to try with a 5.10 snapshot? There were some
recent fixes around leveldb replication, and before trying to
reproduce on my side, would be good to know you see it in the latest:
Should work the same for both queue and topic.
Can you verify you're listening to ActiveMQ.MessageConsumed.Topic.topicname?
On Thu, Nov 7, 2013 at 6:12 AM, jstordeur jeremie.stord...@gmail.com wrote:
Hello,
I'm running ActiveMQ 5.8. I'm trying to use advisory topics to monitore the
processing
Actually... after quick browsing the code (and i didn't try it yet...)
it looks like for non-durable subscriptions to a topic, the message
consumed advisory will not be fired because topic.acknowledge(...)
will not be called from TopicSubscription#acknowledge(...). Don't
think this is on purpose,
On 11/07/2013 03:58 PM, Christian Posta wrote:
Actually... after quick browsing the code (and i didn't try it yet...)
it looks like for non-durable subscriptions to a topic, the message
consumed advisory will not be fired because topic.acknowledge(...)
will not be called from
Now, I have a JDBC master/slave cluster: tcp://remote1:61616,
tcp://remote2:61616, tcp:/remote3:61616
I start a VM , application write message to VM, then VM forward messages to
this master/slave cluster.
core code is below:
ActiveMQConnectionFactory factory = new
29 matches
Mail list logo
