Re: Message Ordering across Networked Brokers

[Tim Bain]

I haven't used JMSXGroupid myself, so everything I say is based on what
I've read, not what I've done.  With that said...

I believe that JMSXGroupid should be respected across the entire network of
brokers (NoB).  When Broker A allocates a given JMSXGroupid to a given
consumer, I believe that it will let Broker B know about that allocation,
so messages with a JMSXGroupid of 1 that are produced to Broker B should be
forwarded to Broker A rather than delivered to a local consumer on B.  So
ActiveMQ should already be able to give you the ability to deliver all of
those messages to a single consumer.

But having every message go to a single consumer isn't the same as having
all messages go to that consumer in the order in which they were
published.  Like I said in my first email, delivery to a single consumer is
in-order **from the perspective of the broker to which it is connected**.
>From Broker A's perspective, a message from Producer 2 on Broker B is
published when the message is published from Broker B to Broker A, not when
it is published from Producer 2 to Broker B.  So all the messages published
directly to Broker A will be in order relative to one another, and all the
messages published to Broker B and then forwarded to Broker A will be in
order relative to one another, but the ordering of the messages in the two
streams relative to one another may not be in the order in which they were
actually produced.

This is both the beauty and the limitation of the ActiveMQ model: the
perspective of any given broker generally spans only that one broker and
the things it can see, but for some features there is no ability to
consider the entire network of brokers.  This is both elegant (because it
allows a simple implementation that still allows you to build arbitrarily
complex networks of brokers) and limiting (because it can be difficult or
impossible to support certain functionality that requires a whole-network
view).

Tim

On Sun, Aug 7, 2016 at 6:54 AM, Dmtiriy  wrote:

> I guess what I was trying to ask is that if BrokerA on JVM1 registers a
> consumer on Queue-1 w/ JMSXGroupid of 1, can networked BrokerB on JVM2
> register a different consumer on same Queue-1 w/ same JMSXGroupid of 1.  Do
> networked brokers have a way to preserve single consumer per unique
> JMSXGroupid and therefore order across network brokers?
>
> You kind of answered that question already that order not preserved across
> network brokers even when JMSXGroupid is used and based on my tests with
> multiple consumers per JMSXGroupid (1 consumer per broker per jvm per
> JMSXGroupid)
>
> What is the best approach to preserve message order across embedded
> brokers?
> Is master/slave setup w/ replicated data store a better option in this case
> or some type of distributed queue setup?
>
>
>
> --
> View this message in context: http://activemq.2283324.n4.
> nabble.com/Message-Ordering-across-Networked-Brokers-
> tp4715070p4715110.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>

Re: Postgresql Database Lock Issue in Master-Slave setup

[Tim Bain]

We don't see a lot of traffic on this list about people using PostgreSQL
(or other SQL data stores, for that matter), and I've seen it said that
there's been less effort spent to test/maintain/improve the JDBC store
code, so it's possible that there are bugs that haven't been found yet, and
this could be one of those.

Can you tell us more about how you shut down the master?  Did you shut down
the ActiveMQ instance itself, or just pull the plug on the server, or...?

And did the slave never successfully start, or just not for some short
amount of time?  The JDBC locker (
http://activemq.apache.org/pluggable-storage-lockers.html) has a
lockKeepAlive period; is it possible that you stopped letting the slave try
to reconnect before that period had elapsed?

Tim

On Sun, Aug 7, 2016 at 10:15 PM, davidyce  wrote:

> Hi,
>
> We have a problem when we shut down serverA (hosting amq master), server B
> (hosting amq slave) did not run as Master.  In the end, amq becomes
> blocked.
> No incoming, no outgoing messages.  Our initial investigation is due to the
> amq slave not able to acquire the database lock which amq master is still
> holding on.
>
> OS: Centos 7
> Activemq version:5.9.0
> Postgre database:9.5.3
> amq master:61616
> amq slave:61617
>
> Appreciate any help.
>
> Thanks in advance.
>
>
>
> --
> View this message in context: http://activemq.2283324.n4.
> nabble.com/Postgresql-Database-Lock-Issue-in-Master-
> Slave-setup-tp4715112.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>

RE: Problem Connecting Client To Message Broker

[Michael.CTR.Tarullo]

Thanks Tim.  I think I have resolved it.  You are correct that it is a network 
problem.  We believe it is related to firewall issues on the two remote VM's 
acting as the JMS clients.

Just so you know our network admins did confirm the existence of the firewalls 
on the VM's and I also installed the app on the VM running the message broker 
and had no problem connecting with that deployment!!!

Looks like I just have to get them to open 61616 on the firewalls and I should 
be OK.

Thanks for getting back to me.

Michael Tarullo
Contractor (Engility Corp)
Software Engineer
FAA WJH Technical Center
(609)485-5294

-Original Message-
From: tbai...@gmail.com [mailto:tbai...@gmail.com] On Behalf Of Tim Bain
Sent: Monday, August 08, 2016 2:23 PM
To: ActiveMQ Users
Subject: Re: Problem Connecting Client To Message Broker

If you have multiple NICs, it's possible for the ping to resolve but the Java 
client not to if they're using different NICs for their connections.

Either way, this is definitely a networking problem that we're not going to be 
able to help you much with.

Tim

On Aug 8, 2016 9:54 AM,  wrote:

> I am trying to connect an ActiveMQ client to the ActiveMQ message broker.
>
> I am running my client and the message broker on separate Linux VM's.  
> The message broker is started and I can access it with the ActiveMQ 
> web console.  I can also ping the message broker VM from the client VM 
> successfully.
>
> However when I run my client app I get a Java net NoRouteToHostException.
>
> I have our network admin's looking into this now, but have received no 
> response yet.  I thought while I was waiting for them I'd see if 
> anyone here could provide any help.
>
> Thanks,
> Mike
>
> Michael Tarullo
> Contractor (Engility Corp)
> Software Engineer
> FAA WJH Technical Center
> (609)485-5294
>
>

Re: Problem Connecting Client To Message Broker

[Tim Bain]

If you have multiple NICs, it's possible for the ping to resolve but the
Java client not to if they're using different NICs for their connections.

Either way, this is definitely a networking problem that we're not going to
be able to help you much with.

Tim

On Aug 8, 2016 9:54 AM,  wrote:

> I am trying to connect an ActiveMQ client to the ActiveMQ message broker.
>
> I am running my client and the message broker on separate Linux VM's.  The
> message broker is started and I can access it with the ActiveMQ web
> console.  I can also ping the message broker VM from the client VM
> successfully.
>
> However when I run my client app I get a Java net NoRouteToHostException.
>
> I have our network admin's looking into this now, but have received no
> response yet.  I thought while I was waiting for them I'd see if anyone
> here could provide any help.
>
> Thanks,
> Mike
>
> Michael Tarullo
> Contractor (Engility Corp)
> Software Engineer
> FAA WJH Technical Center
> (609)485-5294
>
>

Re: Who uses ActiveMQ in Finance / Banking / Markets?

[Hassen Bennour]

Hello AJK,

thank you for sharing your informations, i'm not expert in sonicMQ
(CxMessenger) but as i see it's very easy to work with AMQ than
last CxMessenger version, to configure, for some AMQ possibilities too like
message routing,  destination Interceptors, retroactive consumers, virtual
& composite Destinations...



Kind regards.

*BENNOUR HASSEN*

*SOA **Architect **/ **Java **Software Engineer*

2016-08-08 16:42 GMT+02:00 ActiveMQ Investigation <
ajay.ku...@winterflood.com>:

> Hello Hassen,
>
>
>
> Reasons:
>
> 1. Our last upgrade of SonicMQ was 10 years ago. We would like to look at
> alternatives as well. Specially when we are looking for a product for C++,
> Java, Progress, c#.NET etc. So something which fits for all and with a
> degree of high performance, scalability and reliability.
>
> 2. Why ActiveMQ - Openness - Most popular open source. We are comfortable
> with Open Source space. Not tied to a single company. Thought about other
> products like IBM one and RabbitMQ but ActiveMQ will do the job for us. We
> don't do any complex stuff like network of brokers or constantly open and
> close producer / consumers.
>
> 3. Benchmarking:
>
> Here is one of the queries posted by me in past. It includes links for
> benchmarking I did. I must admit that it's based on our use case scenario
> only. But overall, hopefully it will help.
>
> http://activemq.2283324.n4.nabble.com/Active-MQ-Performance-tc4712952.html
>
> It's for C++/Java/Progress (we say it spark). This is on like for like
> system.
>
> Happy to help if any queries.
>
> Thanks
> AJK
>
>
>
>
> --
> View this message in context: http://activemq.2283324.n4.
> nabble.com/Who-uses-ActiveMQ-in-Finance-Banking-Markets-
> tp4715117p4715141.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>

Problem Connecting Client To Message Broker

[Michael.CTR.Tarullo]

I am trying to connect an ActiveMQ client to the ActiveMQ message broker.

I am running my client and the message broker on separate Linux VM's.  The 
message broker is started and I can access it with the ActiveMQ web console.  I 
can also ping the message broker VM from the client VM successfully.

However when I run my client app I get a Java net NoRouteToHostException.

I have our network admin's looking into this now, but have received no response 
yet.  I thought while I was waiting for them I'd see if anyone here could 
provide any help.

Thanks,
Mike

Michael Tarullo
Contractor (Engility Corp)
Software Engineer
FAA WJH Technical Center
(609)485-5294

[ANNOUNCE] Apache ActiveMQ 5.14.0 Release

[Christopher Shannon]

Hi everyone,

The ActiveMQ team is pleased to announce that Apache ActiveMQ 5.14.0 has
now been released.

A list of issues resolved in this release is available here:
https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12311210=12334188

The Wiki page for the release is here:
http://activemq.apache.org/activemq-5140-release.html

A big thanks to everyone who contributed to this release.

Re: Who uses ActiveMQ in Finance / Banking / Markets?

[ActiveMQ Investigation]

Thanks JB. I understand. 

I was looking for some names where it's a bit of public information. I have
searched on net and couldn't find much info on who uses it. There is a web
page on ActiveMQ website but can't reason them as they don't relate to our
domain. 

Thanks
AJK



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Who-uses-ActiveMQ-in-Finance-Banking-Markets-tp4715117p4715142.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Who uses ActiveMQ in Finance / Banking / Markets?

[ActiveMQ Investigation]

Hello Hassen,



Reasons:

1. Our last upgrade of SonicMQ was 10 years ago. We would like to look at
alternatives as well. Specially when we are looking for a product for C++,
Java, Progress, c#.NET etc. So something which fits for all and with a
degree of high performance, scalability and reliability.

2. Why ActiveMQ - Openness - Most popular open source. We are comfortable
with Open Source space. Not tied to a single company. Thought about other
products like IBM one and RabbitMQ but ActiveMQ will do the job for us. We
don't do any complex stuff like network of brokers or constantly open and
close producer / consumers.

3. Benchmarking:

Here is one of the queries posted by me in past. It includes links for
benchmarking I did. I must admit that it's based on our use case scenario
only. But overall, hopefully it will help.

http://activemq.2283324.n4.nabble.com/Active-MQ-Performance-tc4712952.html

It's for C++/Java/Progress (we say it spark). This is on like for like
system.

Happy to help if any queries.

Thanks
AJK




--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Who-uses-ActiveMQ-in-Finance-Banking-Markets-tp4715117p4715141.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

ArrayIndexOutOfBoundsException in ActiveMQ v5.11.1

[xabhi]

Hi ActiveMQ devs,

I observed below ArrayIndexOutOfBounds exception in my production setup and
it caused high non-persistent memory usage on the affected topic due to
transaction rollbacks. It is not clear why this happened.

Could you please help in investigating this? What could be the possible
causes for this?

[ 2016-08-08 06:37:34,321 [ActiveMQ Transport:
tcp://mqbrokerprod.deshaw.com/149.77.3.169:61616@52260] 
failover.FailoverTransport.handleTransportFailure():260 WARN ]: Transport
(tcp://mqbrokerprod.deshaw.com/149.77.3.169:61616@52260) failed, reason:  ,
attempting to automatically reconnect
java.io.IOException: Unexpected error occured:
java.lang.ArrayIndexOutOfBoundsException: 12851
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:203)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.ArrayIndexOutOfBoundsException: 12851
at
org.apache.activemq.openwire.OpenWireFormat.getFromUnmarshallCache(OpenWireFormat.java:534)
at
org.apache.activemq.openwire.v10.BaseDataStreamMarshaller.tightUnmarsalCachedObject(BaseDataStreamMarshaller.java:148)
at
org.apache.activemq.openwire.v10.MessageMarshaller.tightUnmarshal(MessageMarshaller.java:75)
at
org.apache.activemq.openwire.v10.ActiveMQMessageMarshaller.tightUnmarshal(ActiveMQMessageMarshaller.java:66)
at
org.apache.activemq.openwire.v10.ActiveMQTextMessageMarshaller.tightUnmarshal(ActiveMQTextMessageMarshaller.java:66)
at
org.apache.activemq.openwire.OpenWireFormat.tightUnmarshalNestedObject(OpenWireFormat.java:445)
at
org.apache.activemq.openwire.v10.BaseDataStreamMarshaller.tightUnmarsalNestedObject(BaseDataStreamMarshaller.java:125)
at
org.apache.activemq.openwire.v10.MessageDispatchMarshaller.tightUnmarshal(MessageDispatchMarshaller.java:71)
at
org.apache.activemq.openwire.OpenWireFormat.doUnmarshal(OpenWireFormat.java:354)
at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:268)
at
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:221)
at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:213)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196)
... 1 more

Thanks,
Abhi



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/ArrayIndexOutOfBoundsException-in-ActiveMQ-v5-11-1-tp4715139.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: system property

[Hassen Bennour]

Hello,

If it is on startup of the broker may be with PropertyPlaceholderConfigurer
for the libs configured with spring like this


file:${activemq.conf}/file.properties




SYSTEM_PROPERTIES_MODE_FALLBACK (default)
  Check system properties if not resolvable in the specified properties.
SYSTEM_PROPERTIES_MODE_NEVER
  Never check system properties.
SYSTEM_PROPERTIES_MODE_OVERRIDE
  Check system properties first, before trying the specified properties.




Kind regards.

*BENNOUR HASSEN*

*SOA **Architect **/ **Java **Software Engineer*

2016-08-06 12:59 GMT+02:00 sekaijin :

> Hi
>
> some lib used by ActiveMQ, is configured through the system properties.
> ActiveMQ can be configured via the command line by adding
> -DthePropName = Value
>
> is it possible to define it via ActiveMQ configuration files.
> like activemq.xml or properties file
>
> A+JYT
>
>
>
> --
> View this message in context: http://activemq.2283324.n4.nab
> ble.com/system-property-tp4715105.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>

Re: Message Ordering across Networked Brokers

[Dmtiriy]

I guess what I was trying to ask is that if BrokerA on JVM1 registers a
consumer on Queue-1 w/ JMSXGroupid of 1, can networked BrokerB on JVM2
register a different consumer on same Queue-1 w/ same JMSXGroupid of 1.  Do
networked brokers have a way to preserve single consumer per unique
JMSXGroupid and therefore order across network brokers?

You kind of answered that question already that order not preserved across
network brokers even when JMSXGroupid is used and based on my tests with
multiple consumers per JMSXGroupid (1 consumer per broker per jvm per
JMSXGroupid)

What is the best approach to preserve message order across embedded brokers? 
Is master/slave setup w/ replicated data store a better option in this case
or some type of distributed queue setup?



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Message-Ordering-across-Networked-Brokers-tp4715070p4715110.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

system property

[sekaijin]

Hi

some lib used by ActiveMQ, is configured through the system properties.
ActiveMQ can be configured via the command line by adding
-DthePropName = Value

is it possible to define it via ActiveMQ configuration files.
like activemq.xml or properties file

A+JYT



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/system-property-tp4715105.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Who uses ActiveMQ in Finance / Banking / Markets?

[Jean-Baptiste Onofré]

Hi

I can't give names but I can confirm that I have customers in finance and bank 
using ActiveMQ in production.

Regards
JB



On Aug 8, 2016, 14:02, at 14:02, ActiveMQ Investigation 
 wrote:
>Hello All,
>
>We are looking for replacing SonicMQ with ActiveMQ. After all
>benchmarking
>etc., I am preparing a summary. I need few examples of companies using
>ActiveMQ in Finance. Can anyone help to suggest who is using it in
>Finance/Banking space. Any big names. IF ActiveMQ is not most popular
>then
>which one is in Financial markets.
>
>Although just example names, I am happy to get a pm to my inbox if this
>is
>something which shouldn't be on forums. Any pointers no matter how
>little
>are welcome.
>
>
>Thanks in advance.
>AJK
>
>
>
>
>
>--
>View this message in context:
>http://activemq.2283324.n4.nabble.com/Who-uses-ActiveMQ-in-Finance-Banking-Markets-tp4715117.html
>Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Who uses ActiveMQ in Finance / Banking / Markets?

[Hassen Bennour]

Hello AJK,

Can i ask you please :
1- for wich reasons you choosed to drop SonicMQ.
2- Replacing it by ActiveMQ.
3- it is possible to share your benchmarking... ?

I'm facing the same case and another benchmarking can help.

Thank you.




Kind regards.

*BENNOUR HASSEN*

*SOA **Architect **/ **Java **Software Engineer*

2016-08-08 13:16 GMT+02:00 ActiveMQ Investigation <
ajay.ku...@winterflood.com>:

> Hello All,
>
> We are looking for replacing SonicMQ with ActiveMQ. After all benchmarking
> etc., I am preparing a summary. I need few examples of companies using
> ActiveMQ in Finance. Can anyone help to suggest who is using it in
> Finance/Banking space. Any big names. IF ActiveMQ is not most popular then
> which one is in Financial markets.
>
> Although just example names, I am happy to get a pm to my inbox if this is
> something which shouldn't be on forums. Any pointers no matter how little
> are welcome.
>
>
> Thanks in advance.
> AJK
>
>
>
>
>
> --
> View this message in context: http://activemq.2283324.n4.
> nabble.com/Who-uses-ActiveMQ-in-Finance-Banking-Markets-tp4715117.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>

Who uses ActiveMQ in Finance / Banking / Markets?

[ActiveMQ Investigation]

Hello All,

We are looking for replacing SonicMQ with ActiveMQ. After all benchmarking
etc., I am preparing a summary. I need few examples of companies using
ActiveMQ in Finance. Can anyone help to suggest who is using it in
Finance/Banking space. Any big names. IF ActiveMQ is not most popular then
which one is in Financial markets.

Although just example names, I am happy to get a pm to my inbox if this is
something which shouldn't be on forums. Any pointers no matter how little
are welcome.


Thanks in advance.
AJK





--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Who-uses-ActiveMQ-in-Finance-Banking-Markets-tp4715117.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Using Infinispan or JBoss Data Grid as persistent message store for A-MQ

[jsdads11]

Has anyone got experience of using Infinispan or JBoss Data Grid as a message
store for handling message persistence - particularly across geographically
dispersed Brokers (e.g. separate physical Data Centres or shared across
on-prem/cloud).

thanks

Tony



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Using-Infinispan-or-JBoss-Data-Grid-as-persistent-message-store-for-A-MQ-tp4715116.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.