Looked at the docs again.
The reason for this behavior is that networkTTL defaults to "1" and limits
how many jumps the subscription or message can do across a network of
brokers. Increased it to "10" and my network works!
I suggest to put it more prominently on a
http://activemq.apache.org/netwo
I'm using Apache ServiceMix 4.5.3 with ActiveMQ 5.7 in it.
I have 3 nodes all with exactly same config (except karaf name and ActiveMQ
broker name - they are different):
- hub
- spoke1
- spoke2
spoke1 is connected to hub via duplex openwire network connector.
spoke2 is connected to hub via duplex
if you're using a pool, usually the pool is in charge of shutting down
connections.
This might be it to do it manually:
http://docs.spring.io/spring/docs/2.5.6/api/org/springframework/jms/connection/SingleConnectionFactory.html#destroy()
But it probably gets handled when the spring context gets s
> it's possible the broker gets shut down first before all the client
connections are properly shut down?
How can I determine this?
What triggers the shutdown of a client connection? (how/where?)
--
View this message in context:
http://activemq.2283324.n4.nabble.com/When-will-activemq-core-5-9
Thanks Tim,
This looks like exactly like what I need.
-Vladimir
On 12/5/13, 5:02 PM, "Timothy Bish" wrote:
>On 12/05/2013 04:55 PM, Vladimir Sutskever wrote:
>> Hi
>>
>> I am using the a failover URI with ActiveMQ's Connection Factory for a
>>Java message consumer.
>>
>> failover:(tcp://prima
On 12/05/2013 04:55 PM, Vladimir Sutskever wrote:
Hi
I am using the a failover URI with ActiveMQ's Connection Factory for a Java
message consumer.
failover:(tcp://primary:61616,tcp://secondary:61616)?randomize=false
The connection successfully fails over to the secondary host once primary h
Hi
I am using the a failover URI with ActiveMQ's Connection Factory for a Java
message consumer.
failover:(tcp://primary:61616,tcp://secondary:61616)?randomize=false
The connection successfully fails over to the secondary host once primary host
is down.
But it won't get re-established back w
I tried setting trackMessages=true. Still I get duplicate messages.
failover:(${jms.broker1.uri},${jms.broker2.uri})?randomize=false&jms.prefetchPolicy.queuePrefetch=1&maxReconnectAttempts=-1&trackMessages=true
I also added auditNetworkProducers in the tran
Hi
I am using Active MQ 5.7.
1) If some messages are stuck in a particular queue, does it cause any
impact on the Ack of other messages which went through that same queue?
2) Does ActiveMQ replay all the messages which was put on to that queue
since the stuck messages entered the queue? If the q
well if you're pooling your connections here, it's possible the broker
gets shut down first before all the client connections are properly
shut down? then you would see that error...
On Thu, Dec 5, 2013 at 1:39 PM, edbras wrote:
> It's hard to create an isolated test app, found it hard where to s
It's hard to create an isolated test app, found it hard where to start (a
client app that is bit large).
But I did some more digging and found the following:
In the unit tests I create a global Spring ApplicationContext and call the
method ctx.registerShutdownHook() on the context such that all be
think you could put together a bare-bones unit test that shows this
and send it to me?
On Thu, Dec 5, 2013 at 11:06 AM, edbras wrote:
> It's working now, but only get this strange shutdown exception at the end
> when running it embedded in spring during unit tests.
> See error below.
> I noticed
Thank you for this explanation
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Transactions-in-Stomp-tp4675080p4675214.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
It's working now, but only get this strange shutdown exception at the end
when running it embedded in spring during unit tests.
See error below.
I noticed more people experience this same error, but I can't find a good
way to solve it. Any idea? Strangely I didn't have this with version 5.7.0.
Any
there is no "automatic" redelivery on the client side the way activemq
libraries do for openwire. that's because a STOMP client can be
written by anyone and the Spec doesn't address redelivery on the
client side. But, you are of course able to build in a redelivery
functionality yourself.
if you d
Yes, that is fine. But my question is " Why there is NO message redelivery in
case of STOMP transactions (like JMS transactions have) ?
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Transactions-in-Stomp-tp4675080p4675211.html
Sent from the ActiveMQ - User mailing li
1 - Correct.
2 - I actually haven't used that myself, I'd give it a whirl.
3 - To commit yourself you need to change the Ack mode, this is how
you'd do batches for example with transacted mode.
On Dec 5, 2013, at 10:20 AM, badrinana wrote:
> Hi Johan,
>
> I am assuming if I don't explicit
"export ACTIVEMQ_USER="
You may wish to check the scripts you're running to make sure they're
not purposefully setting the ACTIVEMQ_USER (which is likely)
or, install activemq somewhere where the 'activemq' user has privileges.
On Thu, Dec 5, 2013 at 9:39 AM, Chamila Wijayarathna
wrote:
> How c
Transactions allow you to process a "unit of work" or "group messages together"
ACK/NACK aren't applied on the broker until the transaction has been committed.
On Thu, Dec 5, 2013 at 9:09 AM, Sophia Wright wrote:
> Thanks,
> I am just little bit confused in case of CLIENT_ACK mode in STOMP
> tr
Hi Johan,
I am assuming if I don't explicitly add acknowledge=auto in the spring.xml,
all messages should ideally be Acked automatically. 1) Is the assumption
right?
Reading this jira: https://issues.apache.org/jira/browse/AMQ-3576
auditNetworkProducers - network issues / possible stuck
How can I solve it?
On Thu, Dec 5, 2013 at 8:11 PM, Christian Posta
wrote:
> looks like the script in your distro is changing to 'activemq' user
> which doesn't have permissions to write into your home directory.
>
> On Thu, Dec 5, 2013 at 1:48 AM, Chamila Wijayarathna
> wrote:
> > Hello all,
>
> yah, if using the spring config, you may want activemq-spring also
Yes of course, sounds kind of logic ;)..
And yes, that did the trick. I now have:
activemq-broker, activemq-client, activemq-spring,
activemq-activemq-kahadb-store
Which seems to work fine.
--
View this message in context:
ht
Thanks,
I am just little bit confused in case of CLIENT_ACK mode in STOMP
transaction.
At consumer side,
When consumer is running and throwing exception while processing the message
(consumer doesn't stop, it keeps on running), there is no redelivery of
message.
Even if i uses transactions the
Christian sums it up pretty nicely. However if you insist that using
advisories is the way to go there are some examples of using advisory
consumers in the CMS examples dir. Also in the 3.8.0 line there is now
a DestinationSource in CMS that you can get from the Connection instance
which will
So the bottom line for this is simple, and Tim already mentioned this
in the other thread:
Enable security (http://activemq.apache.org/security.html) and don't
let the producer user "create" any destinations. Then allow the
consumer user to create destinations. Then you can do what you (or the
OP
looks like the script in your distro is changing to 'activemq' user
which doesn't have permissions to write into your home directory.
On Thu, Dec 5, 2013 at 1:48 AM, Chamila Wijayarathna
wrote:
> Hello all,
> I downloaded activeMQ binary distribution and extracted on my computer.
> When I ran "su
yah, if using the spring config, you may want activemq-spring also
On Thu, Dec 5, 2013 at 5:01 AM, edbras wrote:
>> I think activemq-broker and activemq-kahadb-store should be enough.
> If I do so, I do get the xml ns error below.
>
> If I include the activemq-all, it works, but then I get other
> I think activemq-broker and activemq-kahadb-store should be enough.
If I do so, I do get the xml ns error below.
If I include the activemq-all, it works, but then I get other conflicting
issues like slf4j, geronimo, etc...
Example usage:
xmlns:amq="http://activemq.apache.org/schema/core";
B
On 12/05/2013 02:57 AM, Nikolaus Klimek wrote:
Hello,
because our previous SLES Version does not support required apr-version, we
used the ActiveMQ C++ Client 2.2.6, which was compiled to a shared
object/library and called by a cobol application (via CALL). This
combination
works fine.
Actually
On 12/05/2013 01:43 AM, andrewp wrote:
Whilst trying to install ActiveMQ as a windows service, I found this issue
with the wrapper.conf out of the box configuration. (apache-activemq-5.9.0)
wrapper.java.additional.15=-Djava.security.auth.login.config=%ACTIVEMQ_CONF%/login.config
You will no
Hi all,
I am using the cms activemq library, in my porjet, and I have the following
problem:
under windows my own library has 3 Mo size
And on the linux os, the size growing up at 14 Mo, so why ? and how have the
minus library size ?
Thanks a lot
--
View this message in context:
http://activ
Hello all,
I downloaded activeMQ binary distribution and extracted on my computer.
When I ran "sudo sh activemq start" from bin folder I get this response [1].
What is wrong here?
1. https://gist.github.com/cdwijayarathna/7802123
--
*Chamila Dilshan Wijayarathna,*
SMIEEE, SMIESL,
Undergraduate,
32 matches
Mail list logo
