Use the "getQueueNames" method on the address control [1], e.g.:
try (ServerLocator locator =
ActiveMQClient.createServerLocator("vm://0");
ClientSessionFactory factory = locator.createSessionFactory();
ClientSession session = factory.createSession(false, true,
true))
Hello,
I am using ActiveMQClient to talk to the artemis broker. I am trying to
move all the messages in a topic to another topic programmatically. The
only pieces of info I have is the broker URL, username, password and the
topic name (the address). However, since there are quite a number of
Is there anything I can do to help get the PR moving?
Is it still in draft due to the Travis failures?
From: Clebert Suconic
Date: Friday, October 14, 2022 at 9:41 AM
To: users@activemq.apache.org
Subject: Re: Mirror compatibility across versions
It's being done as part of this PR:
For fair queueing I would need to be able to classify messages as belonging to
a particular agent, and then I would need consumers to round robin on the
agents with messages in the queue. It’s about not letting one source monopolize
the consumers, not ensuring that all the consumers take work.
There's a bug fix I'm pushing now on the page counters:
https://github.com/apache/activemq-artemis/pull/4271
notice there's no page loss.. just the counter could go off sync if paging.
I'm also going to add an option to remove the page-counters record soon.
On Thu, Oct 20, 2022 at 4:37 PM
Glad to hear! If you would, please share what the fix was so other users will
be able to match up this error message with a solution when searching the web.
Thanks!
Matt Pavlovich
> On Oct 25, 2022, at 11:42 AM, Wendell Hatcher
> wrote:
>
> We resolved this. Thanks for the info.
>
> On
We resolved this. Thanks for the info.
On Tue, Oct 25, 2022 at 11:30 AM Wendell Hatcher <
wendellhatcher1...@gmail.com> wrote:
> Hello, I am getting the following error message within amq. Can someone
> please give me direction to resolving this issue?
>
> Message Code: JAVA PLUGIN_1762
>
Hello Wendell-
That error seems to indicate some sort of protocol mismatch or network timeout
issue.
Are you able to obtain the logs from the server side?
What version of ActiveMQ client jar?
What version of ActiveMQ server?
Thanks,
Matt Pavlovich
> On Oct 25, 2022, at 10:30 AM, Wendell
Hello, I am getting the following error message within amq. Can someone
please give me direction to resolving this issue?
Message Code: JAVA PLUGIN_1762
Message: [ERROR] Failed to create JMS session: Wire format negotiation
timeout: peer did not send his wire format.Exception Stack:
