Browsing the queue via the web console for the slave broker should be a
good test; if you're able to do that, the master failed to lock the slave
out of the KahaDB data.
Tim
On Thu, Apr 28, 2016 at 2:14 PM, Christopher Fogarty <
christopher.foga...@versiant.com> wrote:
> I have the disk a part o
I think you want to be using interceptors (
http://activemq.apache.org/interceptors.html), not consuming from a queue
and then publishing back to the same queue. I've always believed that
embedded Camel routes couldn't be inserted into the middle of accepting a
message (which is what you really wa
Kevin, welcome back.
What's your network of brokers topology, and your client connection URL?
Could it be that all your clients are on that one broker (which would
explain heavy load), or are you sure your clients are evenly distributed?
Also, have you set decreaseNetworkConsumerPriority to true?
Yes.
> On Apr 28, 2016, at 3:25 PM, Allan Wax wrote:
>
> I have an existing broker with multiple queues that basically
> store-and-forward the messages to a single central site. I now want to
> introduce a new queue that only runs locally and does not get forwarded to
> the central site. This
I have an existing broker with multiple queues that basically
store-and-forward the messages to a single central site. I now want to
introduce a new queue that only runs locally and does not get forwarded to
the central site. This queue will be read locally in another thread in the
application.
I have the disk a part of its on vggroup and an lv carved out of that with ext
4 file system on it. This is mounted on both systems and I am able to start
active mq fine. But would feel a lot better validating that only one of the two
nodes actually has a lock. I would love even more to verify t
Definitely, Artemis is pretty speedy and resilient.
One idea I would recommend, you can leverage Apache Camel to forward the
messages from the local broker to the remote broker.
Regarding embedding, the guide is pretty straightforward:
http://activemq.apache.org/artemis/docs/1.2.0/embedding-activ
One more thing...
Can you point me to the bit of documentation about clients and embedded brokers
that cause you some confusion? Perhaps I can clarify the language a bit to
make things more understandable.
Justin
- Original Message -
From: "Alessandro Manzoni"
To: users@activemq.apa
You can certainly embed Artemis in your application. Then you can send
messages to the local broker and then configure a bridge to forward the
messages to the remote broker. The bridge will deal with the network outages
while your clients will be free to send messages to the local broker witho
Artemis (aka ActiveMQ v6.x) is still in heavy development, I suggest
using the production-ready ActiveMQ 5.x releases.
You can absolutely embed ActiveMQ to achieve what you are trying to do--
this sounds like a "store and forward" use case.
-Matt Pavlovich
On 4/16/16 4:40 AM, Alessandro Manz
Chris-
What file system are you using to share the mount? The filesystem would
need to support distributed locking (many "shareable filesystems" don't
do this properly.
The other approach is to use the shared filesystem for KahaDB and a
database lease-locker to work around the
most-shared-
Does anybody have any insight on this?
The first call to receive apparently works or returns. The subsequent call
to receive() never returns even with messages waiting or with a timeout set
receive(1000)
Any help would be very much appreciated.
Thanks!
--
View this message in context:
http
I’m trying to use the ActiveMQ Broker Camel Component to add some JMS user
properties to messages as they arrive at the broker. I’m using a wildcard on
the from so I can apply the same logic to a set of topics or queues, but I
can’t seem to send the message back to the original queue.
Without
We have a problem where all work is given to ONE host in our cluster. What
then happens is that this box goes to 100% CPU and other boxes are idle and
need more work.
We have an activemq setup where we create 16 connections to ActiveMQ (one
per core), and then one session per thread with a prefetc
I have set up two servers:
Both CENTOS with a shared SAN disk mounted and active on both nodes.
I have set up ActiveMQ 5.6
I am able to start each with the following configuration
Each node can and does start, but how can I test, or what do I look for to make
sure that file locking is
Persistent messages on Topics only go into the KahaDB store if there is
a durable topic subscription for that Topic otherwise they will never go
into the store as a standard Topic subscription doesn't have any
guarantees about message that were delivered while it is off line being
sent to it.
Hello.
I have a question regarding the ActiveMQ temp usage. (The ActiveMQ version
is 5.10.0 but also checked with latest 5.13.2; as storage I´ve tested with
KahaDb and mKahadb)
In our system we have some queues and topics. The topics has persistent
messages; the queues has combinations of persisten
Hello.
Standalone broker conf:
PAGE
1048576
Other settings are default.
"tcp://localhost:61616" - is the "artemis" multiprotocol acceptor
Normal case:
Behaviour: Paging works.
Client: artemis-jms-client v1.2.0
Class: org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory
Code:
Connec
Hi to everyone!
I'm searching feedbacks about a new implementation of
org.apache.activemq.artemis.core.io.SequenceFile that provides (a lot)
faster performances of both the "plain" Nio and libaio implementations: in
"pure Java" (*libaio is not available for windows* AFAIK)!
This implementation cou
19 matches
Mail list logo
