reported. I am not aware of any at the moment.
> > >
> > >
> > > So I think it would be considerable safe to do reconnect the POD.
> > >
> > > So a damage in the file system or journal after a failure is IMO a
> > disaster situation. And for th
On Thu, Mar 11, 2021 at 8:53 AM David Martin wrote:
> >>
> >> Hi,
> >>
> >> Looking to host an Artemis cluster in Kubernetes and am not sure how to
> >> achieve full local resilience. (Clusters for DR and remote distribution
> >> will be added
or that I can only think of the mirror to mitigate any of
> that.
>
> On Thu, Mar 11, 2021 at 8:53 AM David Martin wrote:
>>
>> Hi,
>>
>> Looking to host an Artemis cluster in Kubernetes and am not sure how to
>> achieve full local resilience. (Clusters for
situation. And for that I can only think of the mirror to mitigate any of
that.
On Thu, Mar 11, 2021 at 8:53 AM David Martin wrote:
> Hi,
>
> Looking to host an Artemis cluster in Kubernetes and am not sure how to
> achieve full local resilience. (Clusters for DR and remote distrib
wrote:
> Hi,
>
> Looking to host an Artemis cluster in Kubernetes and am not sure how to
> achieve full local resilience. (Clusters for DR and remote distribution
> will be added later using the mirroring feature introduced with v2.16).
>
> It is configured as 3 active
Hi,
Looking to host an Artemis cluster in Kubernetes and am not sure how to
achieve full local resilience. (Clusters for DR and remote distribution
will be added later using the mirroring feature introduced with v2.16).
It is configured as 3 active cluster members using static discovery because
How have you configured your inclusion rules for which destinations are
forwarded through a network of brokers?
http://activemq.apache.org/networks-of-brokers.html has examples of how to
configure this.
Tim
On Wed, Jul 4, 2018, 10:12 PM javier wrote:
> Hi,
>
> I have configured an activemq brid
Hi,
I have configured an activemq bridge against an activemq on another machine.
When I create a topic and send a message, that message arrives at the
bridge.
The problem I have is when I create a second topic, and send a message, this
second message does not reach bridge.
I see that in the first
017 3:27 PM, "czaban" wrote:
> Is it possible to get the current local IP of the client used to connect
> with
> broker? We have few active ip addresses in the same machine and the simple
> Dns.GetHostAddresses(Dns.GetHostName()) is not the solution.
>
>
>
>
Is it possible to get the current local IP of the client used to connect with
broker? We have few active ip addresses in the same machine and the simple
Dns.GetHostAddresses(Dns.GetHostName()) is not the solution.
--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
Thank you Justin for the quick response.
I found even an easier way to achieve the same result: I changed the
configuration of the LDAPLoginModule as follows:
With the attribute *userRoleName=CN* I map the username of the authenticated
user as the role name. Against this role name I will secur
iveMQ Artemis to protect queues for a list
> uf
> users?
>
> In Wildfly / EAP 7 we use as a workaround a local mapping file that defines
> a mapping between users looked up in the AD to local roles.
>
>
>
> --
> Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-
> f2341805.html
>
users looked up in
the AD. But there will be no groups in the AD we can use for authorization
and changes in the AD are not possible.
What is the simplest way in ActiveMQ Artemis to protect queues for a list uf
users?
In Wildfly / EAP 7 we use as a workaround a local mapping file that defines
a
On 10/31/2017 02:47 AM, jchaitanyak wrote:
I am using the apache MQ 5.12
2017-10-31 11:59:01,113 ERROR RequestOut.ExceptionRaised -
== Exception Details Begin =
ErrorMsg:Error connecting to localhost:8161.
StackTrace:
at SUMMITMQ.RequestOut.StartReceiver()
at SUMMITMQ
I am using the apache MQ 5.12
2017-10-31 11:59:01,113 ERROR RequestOut.ExceptionRaised -
== Exception Details Begin =
ErrorMsg:Error connecting to localhost:8161.
StackTrace:
at SUMMITMQ.RequestOut.StartReceiver()
at SUMMITMQ.RequestOut.Process()
InnerException:
System
u can figure out
how many hops the messages has had. 1 means local broker, >1 means a
remote broker.
On Thu, Sep 29, 2016 at 2:23 PM, Justin Bertram wrote:
> I see a couple of options off the top of my head:
>
> 1) Make sure "messages sent via the local broker" have
I see a couple of options off the top of my head:
1) Make sure "messages sent via the local broker" have a unique, consistent
property and simply create your topic subscription to select those messages.
2) Modify your cluster-connection configuration so that the topic in quest
I have a multi-node (static) network of embedded Artemis JMS brokers.
I'm wondering if there is a way to register a JMS listener to a topic,
but somehow distinguish between messages sent via the local broker and
those that come from different nodes in the 'cluster'?
I'
Thanks,
that was it. For some reason, I thought I had to set the element
on a core configuration, but I've added that the the JMS configuration and
it works fine.
Mitchell
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Potential-memory-leak-with-local-
build up in queue #2 since
there's no client to consume them.
Ultimately I think this is a misconfiguration. Remove the core queue you've
configured and see how it goes.
Justin
- Original Message -
From: "mcacker"
To: users@activemq.apache.org
Sent: Thursday,
Hi,
I have a scenario where I have a queue, interServerQueue, for which I create
a local connection and consumer. The queue is sent messages by local and
remote producers. Messages sent to the queue are received and processed by
the local consumer.
A heap dump, however, shows 2 QueueImpl
> On 13 Jul 2016, at 14:41, Tim Bain wrote:
>
> This is new, so please submit a bug in JIRA. Please include as much
> information as you can about your configuration and how your broker is
> being used; because you're seeing problems while no one else is and this
> appears to be code everyone s
havn't found any patterns for when it occurs) one of the
> connection between the hosts closes with the following message:
>
> "Network connection between vm://esb-test-mq01.it.su.se#18 and ssl://
> esb-test-mq02.it.su.se/77.238.37.208:61616 shutdown due to a local error:
message:
"Network connection between vm://esb-test-mq01.it.su.se#18 and ssl://
esb-test-mq02.it.su.se/77.238.37.208:61616 shutdown due to a local error:
java.lang.ArithmeticException: / by zero"
After this the broker never calls back. Yesterday we finally caught this
division with TRA
) one of the
connection between the hosts closes with the following message:
"Network connection between vm://esb-test-mq01.it.su.se#18 and
ssl://esb-test-mq02.it.su.se/77.238.37.208:61616 shutdown due to a local error:
java.lang.ArithmeticException: / by zero"
After this the broker n
ied
to design the master slave cluster in two different machines. Below is the
enivronment details:
apache-activemq-5.13.3
Two Systems(local-master broker and remote-slave broker ) with Ubuntu
Operating system
Created a Shared folder in local system and given all read and write access
to the kahadb fo
Thanks for your reply,
> Can you please share any article or wiki page or example link on how to use
> NFSv4 to achieve my use case defined above.
>
> Thanks
> Srikanth.
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/can-we-share-
-machines-local-and-remote-tp4711666p4711730.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
.org/shared-file-system-master-slave.html) and tried
> to design the master slave cluster in two different machines. Below is the
> enivronment details:
>
> apache-activemq-5.13.3
> Two Systems(local-master broker and remote-slave broker ) with Ubuntu
> Operating system
> Created
Hi Tim,
Thanks for your reply.
I have used the shared filesystem concept (refering
http://activemq.apache.org/shared-file-system-master-slave.html) and tried
to design the master slave cluster in two different machines. Below is the
enivronment details:
apache-activemq-5.13.3
Two Systems(local
other fails.
Tim
On May 6, 2016 10:19 AM, "srikanth.april30"
wrote:
> Hi ActiveMq Team,
> I am working on a POC related to ActiveMq. Does the Master/Slave concept is
> achievable with two ActiveMQ instances (one in local machine and other in
> remote machine) ?
>
> Ple
Hi ActiveMq Team,
I am working on a POC related to ActiveMq. Does the Master/Slave concept is
achievable with two ActiveMQ instances (one in local machine and other in
remote machine) ?
Please help me with some information .
Thanks
Srikanth
--
View this message in context:
http://activemq
that will be useful knowledge in the future...
Am 25.07.2015 um 17:00 schrieb Tim Bain [via ActiveMQ]:
> And have you confirmed that you updated the URI the client uses so it
> refers to the new non-local host? It's a basic thing, but could be
> easy to
> forget.
>
> If you h
And have you confirmed that you updated the URI the client uses so it
refers to the new non-local host? It's a basic thing, but could be easy to
forget.
If you haven't already, enable JMX for your broker. It'll let you see
which clients are successfully connected, how many messa
t;
> I'd be really glad for any advice on how to solve the problem or how to
> debug it.
>
> Kind regards,
>
> David
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Receiving-messages-in-a-topic-works-local-but-not-remote-tp4699825.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
.
Maybe it's a problem with the way I configure the broker? Here's how I do
it:
I'd be really glad for any advice on how to solve the problem or how to
debug it.
Kind regards,
David
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Receiving-messages-in-a-to
this message in context:
http://activemq.2283324.n4.nabble.com/local-tp4688780.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Hi,
I am getting *Thread Local storage limit reached* at initialization of my
application as soon as I increase my thread pool size more then 80.
I am currently having 80 threads and each threads own a connection object
and failover mechanism is on .
Please let me know the reason if possible
"
localQueueName="" />
" />
">
" />
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Remote-Queue-
d to same consumer.
> Is this possible to achieve ?
>
> I tried using jms bridge/virtual destinations but could not figure it out -
> how to this exactly.
>
> Any help or example will be appreciable . Thanks in advance.
>
> --
> View this message in context:
> http://activ
to this exactly.
Any help or example will be appreciable . Thanks in advance.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Remote-Queue-to-Local-Many-quques-or-Local-Topic-tp4653598.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
e.com/embedded-broker-that-can-be-used-for-local-clients-and-remote-clients-tp4586905p4586905.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
By default ActiveMQ uses the $ACTIVEMQ_HOME/data folder. The persistence
adapter typically writes into $ACTIVEMQ_HOME/data/kahadb, whereas
non-persistent msgs may potentially be written to $ACTIVEMQ_HOME/data/tmp.
Queue properties are also defined in the brokers config, e.g. etc/activemq.xml.
Is there any data written by ActiveMQ to local files (not in the
PersistencdAdapter). Where does it store the properties of queues,
destinations, etc.
thanks,
Ravi.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/does-ActiveMQ-write-to-local-file-store
ml
>
>> Can destinations and
>> messages be shared for HA across the geo-redundant nodes?
> Using a network connector you do not share messages between brokers but you
> allow messages to travel between brokers.
> I.e. when a msg travels to a different broker it is deleted on
s between brokers but you
allow messages to travel between brokers.
I.e. when a msg travels to a different broker it is deleted on the local
broker. Msgs only travel to remote brokers within a network of brokers, when
there are consumers registered on the remote broker.
So this will not serve as
Hello ActiveMQ users,
Imagine 4 nodes, 2 per location, on each node on same location/LAN a
shared filesystem (separate node) used by two local brokers in shared
filesystem master slave (SFSMS) configuration. Can destinations and
messages be shared for HA across the geo-redundant nodes?
Can
your case. This can be
> overridden in the jboss -ds.xml descriptor. Check the jboss RAR
> documentation to find the details.
>
> On 27 June 2010 06:46, Edison Melo wrote:
>
>>
>> Please forgive if this is a silly question. I hadn't be able to
>> configure
Hi all,
Short version : I want to define a local address and local port *range* in
the jndi.properties file. Something like java.naming.provider.url = ssl://
10.1.1.123:61617/localhost:60140-60150. That didn't work (obviously). Is
there any way to specify a port range, instead of a port n
on. I hadn't be able to configure
> a
> MDB to use local transactions inside JBoss. If I deploy a MDB with this
> config:
>
> @MessageDriven(
>activationConfig = {
>@ActivationConfigProperty(
>propertyName
Please forgive if this is a silly question. I hadn't be able to configure a
MDB to use local transactions inside JBoss. If I deploy a MDB with this
config:
@MessageDriven(
activationConfig = {
@ActivationConfigProperty(
propert
o-get-ActiveMQ-to-load-in-Eclipse-3.5-launching-local-Tomcat-6-instance-tp26896375p26896375.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
I am trying to connect the local activemq queue to remote jboss queue with
bridge.
It shows nullpointerexception:
ERROR | Failed to initialize the JMSConnector
java.lang.NullPointerException
at javax.naming.InitialContext.getURLScheme(InitialContext.java:228)
at
rod wrote:
Hi-
I am working on a system where we want to send a message each time an entity
is updated. I really want to commit the message to the broker using a local
transaction - I can't use XA. If the local transaction rolls back and the
entity isn't committed, then I don'
Hi-
I am working on a system where we want to send a message each time an entity
is updated. I really want to commit the message to the broker using a local
transaction - I can't use XA. If the local transaction rolls back and the
entity isn't committed, then I don't want th
te is incremented (visible with JMX console)
For each local consumer, ConsumerCount is also incremented.
Messages sent to this queue are delivered to active consumers in accordance
with the ConsumerCount value.
Stopping consumers
---
When a local consumer stops to work, ConsumerCou
Does anybody know why or how this happens.
If both the message broker and one of the clients are running on the same
machine when the broker is killed the client will also terminate.
If the client is running on a different host the client behaves as expected by
reconnecting as soon as the broke
:
>
> Thanks for this help, I'll test that trick
>
> I've got another question on this: Is this parameter wildcard friendly ?
> Can I define for example that all queues named "_local_foo" would be the
> local ones ?
>
>
> Gary Tully wrote:
> >
> >
Thanks for this help, I'll test that trick
I've got another question on this: Is this parameter wildcard friendly ?
Can I define for example that all queues named "_local_foo" would be the
local ones ?
Gary Tully wrote:
>
> check out the "excludedDestinati
check out the "excludedDestinations" attribute of a network xml
configuration <http://activemq.apache.org/networks-of-brokers.html>, using
this you can define local destinations that will not be distributed. This
attribute is a list or queues and or topic names.
Check out an examp
We would elaborate a distributed broker topography in which brokers can also
have "Local queues" e.g non-distributed queues which can actually be used
only into a local context.
Is it existing a way to do that the broker could contain as well distributed
queues which can be rea
Great
Thanks !
2009/1/19 Gary Tully :
> the vm protocol handler supports an embedded broker: scheme where the
> broker configuration uri syntax can be used:
>
> Something like: vm:broker:(tcp://localhost:61616)?persistent=false
>
> see:
> http://activemq.apache.org/vm-transport-reference.html#VM
the vm protocol handler supports an embedded broker: scheme where the
broker configuration uri syntax can be used:
Something like: vm:broker:(tcp://localhost:61616)?persistent=false
see:
http://activemq.apache.org/vm-transport-reference.html#VMTransportReference-AdvancedBrokerConfigurationSyntax
Under debug I could see in the ConnectionFactory :
brokerUrl = vm://localhost?broker.persistent=false,tcp://localhost:61616
I wonder why the TCP port is not opened ;(
2009/1/19 Henri Gomez :
> Hi to all,
>
> I read carefully the docs about declaring an ActiveMQ in Tomcat :
>
> http://activemq.a
Hi to all,
I read carefully the docs about declaring an ActiveMQ in Tomcat :
http://activemq.apache.org/tomcat.html
I need to get ActiveMQ embedded in a webapp and for both in VM clients
but also external clients and want to get the setup in context.xml :
I tried to add in context.xml :
I
08 at 3:09 PM, Badri
> <[EMAIL PROTECTED]> wrote:
>>
>> Hi
>>
>> When I start Active MQ 5.1, I get the folllowing exception (excerpt given
>> below).
>> I did not get this exception before.
>>
>> 2008-08-04 16:24:39,077 DEBUG
ivemq.apache.org/schema/core";
brokerUrl="tcp://localhost:2506"/>
I also commented SUNJMX in activemq-admin.
This configuration gives me the exception -
2008-08-18 15:32:12,739 DEBUG ManagementContext - Failed to
create local registry
java.rmi.server.ExportE
On Mon, Aug 4, 2008 at 3:09 PM, Badri
<[EMAIL PROTECTED]> wrote:
>
> Hi
>
> When I start Active MQ 5.1, I get the folllowing exception (excerpt given
> below).
> I did not get this exception before.
>
> 2008-08-04 16:24:39,077 DEBUG ManagementContext
DEBUG ManagementContext - Failed to
> create local registry
> java.rmi.server.ExportException: internal error: ObjID already in use
> at sun.rmi.transport.ObjectTable.putTarget(ObjectTable.java:169)
> at sun.rmi.transport.Transport.exportObject(Transport.java:75)
> at sun.rmi.
Hi
When I start Active MQ 5.1, I get the folllowing exception (excerpt given
below).
I did not get this exception before.
2008-08-04 16:24:39,077 DEBUG ManagementContext - Failed to
create local registry
java.rmi.server.ExportException: internal error: ObjID already in use
at
tiveMQ-not-starting---Local-host-name-unknown-tp16807262s2354p16808260.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
directory, i am getting the following
> error message:
> Error: Exception thrown by the agent : java.net.MalformedURLException:
> Local
> host name unknown: java.net.UnknownHostException: mysql: mysql
>
> Can anybody let me know what's with this!!!
> --
> View this me
When trying to run activemq from bin directory, i am getting the following
error message:
Error: Exception thrown by the agent : java.net.MalformedURLException: Local
host name unknown: java.net.UnknownHostException: mysql: mysql
Can anybody let me know what's with this!!!
--
View this me
Any help on this issue?
Thanks
Ashish
On Dec 12, 2007 3:26 PM, Ashish Jain <[EMAIL PROTECTED]> wrote:
> Hi,
> I am using ACTIVE MQ 4.1.1. While running a MDB application with XA
> transaction I am getting the following warning message.
>
> 17:12:21,577 WARN [Server
Hi,
I am using ACTIVE MQ 4.1.1. While running a MDB application with XA
transaction I am getting the following warning message.
17:12:21,577 WARN [ServerSessionImpl:10] Local transaction had not
been commited. Commiting now.
My application is running fine. But I am worried if this will have
If I consume a message from a queue within the context of a local transaction
I can rollback the transaction leaving the message in the queue. What if my
consumer crashes (e.g. due to hardware failure), will the transaction be
automatically rolled back? What if the broker itself crashes (e.g. in
On 6/8/07, David Budworth <[EMAIL PROTECTED]> wrote:
I have a mechanism I've written that uses dynamic proxies to intercept hits
to JMX mbeans that checks to see if a local instance is up and initialized,
if not, it will send a JMS message to a centralized broker to see if another
ser
I have a mechanism I've written that uses dynamic proxies to intercept hits
to JMX mbeans that checks to see if a local instance is up and initialized,
if not, it will send a JMS message to a centralized broker to see if another
server has the service available to service the request.
Basi
78 matches
Mail list logo
