Re: ActiveMQ 5.15.3 Active Directory (LDAP) integration

[mtod]

I found the issue I was missing the "userRoleName=dummyUserRoleName"
key/value in the login.config

It was throwing an exception when hitting 

 

The error was a password error not a missing config error so I was going in
the wrong direction.

Thanks for the help.




--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: ActiveMQ 5.15.3 Active Directory (LDAP) integration

[mtod]

Hi Tim,

I think this is more of an LDAP question then AD.

Good point I will have to setup a debugging session to see if I can resolve
it.

Thanks for the help

Mike



--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: ActiveMQ 5.15.3 Active Directory (LDAP) integration

[mtod]

Can anyone help me?



--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: ActiveMQ 5.15.3 Active Directory (LDAP) integration

[mtod]

Update:

I have the same error when hitting Apache DS locally.




--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

ActiveMQ 5.15.3 Active Directory (LDAP) integration

[mtod]

Hi,

I'm trying to get ActiveMQ to use Active Directory to authenticate our
client service accounts.

*The issue:*
What I get is it will find that service account but will not authenticate. I
first thought it was a bad password but we validated that is not the case.

*My environment:*
A local Windows 10 desktop running ActiveMQ 5.15.3 I have used this test bed
hundreds of times so I know it's not the issue.
The client is a local test app I have used in the past the AD server is over
VPN.

*Error Message:*
jvm 1|  WARN | Failed to add Connection
id=ID:1T9M5Q2-50257-1534966215221-25:1, clientId=Client1 due to {}
jvm 1| java.lang.SecurityException: User name [svc_x] or password is
invalid.
jvm 1|  at
org.apache.activemq.security.JaasAuthenticationBroker.authenticate(JaasAuthenticationBroker.java:97)[activemq-broker-5.15.3.jar:5.15.3]
jvm 1|  at
org.apache.activemq.security.JaasAuthenticationBroker.addConnection(JaasAuthenticationBroker.java:68)[activemq-broker-5.15.3.jar:5.15.3]
jvm 1|  at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:99)[activemq-broker-5.15.3.jar:5.15.3]
jvm 1|  at
org.apache.activemq.broker.TransportConnection.processAddConnection(TransportConnection.java:843)[activemq-broker-5.15.3.jar:5.15.3]
jvm 1|  at
org.apache.activemq.broker.jmx.ManagedTransportConnection.processAddConnection(ManagedTransportConnection.java:77)[activemq-broker-5.15.3.jar:5.15.3]
jvm 1|  at
org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:139)[activemq-client-5.15.3.jar:5.15.3]
jvm 1|  at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:330)[activemq-broker-5.15.3.jar:5.15.3]
jvm 1|  at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:194)[activemq-broker-5.15.3.jar:5.15.3]
jvm 1|  at
org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)[activemq-client-5.15.3.jar:5.15.3]
jvm 1|  at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:125)[activemq-client-5.15.3.jar:5.15.3]
jvm 1|  at
org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:301)[activemq-client-5.15.3.jar:5.15.3]
jvm 1|  at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)[activemq-client-5.15.3.jar:5.15.3]
jvm 1|  at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:233)[activemq-client-5.15.3.jar:5.15.3]
jvm 1|  at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:215)[activemq-client-5.15.3.jar:5.15.3]
jvm 1|  at java.lang.Thread.run(Unknown Source)[:1.8.0_181]

*My ActiveMQ Setup:*
http://activemq.apache.org/schema/core";
brokerName="localhost" dataDirectory="${activemq.data}">


  
 
…


LDAPLogin {
  org.apache.activemq.jaas.LDAPLoginModule required 
 debug=true
 initialContextFactory=com.sun.jndi.ldap.LdapCtxFactory
 connectionURL="ldap://abc.local:389"; 
 connectionUsername="CN=ABC Service Account,OU=Service
Accounts,DC=abc,DC=local" 
 connectionPassword=""
 connectionProtocol=s
 authentication=simple
 userBase="OU=Service Accounts,DC=abc,DC=local"
 userSearchMatching="(sAMAccountName={0})" 
 userSearchSubtree=true
 ;
};

Note: I have tried :
userSearchMatching="(sAMAccountName={0})" 
userSearchMatching="(cn={0})" 
userSearchMatching="(cn={1})" 

No luck

Thanks for helping.

Mike

 



--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: Has anyone connected ActiveMQ to Active Directory?

[mtod]

Thanks Tim,

Jon's example helped I'm not sure what's going on with the "c:\" protocol
but using Jon's example seems to get it reading the file. 

Mike



--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: Has anyone connected ActiveMQ to Active Directory?

[mtod]

I moved the directory to c:\ActiveMQ I still get the same error so it's not
the nested level of the directory.

Not sure where to go from here it's having issues with the URL protocol on a
windows system path "c:\"
It keeps parsing out the "c:" instead of inserting the "file" protocol.

Mike



--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: Has anyone connected ActiveMQ to Active Directory?

[mtod]

Thanks

I setup the debugging session and it seems there is an issue with the path
to the login.config file in the init() method in the configfile.class

"java.net.MalformedURLException: unknown protocol: c"

The url is on windows:

C:\Temp\activemq\assembly\target\apache-activemq-5.16.0-SNAPSHOT-bin\apache-activemq-5.16.0-SNAPSHOT\bin\..\conf\login.config

It seems valid but for some reason it can't resolve the path.

Mike




--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: Has anyone connected ActiveMQ to Active Directory?

[mtod]

Were getting closer but not quite there.
The following error keeps coming up when trying to send ActiveMQ a message.
I can't seem to find what the issue is or how to get deeper into
diagnosising the problem.
All the configs seem correct can you please take a look and see if you
happen to see something out of place?


Thanks

Mike 

 WARN | Failed to add Connection
id=ID:FM-WLTP745-58810-1525290001982-1053:1, clientId=ActiveMQSeedMsg9 due
to {}
java.lang.SecurityException: User name [inttest02] or password is invalid.
at
org.apache.activemq.security.JaasAuthenticationBroker.authenticate(JaasAuthenticationBroker.java:97)[activemq-broker-5.15.3.jar:5.15.3]
at
org.apache.activemq.security.JaasAuthenticationBroker.addConnection(JaasAuthenticationBroker.java:68)[activemq-broker-5.15.3.jar:5.15.3]
at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:99)[activemq-broker-5.15.3.jar:5.15.3]
at
org.apache.activemq.broker.TransportConnection.processAddConnection(TransportConnection.java:843)[activemq-broker-5.15.3.jar:5.15.3]
at
org.apache.activemq.broker.jmx.ManagedTransportConnection.processAddConnection(ManagedTransportConnection.java:77)[activemq-broker-5.15.3.jar:5.15.3]
at
org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:139)[activemq-client-5.15.3.jar:5.15.3]
at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:330)[activemq-broker-5.15.3.jar:5.15.3]
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:194)[activemq-broker-5.15.3.jar:5.15.3]
at
org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)[activemq-client-5.15.3.jar:5.15.3]
at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:125)[activemq-client-5.15.3.jar:5.15.3]
at
org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:301)[activemq-client-5.15.3.jar:5.15.3]
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)[activemq-client-5.15.3.jar:5.15.3]
at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:233)[activemq-client-5.15.3.jar:5.15.3]
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:215)[activemq-client-5.15.3.jar:5.15.3]
at java.lang.Thread.run(Thread.java:748)[:1.8.0_131]


My Login.config file 

LDAPLogin {
  org.apache.activemq.jaas.LDAPLoginModule required
debug=true
initialContextFactory=com.sun.jndi.ldap.LdapCtxFactory
connectionURL="ldap://corp.local:389";
connectionUsername=”CN=Mirth Development Service Account,OU=Service
Accounts,DC=corp,DC=local”
connectionPassword=b8eF352386!
connectionProtocol=""
authentication=simple
userBase="OU=Test Accounts,OU=Special Accounts,DC=corp,DC=local"
userSearchMatching="(&(objectclass=Person)(CN={0}))"
userSearchSubtree=true
roleBase="CN=ActiveMQ_Admins_DEV,OU=Application Groups,OU=Domain
Groups,DC=corp,DC=local”
roleName=cn
roleSearchMatching="(member=CN={1},OU=Test Accounts,OU=Special
Accounts,DC=corp,DC=local)”
roleSearchSubtree=true
;
};  



--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

RE: Has anyone connected ActiveMQ to Active Directory?

[mtod]

Would you happen to know how yo log the LDAP calls to assist in diagnosing
issues? 

I'm not seeing any JAAS appenders 

Mike



--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

RE: Has anyone connected ActiveMQ to Active Directory?

[mtod]

Thanks

I have used AD LDAP with other systems but this one just seems to be giving
me issues.

I'll check out your config and see if I can figure out where I'm going
wrong.

Mike





--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Has anyone connected ActiveMQ to Active Directory?

[mtod]

Has anyone connected ActiveMQ to Active Directory?

Were trying to connect to our companies Active Directory and keep running
into issues.
I'm looking to see if anyone has an example of the config?

Mike



--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

ActiveMQ AWS Cluster failing over randomly

[mtod]

Hello

I'm trying to figure out an issue we have been seeing in our AWS instances.
We have a 3 node Master/Slave/Slave cluster in AWS that keeps failing over
randomly.

It occurs about once or twice each day and does not seem to be a good
reason.
It looks like if the bridge stops it kills ActiveMQ I would have thought it
should just reconnect.

I'm hoping someone can help me out.

My config is as follows:

>Windows Server 2012 systems
>3 Node Master Slave
>persistenceAdapter kahaDB is shared on DFS
>lease-database-locker using SQL Server
>Networked to a USEast AWS cluster (Note no issues with failover)
>ActiveMQ Version 5.15.3


My Log segment:


INFO   | jvm 1| 2018/03/21 16:36:43 |  INFO | Successfully connected to
ssl://01.corp.local:61617
INFO   | jvm 1| 2018/03/21 16:36:43 |  INFO | Successfully connected to
ssl://01.corp.local:61617
INFO   | jvm 1| 2018/03/21 16:36:44 |  INFO | Network connection between
vm://fmigrp01#8 and ssl://01.corp.local:61617 (fmiuseastp01) has
been established.
INFO   | jvm 1| 2018/03/21 16:36:44 |  INFO | Network connection between
vm://fmigrp01#12 and ssl://01.corp.local:61617 (fmiuseastp01) has
been established.
INFO   | jvm 1| 2018/03/21 16:36:48 |  INFO | Successfully refreshed JMS
Connection
INFO   | jvm 1| 2018/03/21 22:50:00 |  INFO | VirtualTopic.heartbeat
Inactive for longer than 30 ms - removing ...
INFO   | jvm 1| 2018/03/21 23:30:00 |  INFO | VirtualTopic.heartbeat
Inactive for longer than 30 ms - removing ...
INFO   | jvm 1| 2018/03/21 23:55:00 |  INFO | VirtualTopic.heartbeat
Inactive for longer than 30 ms - removing ...
INFO   | jvm 1| 2018/03/22 00:25:00 |  INFO | VirtualTopic.heartbeat
Inactive for longer than 30 ms - removing ...
INFO   | jvm 1| 2018/03/22 01:00:00 |  INFO | VirtualTopic.heartbeat
Inactive for longer than 30 ms - removing ...
INFO   | jvm 1| 2018/03/22 01:55:00 |  INFO | VirtualTopic.heartbeat
Inactive for longer than 30 ms - removing ...
INFO   | jvm 1| 2018/03/22 02:10:00 |  INFO | VirtualTopic.heartbeat
Inactive for longer than 30 ms - removing ...
INFO   | jvm 1| 2018/03/22 02:20:00 |  INFO | VirtualTopic.heartbeat
Inactive for longer than 30 ms - removing ...
INFO   | jvm 1| 2018/03/22 18:19:32 |  INFO | Apache ActiveMQ 5.15.3
(fmigrp01, ID:01-52527-1521555769961-1:2) is shutting down
INFO   | jvm 1| 2018/03/22 18:19:32 |  WARN | Transport
(ssl://01.corp.local:61617) failed , not attempting to automatically
reconnect: {}
INFO   | jvm 1| 2018/03/22 18:19:32 | java.io.IOException: Bridge
stopped
INFO   | jvm 1| 2018/03/22 18:19:32 |   at
org.apache.activemq.network.DemandForwardingBridgeSupport.stopFailoverTransport(DemandForwardingBridgeSupport.java:351)[activemq-broker-5.15.3.jar:5.15.3]
INFO   | jvm 1| 2018/03/22 18:19:32 |   at
org.apache.activemq.network.DemandForwardingBridgeSupport.stop(DemandForwardingBridgeSupport.java:327)[activemq-broker-5.15.3.jar:5.15.3]
INFO   | jvm 1| 2018/03/22 18:19:32 |   at
org.apache.activemq.network.DiscoveryNetworkConnector.handleStop(DiscoveryNetworkConnector.java:223)[activemq-broker-5.15.3.jar:5.15.3]
INFO   | jvm 1| 2018/03/22 18:19:32 |   at
org.apache.activemq.network.NetworkConnector$1.doStop(NetworkConnector.java:65)[activemq-broker-5.15.3.jar:5.15.3]
INFO   | jvm 1| 2018/03/22 18:19:32 |   at
org.apache.activemq.util.ServiceSupport.stop(ServiceSupport.java:71)[activemq-client-5.15.3.jar:5.15.3]
INFO   | jvm 1| 2018/03/22 18:19:32 |   at
org.apache.activemq.network.NetworkConnector.stop(NetworkConnector.java:170)[activemq-broker-5.15.3.jar:5.15.3]
INFO   | jvm 1| 2018/03/22 18:19:32 |   at
org.apache.activemq.util.ServiceStopper.stop(ServiceStopper.java:41)[activemq-client-5.15.3.jar:5.15.3]
INFO   | jvm 1| 2018/03/22 18:19:32 |   at
org.apache.activemq.broker.BrokerService.stopAllConnectors(BrokerService.java:2236)[activemq-broker-5.15.3.jar:5.15.3]
INFO   | jvm 1| 2018/03/22 18:19:32 |   at
org.apache.activemq.broker.BrokerService.stop(BrokerService.java:848)[activemq-broker-5.15.3.jar:5.15.3]
INFO   | jvm 1| 2018/03/22 18:19:32 |   at
org.apache.activemq.xbean.XBeanBrokerService.stop(XBeanBrokerService.java:122)[activemq-spring-5.15.3.jar:5.15.3]
INFO   | jvm 1| 2018/03/22 18:19:32 |   at
org.apache.activemq.console.command.StartCommand$1.run(StartCommand.java:104)[activemq-console-5.15.3.jar:5.15.3]
INFO   | jvm 1| 2018/03/22 18:19:32 |  WARN | Transport Connection to:
vm://fmigrp01#8 failed:
org.apache.activemq.transport.TransportDisposedIOException: peer
(vm://fmigrp01#8) stopped.
INFO   | jvm 1| 2018/03/22 18:19:32 |  WARN | Transport Connection to:
vm://fmigrp01#10 failed:
org.apache.activemq.transport.TransportDisposedIOException: peer
(vm://fmigrp01#10) stopped.
INFO   | jvm 1| 2018/03/22 18:19:32 |  INFO | fmigrp01 bridge to
fmiuseastp01 sto

Warning "An exception occurred processing JSP page" - keeps filling up log's

[mtod]

I'm running 2 clusters of 3 ActiveMQ servers version 5.15.1 on Windows
Servers in AWS and I keep getting this same Warning over and over it over
flows my log's so when we do get an Error it's rolled off the log's before
we can look at it.

Is there anyone that know how to fix this issue?

Note: the link to the PAXWEB-1070 is no help.

Thanks

Mike

Full Warning:

INFO   | jvm 1| 2018/02/14 10:50:36 |  WARN | 
INFO   | jvm 1| 2018/02/14 10:50:36 | org.apache.jasper.JasperException:
An exception occurred processing JSP page /xml/queues.jsp at line 21
INFO   | jvm 1| 2018/02/14 10:50:36 | 
INFO   | jvm 1| 2018/02/14 10:50:36 | 18: <%-- Workaround for
https://ops4j1.jira.com/browse/PAXWEB-1070 --%>
INFO   | jvm 1| 2018/02/14 10:50:36 | 19: <%@include
file="../WEB-INF/jspf/headertags.jspf" %>
INFO   | jvm 1| 2018/02/14 10:50:36 | 20: 
INFO   | jvm 1| 2018/02/14 10:50:36 | 21: 
INFO   | jvm 1| 2018/02/14 10:50:36 | 22: ">
INFO   | jvm 1| 2018/02/14 10:50:36 | 23: 
INFO   | jvm 1| 2018/02/14 10:50:36 | 24:   http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

ActiveMQ 5.14.5 - Network connector dropping and reconnecting every 30 sec.

[mtod]

*My Setup: *

Systems: 
>OS: Windows Servers 2016 
>ActiveMQ Version: 5.14.5 
>Java: 1.8.141 

I have setup 2 - 3 node Master/Slave/Slave clusters on AWS 

2 on-prem ActiveMQ servers 
>1 running 5.14.5 
>1 running 5.10.0 

Current network configuration 

Germany (AWS) <-> USEast (AWS) <-> Cambridge (on-prem) 

*Problem:*
I have been seeing my network connector drop and reconnect every 30 sec or
so.

*Network Connector Config:*
*Fmigr (DEXXXq01)*
 














 









*USEast Side:*




 


 

   








*My fmigr activeMQ Log:*
2017-09-19 18:25:02,578 | INFO  | Establishing network connection from
vm://fmigrq01?async=false&create=false to
failover:(ssl://USAEXXXQ01.corp.local:61617,ssl://USAEXXXQ02.corp.local:61617,ssl://USAEXXXQ03.corp.local:61617)?randomize=false&maxReconnectAttempts=0
| org.apache.activemq.network.DiscoveryNetworkConnector | Simple Discovery
Agent-34
2017-09-19 18:25:03,213 | INFO  | Successfully connected to
ssl://USAEXXXQ01.corp.local:61617 |
org.apache.activemq.transport.failover.FailoverTransport | ActiveMQ Failover
Worker: 322718397
2017-09-19 18:25:03,321 | INFO  | Network connection between
vm://fmigrq01#178 and ssl://USAEXXXQ01.corp.local:61617 (fmiuseastq01) has
been established. |
org.apache.activemq.network.DemandForwardingBridgeSupport |
triggerStartAsyncNetworkBridgeCreation: remoteBroker=unconnected,
localBroker= vm://fmigrq01#178
2017-09-19 18:25:33,433 | WARN  | Transport
(ssl://USAEXXXQ01.corp.local:61617) failed , not attempting to automatically
reconnect: java.io.EOFException |
org.apache.activemq.transport.failover.FailoverTransport | ActiveMQ
Transport: ssl://USAEXXXQ01.corp.local/10.120.237.233:61617
2017-09-19 18:25:33,433 | WARN  | Network connection between
vm://fmigrq01#178 and unconnected shutdown due to a remote error:
java.io.EOFException |
org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ
Transport: ssl://USAEXXXQ01.corp.local/10.120.237.233:61617
2017-09-19 18:25:33,439 | INFO  | fmigrq01 bridge to fmiuseastq01 stopped |
org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ
BrokerService[fmigrq01] Task-298
2017-09-19 18:25:34,435 | INFO  | Establishing network connection from
vm://fmigrq01?async=false&create=false to
failover:(ssl://USAEXXXQ01.corp.local:61617,ssl://USAEXXXQ02.corp.local:61617,ssl://USAEXXXQ03.corp.local:61617)?randomize=false&maxReconnectAttempts=0
| org.apache.activemq.network.DiscoveryNetworkConnector | Simple Discovery
Agent-35
2017-09-19 18:25:35,062 | INFO  | Successfully connected to
ssl://USAEXXXQ01.corp.local:61617 |
org.apache.activemq.transport.failover.FailoverTransport | ActiveMQ Failover
Worker: 663286350
2017-09-19 18:25:35,169 | INFO  | Network connection between
vm://fmigrq01#182 and ssl://USAEXXXQ01.corp.local:61617 (fmiuseastq01) has
been established. |
org.apache.activemq.network.DemandForwardingBridgeSupport |
triggerStartAsyncNetworkBridgeCreation: remoteBroker=unconnected,
localBroker= vm://fmigrq01#182
2017-09-19 18:26:05,301 | WARN  | Transport
(ssl://USAEXXXQ01.corp.local:61617) failed , not attempting to automatically
reconnect: java.io.EOFException |
org.apache.activemq.transport.failover.FailoverTransport | ActiveMQ
Transport: ssl://USAEXXXQ01.corp.local/10.120.237.233:61617
2017-09-19 18:26:05,302 | WARN  | Network connection between
vm://fmigrq01#182 and unconnected shutdown due to a remote error:
java.io.EOFException |
org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ
Transport: ssl://USAEXXXQ01.corp.local/10.120.237.233:61617
2017-09-19 18:26:05,307 | INFO  | fmigrq01 bridge to fmiuseastq01 stopped |
org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ
BrokerService[fmigrq01] Task-307
2017-09-19 18:26:06,304 | INFO  | Establishing network connection from
vm://fmigrq01?async=false&create=false to
failover:(ssl://USAEXXXQ01.corp.local:61617,ssl://USAEXXXQ02.corp.local:61617,ssl://USAEXXXQ03.corp.local:61617)?randomize=false&maxReconnectAttempts=0
| org.apache.activemq.network.DiscoveryNetworkConnector | Simple Discovery
Agent-36
2017-09-19 18:26:06,937 | INFO  | Successfully connected to
ssl://USAEXXXQ01.corp.local:61617 |
org.apache.activemq.transport.failover.FailoverTransport | ActiveMQ Failover
Worker: 1852967876
2017-09-19 18:26:07,041 | INFO  | Network connection between
vm://fmigrq01#188 and ssl://USAEXXXQ01.corp.local:61617 (fmiuseastq01) has
been established. |
org.apache.activemq.network.DemandForwardingBridgeSu

ActiveMQ DLQ issues

[mtod]

I'm running ActiveMQ 5.10.0 with an embedded camel route. It's been running
fine until we connected the master to an instance 5.14.5.

5.10.0 Network Connector:











 



Now I have been experiencing a lot of messages going to the DLQ.

I looked at the messages and they don't seem to have anything wrong with
them I did notice the following:

dlqDeliveryFailureCause java.lang.Throwable: TopicSubDiscard.
ID:localhost->fmiuseastp01-63022-1486246061090-100948:1:1:2

I'm not sure what this is telling me.

Thanks

Mike





--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Network Connector question

[mtod]

My Setup:

Systems:
>OS: Windows Servers 2016
>ActiveMQ Version: 5.14.5
>Java: 1.8.141

I have setup 2 - 3 node Master/Slave/Slave clusters on AWS

2 on-prem ActiveMQ servers 
>1 running 5.14.5
>1 running 5.10.0

Current network configuration

Germany (AWS) <-> USEast (AWS) <-> Cambridge (on-prem) 

I have traffic flowing between all servers except for the 5.10.0 ActiveMQ it
seems that everytime I enable the network connector the 2 on-prem boxes
compete for messages only one will get them.

So the main question is there a issue using network connectors between
different ActiveMQ versions such as 5.10.0 and 5.14.5?

Thanks 
Mike







--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: ActiveMQ 5.14.5 bridge intermittent reconnect issue

[mtod]

Thanks Tim

I'll make that change 

Mike



--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: ActiveMQ 5.14.5 bridge intermittent reconnect issue

[mtod]

Well found out that the networking team in there wisdom is using VPN to
connect regions and it's bouncing every so often. :(

So not as big an issue as I thought but I would like to know if anyone sees
any issue with the config.

Thanks

Mike



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/ActiveMQ-5-14-5-bridge-intermittent-reconnect-issue-tp4730035p4730036.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

ActiveMQ 5.14.5 bridge intermittent reconnect issue

[mtod]

I'm looking for some help diagnosising an issue with networkconnectors
failing and restarting.

I have a set of 3 node master/slave/slave clusters setup in AWS that are
having an issue maintaining a network connection.
We have 3 nodes in Germany and 3 nodes in the US East the clusters are setup
as a Master/Slave/Slave that seems to be working fine but the connection
between the 2 clusters seems to be having issues.
It establishes the connection then after a bit it will fail and start the
cycle all over again.

I can send traffic over the connection when it re-establishes the
connection.

Thanks for looking at this

Mike

Setup:

> Windows Server 2016
> ActiveMQ 5.14.5
> Amazon instances

US Cluster ActiveMQ.xml:





 




 



Germany Cluster ActiveMQ.xml:

 














 



US East ActiveMQ log:

2017-08-28 13:31:38,116 | INFO  | Establishing network connection from
vm://fmiuseastp01?async=false&create=false to
failover:(ssl://DEAU2ACTMAPPP01:61617,ssl://DEAU2ACTMAPPP02:61617,ssl://DEAU2ACTMAPPP03:61617)?randomize=false&maxReconnectAttempts=0
| org.apache.activemq.network.DiscoveryNetworkConnector | Simple Discovery
Agent-78
2017-08-28 13:31:38,489 | INFO  | Successfully connected to
ssl://DEAU2ACTMAPPP01:61617 |
org.apache.activemq.transport.failover.FailoverTransport | ActiveMQ Failover
Worker: 1064461660
2017-08-28 13:31:38,754 | INFO  | Network connection between
vm://fmiuseastp01#416 and ssl://DEAU2ACTMAPPP01:61617 (fmigrp01) has been
established. | org.apache.activemq.network.DemandForwardingBridgeSupport |
triggerStartAsyncNetworkBridgeCreation: remoteBroker=unconnected,
localBroker= vm://fmiuseastp01#416
2017-08-28 13:56:15,210 | WARN  | Transport (ssl://DEAU2ACTMAPPP01:61617)
failed , not attempting to automatically reconnect:
java.net.SocketException: Connection reset |
org.apache.activemq.transport.failover.FailoverTransport | ActiveMQ
Transport: ssl://DEAU2ACTMAPPP01/10.124.108.127:61617
2017-08-28 13:56:15,211 | WARN  | Network connection between
vm://fmiuseastp01#414 and unconnected shutdown due to a remote error:
java.net.SocketException: Connection reset |
org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ
Transport: ssl://DEAU2ACTMAPPP01/10.124.108.127:61617
2017-08-28 13:56:15,217 | INFO  | fmiuseastp01 bridge to fmigrp01 stopped |
org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ
BrokerService[fmiuseastp01] Task-1204
2017-08-28 13:56:15,323 | WARN  | Transport (ssl://DEAU2ACTMAPPP01:61617)
failed , not attempting to automatically reconnect:
java.net.SocketException: Connection reset |
org.apache.activemq.transport.failover.FailoverTransport | ActiveMQ
Transport: ssl://DEAU2ACTMAPPP01/10.124.108.127:61617
2017-08-28 13:56:15,323 | INFO  | Network connection between
vm://fmiuseastp01#416 and unconnected shutdown due to a local error:
org.apache.activemq.transport.TransportDisposedIOException: Disposed due to
prior exception | org.apache.activemq.network.DemandForwardingBridgeSupport
| ActiveMQ Transport: ssl://DEAU2ACTMAPPP01/10.124.108.127:61617
2017-08-28 13:56:15,324 | INFO  | Network connection between
vm://fmiuseastp01#416 and unconnected shutdown due to a local error:
org.apache.activemq.transport.TransportDisposedIOException: Disposed due to
prior exception | org.apache.activemq.network.DemandForwardingBridgeSupport
| ActiveMQ Transport: ssl://DEAU2ACTMAPPP01/10.124.108.127:61617
2017-08-28 13:56:15,326 | INFO  | fmiuseastp01 bridge to fmigrp01 stopped |
org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ
BrokerService[fmiuseastp01] Task-1207
2017-08-28 13:56:15,473 | WARN  | Transport Connection to:
tcp://10.124.108.127:57492 failed: java.net.SocketException: Connection
reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ
Transport: ssl:///10.124.108.127:57492
2017-08-28 13:56:16,216 | INFO  | Establishing network connection from
vm://fmiuseastp01?async=false&create=false to
failover:(ssl://DEAU2ACTMAPPP01:61617,ssl://DEAU2ACTMAPPP02:61617,ssl://DEAU2ACTMAPPP03:61617)?randomize=false&maxReconnectAttempts=0
| or

Re: ActiveMQ Master / Slave Fall Back Master

[mtod]

5.x ActiveMQ



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/ActiveMQ-Master-Slave-Fall-Back-Master-tp4729663p4729668.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

ActiveMQ Master / Slave Fall Back Master

[mtod]

Does ActiveMQ have any support for a master fall back.

If I have 2 servers one the master let's call it server A and a slave server
B.

When server A has an issue it fails over to server B "Great!"

Then when I get server A back on line server A becomes the slave 

I'm looking for an option so that when Server A comes back online Server A
is promoted automatically back to a the Master.

Thanks

Mike



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/ActiveMQ-Master-Slave-Fall-Back-Master-tp4729663.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Users.properties & groups not updating when removing of a user

[mtod]

I have an ActiveMQ 5.14.5 running on Windows I have a login.config setup as
listed below:

activemq-domain {
org.apache.activemq.jaas.PropertiesLoginModule required
org.apache.activemq.jaas.properties.user="users.properties"
org.apache.activemq.jaas.properties.group="groups.properties"
reload=true;
};

I updated the activemq.xml with the following:



When I add a user to the users.properties and group.properties it seems to
work fine.
It reloads and the user starts working but when I try to remove that same
user it does not seem to reload the file updates. 
The user just continues to have the ability to send messages.

I would like the ability to update the file both for new accounts and to
remove old ones with out having to restart ActiveMQ.

Anyone have any experience with this option?

Thanks

Mike





--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Users-properties-groups-not-updating-when-removing-of-a-user-tp4726738.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Artemis 2.0 cluster fail over issue

[mtod]

Just to close this out I setup static connections and it's failing over fine.

I would have preferred to use the discovery but seems that's not possible at
this time on AWS.

Thanks for your help

Mike



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-2-0-cluster-fail-over-issue-tp4726002p4726089.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Artemis 2.0 cluster fail over issue

[mtod]

To answer your question yes it does support UDP. But to add no it does not
support the multicast ip address.

The images shows the inbound and outbound rules broken down by protocol and
ip ranges for the AWS image. The outbound has no limits all protocols and
all IP's but the inbound shows all protocols but limits the ip thus does not
include the address 231.7.7.7 but will allow UDP.

No need to respond and thanks for you help I'll figure it out.

Mike







--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-2-0-cluster-fail-over-issue-tp4726002p4726084.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Artemis 2.0 cluster fail over issue

[mtod]

Hmm I had to verify to configuration looks like UDP is allowed:

I'm not an expert on IP but it looks like the 231.7.7.7 would not be able to
send out to the server.

 

 



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-2-0-cluster-fail-over-issue-tp4726002p4726081.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Artemis 2.0 cluster fail over issue

[mtod]

Looking at the slaves I see an entry in the log for topology I'm not sure
what the initialConnectors=[] mean.

12:57:26,528 DEBUG [org.apache.activemq.artemis.core.client.impl.Topology]
Topology@4d2d5542[owner=ServerLocatorImpl [initialConnectors=[],
discoveryGroupConfiguration=DiscoveryGroupConfiguration{name='dg-group1',
refreshTimeout=1, discoveryInitialWaitTimeout=1}]] is sending
topology to QuorumManager(server=null)




--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-2-0-cluster-fail-over-issue-tp4726002p4726076.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Artemis 2.0 cluster fail over issue

[mtod]

I just did not have the ${udp-address: } just the ip 231.7.7.7 default from
the atremis create function.

I just happen to notice that's how they had it in the example to I gave it a
try. :)


Thanks

Mike
 



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-2-0-cluster-fail-over-issue-tp4726002p4726073.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Artemis 2.0 cluster fail over issue

[mtod]

The UDP multi cast was just added to align the config with the example I
tried it both ways.
Note: the log in the original post was without that option such as :

  
 
231.7.7.7
9876
1
 
  



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-2-0-cluster-fail-over-issue-tp4726002p4726070.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Artemis 2.0 cluster fail over issue

[mtod]

Thanks for the response.


3 systems running on AWS Windows 2016 

I just trimed it down removing any SSL until I can get this working.
I followed the
https://github.com/apache/activemq-artemis/tree/master/examples/features/ha/replicated-transaction-failover
example.

Quick question how does the cluster know when a master fails is the a ping
if so what port does that use?

Thanks for looking at this.

Mike

Server1 - Master

http://www.w3.org/2001/XMLSchema-instance";
   xsi:schemaLocation="urn:activemq
/schema/artemis-configuration.xsd">

   http://www.w3.org/2001/XMLSchema-instance";
 xsi:schemaLocation="urn:activemq:core ">

  fmibroker

  true
  
  
  true

  
  NIO

  ./data/paging

  ./data/bindings

  ./data/journal

 
./data/large-messages

  true

  2

  -1

  

  

  
  

  
  

  
  

  
  



  
  1488000



tcp://10.121.51.121:61616


  
  5000

  
  90

  
  100Mb

  
 
 tcp://10.121.51.121:61616?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=CORE,AMQP,STOMP,HORNETQ,MQTT,OPENWIRE
 
  

  x
  x

  
 
${udp-address:231.7.7.7}
9876
5000
netty_connector
 
  

  
 
${udp-address:231.7.7.7}
9876
1
 
  

  
 

netty_connector
1000
ON_DEMAND
1
 
 
  

  
 

fmieastcluster
useast 


true

 
  

  jms.queue.activemq.management
  
  






  
 











 
  

  
 
 
DLQ
ExpiryQueue
0

-1
   
10
PAGE
true
true
true
true
 
 
 
DLQ
ExpiryQueue
0

-1
   
10
PAGE
true
true
true
true
 
  

  
 

   

 
 

   

 

  

   





Server2 - Slave

http://www.w3.org/2001/XMLSchema-instance";
   xsi:schemaLocation="urn:activemq
/schema/artemis-configuration.xsd">

   http://www.w3.org/2001/XMLSchema-instance";
 xsi:schemaLocation="urn:activemq:core ">

  fmibroker

  true
  
  
  true

  
  NIO

  ./data/paging

  ./data/bindings

  ./data/journal

 
./data/large-messages

  true

  2

  -1

  

  

  
  

  
  

  
  

  
  

  
  1364000



tcp://10.121.49.225:61616


  
  5000

  
  90

  
  100Mb

  
 
 tcp://10.121.49.225:61616?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=CORE,AMQP,STOMP,HORNETQ,MQTT,OPENWIRE
  

  x
  x

  
 
${udp-address:231.7.7.7}
9876
5000
netty_connector
 
  

  
 
${udp-address:231.7.7.7}
9876
1
 
  

  
 

netty_connector
1000
ON_DEMAND
1
 
 
  

  
 

fmieastcluster
useast 

true

 
  

  




 











 
  

  
 
 
DLQ
ExpiryQueue
0

-1
   
10
PAGE
true
true
true
true
 
 
 
DLQ
ExpiryQueue
0

-1
   
10
PAGE
true
true
true
  

Artemis 2.0 cluster fail over issue

[mtod]

I'm trying to get an Artemis 2.0 cluster working.

I have 3 Nodes Running on AWS Windows 2016 and Artemis 2.0
Java jdk 1.8.0_131

I can't seem to get them to fail over when I take the Live server offline I
see no changes to the backup servers.
I'm not sure whats happening anyone have any ideas?

Thanks

Mike

Live Server excerpts:

16:48:17,209 DEBUG [org.apache.activemq.artemis.core.client.impl.Topology]
Topology@bae7dc0[owner=ClusterConnectionImpl@547201549[nodeUUID=c20c017e-35c7-11e7-97fc-0e677709a282,
connector=TransportConfiguration(name=artemis,
factory=org-apache-activemq-artemis-core-remoting-impl-netty-NettyConnectorFactory)
?port=61616&host=10-121-51-121, address=jms,
server=ActiveMQServerImpl::serverUUID=c20c017e-35c7-11e7-97fc-0e677709a282]]
is sending topology to Remote Proxy on channel 6c3f9531
16:48:17,211 DEBUG [org.apache.activemq.artemis.core.client.impl.Topology]
Topology@bae7dc0[owner=ClusterConnectionImpl@547201549[nodeUUID=c20c017e-35c7-11e7-97fc-0e677709a282,
connector=TransportConfiguration(name=artemis,
factory=org-apache-activemq-artemis-core-remoting-impl-netty-NettyConnectorFactory)
?port=61616&host=10-121-51-121, address=jms,
server=ActiveMQServerImpl::serverUUID=c20c017e-35c7-11e7-97fc-0e677709a282]]
sending c20c017e-35c7-11e7-97fc-0e677709a282 /
Pair[a=TransportConfiguration(name=artemis,
factory=org-apache-activemq-artemis-core-remoting-impl-netty-NettyConnectorFactory)
?port=61616&host=10-121-51-121, b=null] to Remote Proxy on channel 6c3f9531
16:48:17,295 DEBUG
[org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl]
ClientSessionFactoryImpl received backup update for live/backup pair =
TransportConfiguration(name=artemis,
factory=org-apache-activemq-artemis-core-remoting-impl-netty-NettyConnectorFactory)
?port=61616&host=10-121-51-121 / null but it didn't belong to
TransportConfiguration(name=artemis,
factory=org-apache-activemq-artemis-core-remoting-impl-netty-NettyConnectorFactory)
?port=61616&host=10-121-51-121
16:48:17,887 INFO  [org.apache.activemq.artemis] AMQ241001: HTTP Server
started at http://localhost:8161
16:48:17,899 INFO  [org.apache.activemq.artemis] AMQ241002: Artemis Jolokia
REST API available at http://localhost:8161/jolokia
16:48:28,204 DEBUG
[org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl]
ClusterCommunication::Sending notification for addBinding LocalQueueBinding
[address=ActiveMQ.Advisory.TempQueue,
queue=QueueImpl[name=6addd362-772b-4675-9c97-fca4eb1fdada,
postOffice=PostOfficeImpl
[server=ActiveMQServerImpl::serverUUID=c20c017e-35c7-11e7-97fc-0e677709a282],
temp=true]@dae557e, filter=FilterImpl
[sfilterString=__AMQ_CID<>'ID:b3be4c964f10-37643-1494535648494-1:1'],
name=6addd362-772b-4675-9c97-fca4eb1fdada,
clusterName=6addd362-772b-4675-9c97-fca4eb1fdadac20c017e-35c7-11e7-97fc-0e677709a282]
from server
ActiveMQServerImpl::serverUUID=c20c017e-35c7-11e7-97fc-0e677709a282
16:48:28,222 DEBUG
[org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl] Couldn't
find any bindings for address=activemq.notifications on
message=CoreMessage[messageID=6442452924,durable=true,userID=null,priority=0,
timestamp=0,expiration=0, durable=true,
address=activemq.notifications,properties=TypedProperties[_AMQ_Binding_Type=0,_AMQ_RoutingName=6addd362-772b-4675-9c97-fca4eb1fdada,_AMQ_Distance=0,_AMQ_Address=ActiveMQ.Advisory.TempQueue,_AMQ_NotifType=BINDING_ADDED,_AMQ_Binding_ID=6442452923,_AMQ_FilterString=__AMQ_CID<>'ID:b3be4c964f10-37643-1494535648494-1:1',_AMQ_NotifTimestamp=1494535708220,_AMQ_ClusterName=6addd362-772b-4675-9c97-fca4eb1fdadac20c017e-35c7-11e7-97fc-0e677709a282,foobar=2f6bb043-368b-11e7-a106-0e677709a282]]@2101112334
16:48:28,222 DEBUG
[org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl] Message
CoreMessage[messageID=6442452924,durable=true,userID=null,priority=0,
timestamp=0,expiration=0, durable=true,
address=activemq.notifications,properties=TypedProperties[_AMQ_Binding_Type=0,_AMQ_RoutingName=6addd362-772b-4675-9c97-fca4eb1fdada,_AMQ_Distance=0,_AMQ_Address=ActiveMQ.Advisory.TempQueue,_AMQ_NotifType=BINDING_ADDED,_AMQ_Binding_ID=6442452923,_AMQ_FilterString=__AMQ_CID<>'ID:b3be4c964f10-37643-1494535648494-1:1',_AMQ_NotifTimestamp=1494535708220,_AMQ_ClusterName=6addd362-772b-4675-9c97-fca4eb1fdadac20c017e-35c7-11e7-97fc-0e677709a282,foobar=2f6bb043-368b-11e7-a106-0e677709a282]]@2101112334
is not going anywhere as it didn't have a binding on
address:activemq.notifications
16:48:28,293 DEBUG
[org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl] Couldn't
find any bindings for address=activemq.notifications on
message=CoreMessage[messageID=6442452927,durable=true,userID=null,priority=0,
timestamp=0,expiration=0, durable=true,
address=activemq.notifications,properties=TypedProperties[_AMQ_RoutingName=6addd362-772b-4675-9c97-fca4eb1fdada,_AMQ_Distance=0,_AMQ_ConsumerCount=1,_AMQ_User=fmiuser,_AMQ_SessionName=ID:b3be4c964f10-37643-1494535648494-1:1:-1,_AMQ_Address=ActiveMQ.Advisory.TempQueue,_AMQ

Artemis Rest installation & configuration

[mtod]

I seem to be missing something on the REST setup the doc seems to cover 2
types of install an app server like Wildfly or an embedded install.

I have Artemis running as a service on a Windows Server where does that
fall?

Also it seems that to use Rest I would have to build a war file is that
correct there's no default Rest API like  5.x ActiveMQ?

Thanks

Mike



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-Rest-installation-configuration-tp4725729.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Artemis JConsole Support

[mtod]

Thanks I have this working now.

Mike



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-JConsole-Support-tp4725085p4725728.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Artemis production ready?

[mtod]

The filtering or routing could be a camel microservice (I have this working
on docker AWS today) or I can work up something using the
https://activemq.apache.org/artemis/docs/1.0.0/wildcard-routing.html

Our current ActiveMQ uses a Camel content router for managing queue to
topics. We setup a single input queue for each application then use camel to
route the messages based on a route element in the message header. This
keeps the number of application connections down and in case of a queue
corruption should not affect other consumers. We are using ActiveMQ in an
event based message model today.

But the final method is still an open question.

I'm still working on getting the architectural model up and running so I can
refine the routing and security requirements.

btw when will the 2.0.1 release be out?

Thanks

Mike



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-production-ready-tp4725363p4725618.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: broker to broker testing scenario

[mtod]

I can attest to the embedded camel for ActiveMQ we have been running a route
in production for 3 years+ with no issues.

I use it for message routing based on content.

Mike



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/broker-to-broker-testing-scenario-tp4725331p4725552.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Artemis replicated failover cluster question

[mtod]

I'm trying to setup a replicated failover cluster I can't seem to get them to
connect.
Can someone please review the broker.xml below and let me know if I'm doing
this right.

Thanks

Mike

Enviroment:

AWS EC2
Windows 2016
Java 1.8.0_131
Testing using Artemis.cmd run

I am able to connect using SSL to the Master using JMStoolbox on 61617

Master Server:








tcp://X01:61617?sslEnabled=true


x
x

 
 
server1-ssl-connector
500
true
ON_DEMAND
1

   server0-ssl-connector
   server1-ssl-connector

 
  

  
  
 tcp://0.0.0.0:61617?sslEnabled=true;keyStorePath=/Apache/apache-artemis-2.0.0/bin/fmibroker/etc/key/masterbroker.ks;keyStorePassword=x
  


Slave Server:








tcp://X02:61617?sslEnabled=true



x
x  


  
 
server1-ssl-connector
500
true
ON_DEMAND
1

   server0-ssl-connector
   server1-ssl-connector

 
  

  
  
 tcp://0.0.0.0:61617?sslEnabled=true;keyStorePath=/Apache/apache-artemis-2.0.0/bin/fmibroker/etc/key/slavebroker.ks;keyStorePassword=x
  

  






--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-replicated-failover-cluster-question-tp4725551.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Artemis production ready?

[mtod]

Thanks everyone for the responses that helps.

For the support model we have been running ActiveMQ in production for 4
years I'm very happy with the performance. I know there are several 3rd
parties that if I need to add a support model they would be happy to sign a
contract. :)

I plan on setting up 2-2 node clusters and connecting them across the pond
and stress test the solution.


Mike




--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-production-ready-tp4725363p4725368.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Artemis production ready?

[mtod]

Is Artemis production ready?

I have ActiveMQ 5.10 in production today but our infrastructure is moving to
AWS and global ( US and Europe).

I would like to upgrade from a single on prem cluster to a 2 failover
cluster model with a network connector across the pond.

before I spend all the cycles I would like to know if Artemis is used in
production today.

Thanks

Mike 



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-production-ready-tp4725363.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Artemis JConsole Support

[mtod]

Sorry for the delay here is the artemis-service.xml



   artemis-broker-0.0.0.0
   ActiveMQ Artemis: broker @ 0.0.0.0
   Apache ActiveMQ Artemis is a reliable messaging
broker

   
   

   C:\Apache\apache-artemis-2.0.0\bin\broker\log
   roll

   %JAVA_HOME%\bin\java.exe
  
-Xbootclasspath/a:%ARTEMIS_HOME%\lib\jboss-logmanager-2.0.3.Final.jar
   -XX:+UseParallelGC
   -XX:+AggressiveOpts
   -XX:+UseFastAccessorMethods
   -Xms512M
   -Xmx1024M

   

   -classpath
   %ARTEMIS_HOME%\lib\artemis-boot.jar
   -Dartemis.home=%ARTEMIS_HOME%
   -Dartemis.instance=%ARTEMIS_INSTANCE%
  
-Djava.util.logging.manager=org.jboss.logmanager.LogManager
  
-Dlogging.configuration=file:%ARTEMIS_INSTANCE%\etc\logging.properties
  
-Djava.security.auth.login.config=%ARTEMIS_INSTANCE%\etc\login.config


   

   org.apache.activemq.artemis.boot.Artemis

   run





--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-JConsole-Support-tp4725085p4725261.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Artemis JConsole Support

[mtod]

I have Artemis 2.0 installed on a Windows Box when I run it using artemis.cmd
run
I can see the local jconsole and connect and works fine.

When I install it as a windows service using artemis-service.exe install
then start the service I can't access the service using jconsole.

see attached images.

Artemis Run:

 

Artemis Service:

 

Any idea why this would happen ?

Thanks

Mike



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-JConsole-Support-tp4725085.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Artemis 2.0 in Docker 61616 not initialized

[mtod]

Thanks for the reply seems that was it I set them to 0.0.0.0 and that worked.
Your response trigger a memory from something I read where they had an issue
with localhost in docker and set it to 0.0.0.0.

Thanks Again.

Mike



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-2-0-in-Docker-61616-not-initialized-tp4724916p4724918.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Artemis 2.0 in Docker 61616 not initialized

[mtod]

I'm running Artemis 2.0 in docker everything seems fine in the logs but I'm
not able to access from outside docker.

Anybody come across this issue before?

I noticed this in the log:

18:50:30,667 DEBUG
[org.apache.activemq.artemis.core.server.management.impl.ManagementServiceImpl]
ignoring message Notification[uid=null, type=ACCEPTOR_STARTED,
properties=TypedProperties[factory=org.apache.activemq.artemis.core.remoting.impl.netty.NettyAcceptorFactory,host=localhost,port=61616]]
*as the server is not initialized*
18:50:30,667 INFO  [org.apache.activemq.artemis.core.server] AMQ221020:
Started Acceptor at localhost:61616 for protocols
[CORE,MQTT,AMQP,STOMP,HORNETQ,OPENWIRE]
18:50:30,673 DEBUG
[org.apache.activemq.artemis.core.server.management.impl.ManagementServiceImpl]
ignoring message Notification[uid=null, type=ACCEPTOR_STARTED,
properties=TypedProperties[factory=org.apache.activemq.artemis.core.remoting.impl.netty.NettyAcceptorFactory,host=localhost,port=5445]]
as the server is not initialized
18:50:30,674 INFO  [org.apache.activemq.artemis.core.server] AMQ221020:
Started Acceptor at localhost:5445 for protocols [HORNETQ,STOMP]
18:50:30,679 DEBUG
[org.apache.activemq.artemis.core.server.management.impl.ManagementServiceImpl]
ignoring message Notification[uid=null, type=ACCEPTOR_STARTED,
properties=TypedProperties[factory=org.apache.activemq.artemis.core.remoting.impl.netty.NettyAcceptorFactory,host=localhost,port=5672]]
as the server is not initialized
18:50:30,679 INFO  [org.apache.activemq.artemis.core.server] AMQ221020:
Started Acceptor at localhost:5672 for protocols [AMQP]
18:50:30,685 DEBUG
[org.apache.activemq.artemis.core.server.management.impl.ManagementServiceImpl]
ignoring message Notification[uid=null, type=ACCEPTOR_STARTED,
properties=TypedProperties[factory=org.apache.activemq.artemis.core.remoting.impl.netty.NettyAcceptorFactory,host=localhost,port=1883]]
as the server is not initialized
18:50:30,686 INFO  [org.apache.activemq.artemis.core.server] AMQ221020:
Started Acceptor at localhost:1883 for protocols [MQTT]
18:50:30,690 DEBUG
[org.apache.activemq.artemis.core.server.management.impl.ManagementServiceImpl]
ignoring message Notification[uid=null, type=ACCEPTOR_STARTED,
properties=TypedProperties[factory=org.apache.activemq.artemis.core.remoting.impl.netty.NettyAcceptorFactory,host=localhost,port=61613]]
as the server is not initialized
18:50:30,690 INFO  [org.apache.activemq.artemis.core.server] AMQ221020:
Started Acceptor at localhost:61613 for protocols [STOMP]
18:50:30,701 INFO  [org.apache.activemq.artemis.core.server] AMQ221007:
Server is now live
18:50:30,702 INFO  [org.apache.activemq.artemis.core.server] AMQ221001:
Apache ActiveMQ Artemis Message Broker version 2.0.0 [localhost,
nodeID=e65a6bf6-1fb0-11e7-90b5-0242ac110002]
18:50:30,986 INFO  [org.apache.activemq.artemis] AMQ241001: HTTP Server
started at http://0.0.0.0:8161
18:50:30,986 INFO  [org.apache.activemq.artemis] AMQ241002: Artemis Jolokia
REST API available at http://0.0.0.0:8161/jolokia

Thanks
Mike




--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-2-0-in-Docker-61616-not-initialized-tp4724916.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Artemis 2.0 client migration from ActiveMQ 5.14

[mtod]

Thats strange then because it would fail unless I put in a queue that was
already created.

Thanks
Mike



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-2-0-client-migration-from-ActiveMQ-5-14-tp4724150p4724210.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Artemis 2.0 in Karaf 4.1.0 accessing via Camel issues

[mtod]

I'm running Karaf 4.1.0 and Artemis 2.0 on AWS EC2.

It's running fine but when I setup a camel route that connects to Artemis I
get the following errors.

org.apache.activemq -- Cannot be resolved
org.apache.activemq.camel.component -- Cannot be resolved

Question 1 - When running Artemis do I have to include some legacy ActiveMQ
components?
Question 2 - If not is there a different connection factory that should be
used for Artemis?

I don't have ActiveMQ installed only Artemis I'm using the following camel
connection:











 




--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-2-0-in-Karaf-4-1-0-accessing-via-Camel-issues-tp4724207.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Artemis 2.0 client migration from ActiveMQ 5.14

[mtod]

Thanks I got the uri to work my prod ActiveMQ implementation has dynamic
queue creation Artemis does not have that turned on or at least I don't know
how to do that yet.

Thanks Again

Mike



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-2-0-client-migration-from-ActiveMQ-5-14-tp4724150p4724154.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Artemis 2.0 client migration from ActiveMQ 5.14

[mtod]

Thanks for the quick reply.

That's good to know I have been having issues using my existing test clients
trying to connect both from Camel and JMS/NMS.

Has the URI changed maybe I'm missing something.

I know the system is working correctly the command line tool works fine
sending and receiving messages.

if you have an example of the connection string that would help a lot.

Thanks

Mike




--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-2-0-client-migration-from-ActiveMQ-5-14-tp4724150p4724152.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Artemis 2.0 client migration from ActiveMQ 5.14

[mtod]

I'm looking to upgrade to Artemis from ActiveMQ 5.14 most of my clients are
running JMS and NMS openwire.

Is there a path to upgrade without rewriting all the clients?

if so do you have an example of the connection string?

Thanks

Mike






--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-2-0-client-migration-from-ActiveMQ-5-14-tp4724150.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Artemis 2.0 - Karaf - JsonLoader not found issue

[mtod]

Seems this has to do with adding Hawtio to the system.

Seems to work fine on a local instance.




--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-2-0-Karaf-JsonLoader-not-found-issue-tp4723979p4724007.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Artemis 2.0 - Karaf - JsonLoader no found issue

[mtod]

Hi I'm loading up Artemis 2.0 on AWS EC2 in a karaf container.
It loaded fine and is working except for the following error when executing
listAllConsumersAsJSON() 

javax.management.RuntimeErrorException: java.lang.NoClassDefFoundError:
Could not initialize class org.apache.activemq.artemis.utils.JsonLoader
at
com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.rethrow(DefaultMBeanServerInterceptor.java:841)
at
com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.rethrowMaybeMBeanException(DefaultMBeanServerInterceptor.java:852)
at
com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.invoke(DefaultMBeanServerInterceptor.java:821)
at 
com.sun.jmx.mbeanserver.JmxMBeanServer.invoke(JmxMBeanServer.java:801)
at org.jolokia.handler.ExecHandler.doHandleRequest(ExecHandler.java:98)
at org.jolokia.handler.ExecHandler.doHandleRequest(ExecHandler.java:40)
at
org.jolokia.handler.JsonRequestHandler.handleRequest(JsonRequestHandler.java:89)
at
org.jolokia.backend.MBeanServerExecutorLocal.handleRequest(MBeanServerExecutorLocal.java:109)
at
org.jolokia.backend.MBeanServerHandler.dispatchRequest(MBeanServerHandler.java:159)
at
org.jolokia.backend.LocalRequestDispatcher.dispatchRequest(LocalRequestDispatcher.java:99)
at
org.jolokia.backend.BackendManager.callRequestDispatcher(BackendManager.java:413)
at
org.jolokia.backend.BackendManager.handleRequest(BackendManager.java:158)
at
org.jolokia.http.HttpRequestHandler.executeRequest(HttpRequestHandler.java:197)
at
org.jolokia.http.HttpRequestHandler.handlePostRequest(HttpRequestHandler.java:137)
at org.jolokia.http.AgentServlet$3.handleRequest(AgentServlet.java:420)
at org.jolokia.http.AgentServlet.handleSecurely(AgentServlet.java:301)
at org.jolokia.http.AgentServlet.handle(AgentServlet.java:277)
at org.jolokia.http.AgentServlet.doPost(AgentServlet.java:244)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:707)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:790)
at 
org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:845)
at
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1772)
at
org.eclipse.jetty.websocket.server.WebSocketUpgradeFilter.doFilter(WebSocketUpgradeFilter.java:193)
at
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1759)
at io.hawt.web.AuthenticationFilter$3.run(AuthenticationFilter.java:227)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:422)
at
io.hawt.web.AuthenticationFilter.executeAs(AuthenticationFilter.java:224)
at 
io.hawt.web.AuthenticationFilter.doFilter(AuthenticationFilter.java:162)
at
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1759)
at 
io.hawt.web.XXSSProtectionFilter.doFilter(XXSSProtectionFilter.java:28)
at
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1759)
at io.hawt.web.XFrameOptionsFilter.doFilter(XFrameOptionsFilter.java:28)
at
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1759)
at io.hawt.web.CORSFilter.doFilter(CORSFilter.java:42)
at
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1759)
at io.hawt.web.CacheHeadersFilter.doFilter(CacheHeadersFilter.java:37)
at
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1759)
at io.hawt.web.SessionExpiryFilter.process(SessionExpiryFilter.java:163)
at io.hawt.web.SessionExpiryFilter.doFilter(SessionExpiryFilter.java:57)
at
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1759)
at io.hawt.web.RedirectFilter.process(RedirectFilter.java:73)
at io.hawt.web.RedirectFilter.doFilter(RedirectFilter.java:38)
at
org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1751)
at
org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:582)
at
org.ops4j.pax.web.service.jetty.internal.HttpServiceServletHandler.doHandle(HttpServiceServletHandler.java:70)
at
org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:143)
at
org.eclipse.jetty.security.SecurityHandler.handle(SecurityHandler.java:548)
at
org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:226)
at
org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1180)
at
org.ops4j.pax.web.service.jetty.internal.HttpServiceContext.doHandle(HttpServiceContext.java:284)
at
org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:512)
at
org.eclipse.jetty.server.session.

Re: Active MQ Shared File System Master Slave with Elastic File System

[mtod]

I'm working on a similar setup right now can you share your activemq.xml
database config? specificly what class did you use?

I tried the one below but keep getting errors that the class can't be found.










Thanks

Mike




--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Active-MQ-Shared-File-System-Master-Slave-with-Elastic-File-System-tp4715818p4723957.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

ActiveMQ lease-database-locker in Servicemix - Class not found

[mtod]

I'm working with ActiveMQ in Servicemix 7.0 trying to get the
lease-database-locker working.

I have it working in stand alone mode using MSSql but when I place the same
configuration in Servicemix it says :

Caused by: java.lang.ClassNotFoundException:
org.apache.commons.dbcp2.BasicDataSource not found by
org.apache.activemq.activemq-osgi.

I can't find how to install that class in Servicemix.

I'm not sure what I'm missing or if there is another way to do this.

Thanks

Mike 

ActiveMQ.xml config





  
  

  
  

  




.














--
View this message in context: 
http://activemq.2283324.n4.nabble.com/ActiveMQ-lease-database-locker-in-Servicemix-Class-not-found-tp4723913.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: cameRoutesBrokerPlugin namespace question

[mtod]

I noticed you said "next Camel 2.18.x" so does that mean it's not in the
current 2.18.1?

Any idea when that will be out?


Thanks
Mike




--
View this message in context: 
http://activemq.2283324.n4.nabble.com/cameRoutesBrokerPlugin-namespace-question-tp4720237p4720271.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: cameRoutesBrokerPlugin namespace question

[mtod]

Thanks for that info.

Do you have an example? 
I tried Camel 2.18.1

*Activemq.log*
jvm 1|  INFO | Apache Camel 2.18.1 (CamelContext:
EmbeddedCamel-localhost) started in 0.166 seconds

*My routes file:*

http://camel.apache.org/schema/spring";
xmlns:km="http://xsdrepo..com/messaging/esb"; >

http://xsdrepo..com/messaging/esb/ESBMessageV3.xsd"/>
 

/km:FMIMessage/km:Header/km:Route/text()


Route1



org.apache.camel.ValidationException


${exception.message}







*Error:
*
jvm 1| org.apache.camel.builder.xml.InvalidXPathExpression: Invalid
xpath: /km:FMIMessage/km:Header/km:Route/text(). Reason:
javax.xml.xpath.XPathExpressionException: com.sun.org.apache.xpath.inte
rnal.domapi.XPathStylesheetDOM3Exception: Prefix must resolve to a
namespace: km
jvm 1|  at
org.apache.camel.builder.xml.XPathBuilder.evaluateAs(XPathBuilder.java:794)[camel-core-2.18.1.jar:2.18.1]




--
View this message in context: 
http://activemq.2283324.n4.nabble.com/cameRoutesBrokerPlugin-namespace-question-tp4720237p4720268.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

cameRoutesBrokerPlugin namespace question

[mtod]

I'm working with ActiveMQ 5.14.1 and trying to get the
camelRoutesBrokerPlugin to work with namespaces.

when I setup a routes.xml file that uses the following:

http://camel.apache.org/schema/spring";
xmlns:km="http://xsdrepo..com/messaging/esb"; >



http://xsdrepo..com/messaging/esb/ESBMessageV3.xsd"/>

/km:FMIMessage/km:Header/km:Route/text()


Route1



org.apache.camel.ValidationException


${exception.message}







And send a message to the esb.testit queue I receive a namespace error :
Prefix must resolve to a namespace: km

Normally using an import with a cameContext I would place the namespace in
the camelContext element.

such as :

http://camel.apache.org/schema/spring";
xmlns:km="http://xsdrepo..com/messaging/esb";>   


That would work fine but with the plugin I don't seem to have that option.

Is there a way to add a namespace to the routes.xml camel file?

Thanks

Mike



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/cameRoutesBrokerPlugin-namespace-question-tp4720237.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

ActiveMQ Locking down Web Console via LDAP

[mtod]

I'm in the process of setting up ActiveMQ to use LDAP on Active Directory.

I have it working for the JMS connections but I'm running into some issues
on the Web Console.
I gone through all the doc's and email threads I can find on the subject.
My setup is a Windows 10 desktop ActiveMQ loaded locally connecting to my AD
domain on remote server.

I'm using ActiveMQ version 5.14.1

*When I access using the Web Console I get this:*

HTTP ERROR: 403

Problem accessing /admin/. Reason:

!role
Powered by Jetty:// 9.3.z-SNAPSHOT

Does anyone have an idea why this would happen?

Thanks
Mike


*Here is a snapshot of my console:*

jvm 1|  INFO | jetty-9.3.z-SNAPSHOT
jvm 1|  INFO | No Spring WebApplicationInitializer types detected on
classpath
jvm 1|  INFO | Refreshing Root WebApplicationContext: startup date [Wed
Oct 26 14:00:46 PDT 2016]; root of context hierarchy
jvm 1|  INFO | Loading XML bean definitions from ServletContext resource
[/WEB-INF/webconsole-embedded.xml]
jvm 1|  INFO | Loading XML bean definitions from ServletContext resource
[/WEB-INF/webconsole-query.xml]
jvm 1|  INFO | Loading properties file from URL
[file:../../conf/credentials.properties]
jvm 1|  INFO | ActiveMQ WebConsole available at http://0.0.0.0:8161/
jvm 1|  INFO | ActiveMQ Jolokia REST API available at
http://0.0.0.0:8161/api/jolokia/
jvm 1|  INFO | Initializing Spring FrameworkServlet 'dispatcher'
jvm 1|  INFO | FrameworkServlet 'dispatcher': initialization started
jvm 1|  INFO | Refreshing WebApplicationContext for namespace
'dispatcher-servlet': startup date [Wed Oct 26 14:00:46 PDT 2016]; parent:
Root WebApplicationContext
jvm 1|  INFO | Loading XML bean definitions from ServletContext resource
[/WEB-INF/dispatcher-servlet.xml]
jvm 1|  INFO | Mapped URL path [/createDestination.action] onto handler
'/createDestination.action'
jvm 1|  INFO | Mapped URL path [/deleteDestination.action] onto handler
'/deleteDestination.action'
jvm 1|  INFO | Mapped URL path [/createSubscriber.action] onto handler
'/createSubscriber.action'
jvm 1|  INFO | Mapped URL path [/deleteSubscriber.action] onto handler
'/deleteSubscriber.action'
jvm 1|  INFO | Mapped URL path [/sendMessage.action] onto handler
'/sendMessage.action'
jvm 1|  INFO | Mapped URL path [/purgeDestination.action] onto handler
'/purgeDestination.action'
jvm 1|  INFO | Mapped URL path [/deleteMessage.action] onto handler
'/deleteMessage.action'
jvm 1|  INFO | Mapped URL path [/copyMessage.action] onto handler
'/copyMessage.action'
jvm 1|  INFO | Mapped URL path [/moveMessage.action] onto handler
'/moveMessage.action'
jvm 1|  INFO | Mapped URL path [/deleteJob.action] onto handler
'/deleteJob.action'
jvm 1|  INFO | Mapped URL path [/retryMessage.action] onto handler
'/retryMessage.action'
jvm 1|  INFO | FrameworkServlet 'dispatcher': initialization completed
in 139 ms
jvm 1|  INFO | Started
o.e.j.w.WebAppContext@a49d8a{/admin,file:///C:/Apache/apache-activemq-5.14.1/webapps/admin/,AVAILABLE}
jvm 1|  INFO | ActiveMQ Console at
http://ServerConnector@1a854e0{HTTP/1.1,[http/1.1]}{0.0.0.0:8161}/admin
jvm 1|  INFO | No Spring WebApplicationInitializer types detected on
classpath
jvm 1|  INFO | jolokia-agent: Using policy access restrictor
classpath:/jolokia-access.xml
jvm 1|  INFO | Started
o.e.j.w.WebAppContext@1362cf8{/api,file:///C:/Apache/apache-activemq-5.14.1/webapps/api/,AVAILABLE}
jvm 1|  INFO | Apache ActiveMQ REST API at
http://ServerConnector@1a854e0{HTTP/1.1,[http/1.1]}{0.0.0.0:8161}/api
jvm 1|  INFO | Started
ServerConnector@1a854e0{HTTP/1.1,[http/1.1]}{0.0.0.0:8161}
jvm 1|  INFO | Started @2857ms


*My Jetty.xml sections that I have changed:*





















  
  


*My login.xml:*


LDAP-Login { 
   org.apache.activemq.jaas.LDAPLoginModule required 
 debug=true 
 initialContextFactory=com.sun.jndi.ldap.LdapCtxFactory 
 connectionURL="ldap://corp.local"; 
 connectionUsername="CN=Mirth Development Service Account,OU=Service
Accounts,DC=corp,DC=local"
 connectionPassword="X"
 connectionProtocol=s 
 authentication=simple
 userBase="OU=Service Accounts,DC=corp,DC=local" 
 userSearchMatching="(samaccountname={0})" 
 userSearchSubtree=true
 roleBase="OU=Server Access Groups,OU=IT Security Groups,OU=Domain
Groups,DC=corp,DC=local" 
 roleName=CN 
 roleSearchMatching="(memberOf={0})" 
 roleSearchSubtree=true 
 ; 
}; 









--
View this message in context: 
http://activemq.2283324.n4.nabble.com/ActiveMQ-Locking-down-Web-Console-via-LDAP-tp4718545.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Orphaned connections to TempTopic

[mtod]

I'm running ActiveMQ 5.10 in production on a Windows Server.

The system has been running fine for a few years now except for a connection
issue where we have orphaned connections to
ActiveMQ.Advisory.TempQueue,ActiveMQ.Advisory.TempTopic.

Over time it will use up all available memory and the system will stop
accepting messages.
I reset activemq and it works fine for about 60 days then run's out of
memory.

I can not id the client as it comes from a Mirth connect system with a large
number of channels that connect to ActiveMQ. 

We are getting ready to move to a Network of Brokers model in the cloud so
disabling the TempQueues is not an option.


Any ideas how to id the source or correct the issue.

Thanks for the help.

Mike

*My ActiveMQ.xml*



http://www.springframework.org/schema/beans";
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
  xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
  http://camel.apache.org/schema/spring
http://camel.apache.org/schema/spring/camel-spring.xsd
  http://activemq.apache.org/schema/core
http://activemq.apache.org/schema/core/activemq-core.xsd";>





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





















http://activemq.apache.org/schema/core"; 
populateJMSXUserID="true" useJmx="true" start="false" brokerName="localhost"
dataDirectory="${activemq.data}" offlineDurableSubscriberTimeout="25920"
offlineDurableSubscriberTaskSchedule="360">
























  



   




























  





























http://www.springframework.org/schema/beans";
class="org.apache.activemq.hooks.SpringContextHook" />















--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Orphaned-connections-to-TempTopic-tp4716676.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Network of brokers setup error

[mtod]

Thanks Tim

I have it working now with the masterslave option.

Question: I'm setting up a masterslave cluster in Germany, China and other
US Based locations is there any best practices for distributed clusters?

Mike



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Network-of-brokers-setup-error-tp4715603p4715639.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Network of brokers setup error

[mtod]

Additional info I left out.

This is running ActiveMQ 5.14 in a SQL lock / Kahadb configuration on
Windows 2012 core servers.






--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Network-of-brokers-setup-error-tp4715603p4715604.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Network of brokers setup error

[mtod]

I have some issues with the network of brokers configuration I keep getting a
failure to connect.

The setup for the network of brokers is as follows:

Broker1 Master/Slave
Node 1 (Master)
Node 2 (Slave)

Broker 2 Master/Slave
Node 1 (Master)
Node 2 (Slave)

Both clusters work fine.

The activemq.xml broker setup:

Broker1:


 

Broker2:





Section of the activeMQ log:

2016-08-17 13:25:58,599 | DEBUG | Attempting 2th connect to:
tcp://192.168.10.4:61616 |
org.apache.activemq.transport.failover.FailoverTransport | ActiveMQ Failover
Worker: 236039765
2016-08-17 13:25:59,616 | DEBUG | Connect fail to: tcp://192.168.10.4:61616,
reason: java.net.ConnectException: Connection refused: connect |
org.apache.activemq.transport.failover.FailoverTransport | ActiveMQ Failover
Worker: 236039765
2016-08-17 13:25:59,616 | DEBUG | Stopping transport
tcp://192.168.10.4:61616 | org.apache.activemq.transport.tcp.TcpTransport |
ActiveMQ Failover Worker: 236039765
2016-08-17 13:25:59,616 | DEBUG | Initialized TaskRunnerFactory[ActiveMQ
Task] using ExecutorService: null |
org.apache.activemq.thread.TaskRunnerFactory | ActiveMQ Failover Worker:
236039765
2016-08-17 13:25:59,616 | DEBUG | Closed socket Socket[unconnected] |
org.apache.activemq.transport.tcp.TcpTransport | ActiveMQ Task-1
2016-08-17 13:25:59,616 | DEBUG | Waiting 40 ms before attempting connection
| org.apache.activemq.transport.failover.FailoverTransport | ActiveMQ
Failover Worker: 236039765

Thanks for the help

Mike



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Network-of-brokers-setup-error-tp4715603.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Leveldb not recovering from failover

[mtod]

I'm coming to the conclusion that LevelDB is not ready for prime time.

I have run this scenario several times and it just keeps failing over time.

I think I'm going to have to look for another solution.

Thanks

Mike
 



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Leveldb-not-recovering-from-failover-tp4709307p4709941.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Leveldb not recovering from failover

[mtod]

I think I found the issue it was a typo in the activemq.xml leveldb config.

I setup a new test I'll report back.

Thanks
Mike




--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Leveldb-not-recovering-from-failover-tp4709307p4709317.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Leveldb not recovering from failover

[mtod]

I have a 3 node cluster on Redhat servers running ActiveMQ version 5.13.2 and
Zookeeper 3.4.8

The system runs without error for days then when I fail it over it will
sometimes will not recover see log segment below.
The strange thing is I’m getting a Connection refused even from the master
connecting to itself.

Does anyone have any idea what might cause this?

Server1
ActiveMQ.log
2016-03-15 11:57:27,756 | WARN  | Store update waiting on 1 replica(s) to
catch up to log position 1268728231.  |
org.apache.activemq.leveldb.replicated.MasterLevelDBStore | ActiveMQ
BrokerService[localhost] Task-24
2016-03-15 11:57:28,757 | WARN  | Store update waiting on 1 replica(s) to
catch up to log position 1268728231.  |
org.apache.activemq.leveldb.replicated.MasterLevelDBStore | ActiveMQ
BrokerService[localhost] Task-24
2016-03-15 11:57:29,758 | WARN  | Store update waiting on 1 replica(s) to
catch up to log position 1268728231.  |
org.apache.activemq.leveldb.replicated.MasterLevelDBStore | ActiveMQ
BrokerService[localhost] Task-24

Server2
ActiveMQ.log
2016-03-15 11:58:27,575 | INFO  | Using the pure java LevelDB
implementation. | org.apache.activemq.leveldb.LevelDBClient |
hawtdispatch-DEFAULT-1
2016-03-15 11:58:27,575 | INFO  | Attaching to master:
tcp://Server2.corp.local:61619 |
org.apache.activemq.leveldb.replicated.SlaveLevelDBStore |
hawtdispatch-DEFAULT-1
2016-03-15 11:58:27,577 | WARN  | Unexpected session error:
java.net.ConnectException: Connection refused |
org.apache.activemq.leveldb.replicated.SlaveLevelDBStore |
hawtdispatch-DEFAULT-1

Server3
ActiveMQ.log
2016-03-15 11:58:27,484 | INFO  | Using the pure java LevelDB
implementation. | org.apache.activemq.leveldb.LevelDBClient |
hawtdispatch-DEFAULT-1
2016-03-15 11:58:27,485 | INFO  | Attaching to master:
tcp://Server2.corp.local:61619 |
org.apache.activemq.leveldb.replicated.SlaveLevelDBStore |
hawtdispatch-DEFAULT-1
2016-03-15 11:58:27,487 | WARN  | Unexpected session error:
java.net.ConnectException: Connection refused |
org.apache.activemq.leveldb.replicated.SlaveLevelDBStore |
hawtdispatch-DEFAULT-1

Thanks
Mike




--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Leveldb-not-recovering-from-failover-tp4709307.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Help with a Failover testing that shows missing messages

[mtod]

So I found one issue that seems to have stabilized it a bit.

My ops gave me 3 boxes with only 1 Gig Ram and 1 CPU.

I increased that to 4 Gig Ram and 2 CPU's and it seems to be running better.

I don't see any out of order messages so nothing to report. 

I performed a few reboot's to test fail over and the NMS clients seem to
resume the fail-over but it seems to take a bit longer then I like.

I still get this error:

2016-03-07 11:55:01,334 | WARN  | Invalid log position: 195605985 |
org.apache.activemq.leveldb.LevelDBClient | Thread-14
2016-03-07 11:55:01,335 | WARN  | Invalid log position: 195609854 |
org.apache.activemq.leveldb.LevelDBClient | Thread-14
2016-03-07 11:55:01,336 | WARN  | Invalid log position: 195613723 |
org.apache.activemq.leveldb.LevelDBClient | Thread-14
2016-03-07 11:55:01,336 | WARN  | Invalid log position: 195617592 |
org.apache.activemq.leveldb.LevelDBClient | Thread-14
2016-03-07 11:55:01,337 | WARN  | Invalid log position: 195621461 |
org.apache.activemq.leveldb.LevelDBClient | Thread-14

I'm not sure what that is all about.

Other note: I had to remove the transacted=true as it was stopping and
starting the connectors over and over.
Also I'm not using connectionpooling should I be?

Thanks

Mike






--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Help-with-a-Failover-testing-that-shows-missing-messages-tp4707916p4708987.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Help with a Failover testing that shows missing messages

[mtod]

Thanks for the response.

I'll give that a try and report back.

Mike



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Help-with-a-Failover-testing-that-shows-missing-messages-tp4707916p4708802.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Help with a Failover testing that shows missing messages

[mtod]

Sorry yes I did read his post.

I was already using a durable subscription.

C# code.

public SimpleTopicSubscriber(string topicName, string brokerUri,
string clientId, string consumerId, string filter, string userID, string
password, string message)
{
try 
{
this.topicName = topicName;
this.connectionFactory = new ConnectionFactory(brokerUri);
if (!String.IsNullOrEmpty(userID))
{
this.connection =
this.connectionFactory.CreateConnection(userID, password);
}
else
{
this.connection =
this.connectionFactory.CreateConnection();
}
this.connection.ClientId = clientId;
this.connection.Start();
this.session = connection.CreateSession();
ActiveMQTopic topic = new ActiveMQTopic(topicName);

   * this.consumer = this.session.CreateDurableConsumer(topic,
consumerId, filter, false);*
this.consumer.Listener += new MessageListener(OnMessage);
}
catch(NMSException ex)
{
Console.WriteLine(ex);
}
}



I did just find an older 2009 post where the NMS C# code did not work. I'm
not sure if that has been fixed.

http://activemq.2283324.n4.nabble.com/NMS-durable-consumer-not-durable-td2366254.html

I'm going to setup the same test using JMeter and see if I can get the same
results.

Thanks

Mike



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Help-with-a-Failover-testing-that-shows-missing-messages-tp4707916p4708791.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Help with a Failover testing that shows missing messages

[mtod]

To expand on model a bit :

The model is currently designed to support a Pub/Sub model. We have several
applications that publish documents and events to ActiveMQ. Each application
is assigned a queue each message that is submitted to the queue is placed in
an XML wrapper (see below) using a Camel route the message is sent to a
topic or queue that is described in the message envelope Route element.

So on one side we have queues that represents the applications. On the other
side we have queues/topics that represents data types such as xml Documents,
Events,  This allows the developers to have a single point of entry and
control of the routing of data.

 

Example Message:

http://xsdrepo..com/messaging/esb"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="http://xsdrepo..com/messaging/esb
http://xsdrepo..com/messaging/esb/ESBMessageV3.xsd">
  
1.4
Event
Info
LPublisher
activemq:topic:TrackingEvent
ALL
  
  
http://xsdrepo..com/messaging"
xmlns:xsd="http://www.w3.org/2001/XMLSchema";
xsi:schemaLocation="http://xsdrepo..com/messaging
http://xsdrepo..com/messaging/trfevent.xsd">
  470208
  Specimen
  2015-09-08T12:42:06
  TRFX
  TRFX.01
  Accessioning
  TRFX.01
  Created
  
  
TRFX
  

  




--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Help-with-a-Failover-testing-that-shows-missing-messages-tp4707916p4708718.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Help with a Failover testing that shows missing messages

[mtod]

Thanks for all the help.

I removed the chaos monkey and started a new run. I don't think I will see
any errors this model has been running in my production for 2 years. The
only difference is that this is using a newer version of ActiveMQ and
LevelDB on a Linux cluster.

Granted I have not had to many outages in production and it's a single
server. (only due to some REST requirements) :(

Short term my goal is to move to a more robust model then over time move to
a more full featured ESB (maybe Service Mix or Fuse etc.)

Production today:
ActiveMQ 5.10 running on Windows Server with KahaDB.

New Redhat cluster:
ActiveMQ 5.13.1 running zookeeper / leveldb

I looked for any DLQ or other error queues and I don't see any messages.

I attached my ActiveMQ conf and zookeeper conf for reference.

ActiveMQFourm.zip
  

Thanks




--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Help-with-a-Failover-testing-that-shows-missing-messages-tp4707916p4708716.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Help with a Failover testing that shows missing messages

[mtod]

I'm checking for the missing messages at the subscriber client.

I generate the messages with sequential numbering so the client can detect
when one is missing.

I ran it over the weekend and I don't see any correlation between the
missing messages and the reboots/failovers.

subscriber :

Starting Log : 2/26/2016 2:02:21 PM
[2/26/2016 3:03:34 PM] > Missing Message : 2405 <<
[2/26/2016 6:49:47 PM] > Missing Message : 9661 <<
[2/26/2016 10:38:35 PM] > Missing Message : 17808 <<
[2/27/2016 9:14:35 AM] > Missing Message : 36965 <<
[2/27/2016 8:44:52 PM] > Missing Message : 56017 <<
[2/27/2016 9:08:28 PM] > Missing Message : 56697 <<
[2/28/2016 3:27:55 PM] > Missing Message : 87836 <<

Reboots:

Fri 02/26/2016 14:02:57.73 - Starting ActiveMQ Test Cycle  
Fri 02/26/2016 14:02:59.35 - Rebooted server041 
Fri 02/26/2016 14:16:21.68 - Rebooted server042 
Fri 02/26/2016 14:29:43.20 - Rebooted server043 
Fri 02/26/2016 14:43:09.15 - Rebooted server041 
Fri 02/26/2016 14:56:30.93 - Rebooted server042 
Fri 02/26/2016 15:09:51.89 - Rebooted server043 
Fri 02/26/2016 15:23:13.06 - Rebooted server041 
Fri 02/26/2016 15:36:35.09 - Rebooted server042 
Fri 02/26/2016 15:49:59.70 - Rebooted server043 
Fri 02/26/2016 16:03:20.78 - Rebooted server041 
Fri 02/26/2016 16:16:42.61 - Rebooted server042 
Fri 02/26/2016 16:30:05.00 - Rebooted server043 
Fri 02/26/2016 16:43:27.20 - Rebooted server041 
Fri 02/26/2016 16:56:48.92 - Rebooted server042 
Fri 02/26/2016 17:10:09.63 - Rebooted server043 
Fri 02/26/2016 17:23:30.97 - Rebooted server041 
Fri 02/26/2016 17:36:53.93 - Rebooted server042 
Fri 02/26/2016 17:50:14.85 - Rebooted server043 
Fri 02/26/2016 18:03:36.07 - Rebooted server041 
Fri 02/26/2016 18:16:58.10 - Rebooted server042 
Fri 02/26/2016 18:30:22.48 - Rebooted server043 
Fri 02/26/2016 18:43:46.99 - Rebooted server041 
Fri 02/26/2016 18:57:11.12 - Rebooted server042 
Fri 02/26/2016 19:10:35.79 - Rebooted server043 
Fri 02/26/2016 19:24:00.48 - Rebooted server041 
Fri 02/26/2016 19:37:25.27 - Rebooted server042 
Fri 02/26/2016 19:50:50.03 - Rebooted server043 
Fri 02/26/2016 20:04:14.47 - Rebooted server041 
Fri 02/26/2016 20:17:38.34 - Rebooted server042 
Fri 02/26/2016 20:31:03.65 - Rebooted server043 
Fri 02/26/2016 20:44:27.53 - Rebooted server041 
Fri 02/26/2016 20:57:51.21 - Rebooted server042 
Fri 02/26/2016 21:11:15.29 - Rebooted server043 
Fri 02/26/2016 21:24:39.29 - Rebooted server041 
Fri 02/26/2016 21:38:01.77 - Rebooted server042 
Fri 02/26/2016 21:51:24.04 - Rebooted server043 
Fri 02/26/2016 22:04:45.98 - Rebooted server041 
Fri 02/26/2016 22:18:08.53 - Rebooted server042 
Fri 02/26/2016 22:31:33.22 - Rebooted server043 
Fri 02/26/2016 22:44:57.32 - Rebooted server041 
Fri 02/26/2016 22:58:20.99 - Rebooted server042 
Fri 02/26/2016 23:11:45.27 - Rebooted server043 
Fri 02/26/2016 23:25:09.33 - Rebooted server041 
Fri 02/26/2016 23:38:33.40 - Rebooted server042 
Fri 02/26/2016 23:51:57.75 - Rebooted server043 
Sat 02/27/2016  0:05:21.77 - Rebooted server041 
Sat 02/27/2016  0:18:43.40 - Rebooted server042 
Sat 02/27/2016  0:32:05.02 - Rebooted server043 
Sat 02/27/2016  0:45:27.10 - Rebooted server041 
Sat 02/27/2016  0:58:52.49 - Rebooted server042 
Sat 02/27/2016  1:12:13.90 - Rebooted server043 
Sat 02/27/2016  1:25:34.84 - Rebooted server041 
Sat 02/27/2016  1:38:56.03 - Rebooted server042 
Sat 02/27/2016  1:52:17.86 - Rebooted server043 
Sat 02/27/2016  2:05:39.70 - Rebooted server041 
Sat 02/27/2016  2:19:01.04 - Rebooted server042 
Sat 02/27/2016  2:32:22.57 - Rebooted server043 
Sat 02/27/2016  2:45:46.45 - Rebooted server041 
Sat 02/27/2016  2:59:08.06 - Rebooted server042 
Sat 02/27/2016  3:12:31.96 - Rebooted server043 
Sat 02/27/2016  3:25:53.32 - Rebooted server041 
Sat 02/27/2016  3:39:15.04 - Rebooted server042 
Sat 02/27/2016  3:52:36.85 - Rebooted server043 
Sat 02/27/2016  4:05:58.78 - Rebooted server041 
Sat 02/27/2016  4:19:19.53 - Rebooted server042 
Sat 02/27/2016  4:32:40.84 - Rebooted server043 
Sat 02/27/2016  4:46:06.82 - Rebooted server041 
Sat 02/27/2016  4:59:28.61 - Rebooted server042 
Sat 02/27/2016  5:12:52.28 - Rebooted server043 
Sat 02/27/2016  5:26:18.66 - Rebooted server041 
Sat 02/27/2016  5:39:43.46 - Rebooted server042 
Sat 02/27/2016  5:53:06.54 - Rebooted server043 
Sat 02/27/2016  6:06:29.86 - Rebooted server041 
Sat 02/27/2016  6:19:50.61 - Rebooted server042 
Sat 02/27/2016  6:33:13.83 - Rebooted server043 
Sat 02/27/2016  6:46:36.52 - Rebooted server041 
Sat 02/27/2016  6:59:58.61 - Rebooted server042 
Sat 02/27/2016  7:13:21.27 - Rebooted server043 
Sat 02/27/2016  7:26:42.84 - Rebooted server041 
Sat 02/27/2016  7:40:03.89 - Rebooted server042 
Sat 02/27/2016  7:53:24.98 - Rebooted server043 
Sat 02/27/2016  8:06:46.75 - Rebooted server041 
Sat 02/27/2016  8:20:08.04 - Rebooted server042 
Sat

Re: Help with a Failover testing that shows missing messages

[mtod]

Great suggestions I'll increase some of my logging to see if I can narrow it
down a bit.

I'm not logging the reboots so I'll add a log for that.
Also check the DLQ and the invalid.schema
Add a general exception trap.

Thanks

I'll do some more testing and report back.

Mike
 



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Help-with-a-Failover-testing-that-shows-missing-messages-tp4707916p4708363.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Help with a Failover testing that shows missing messages

[mtod]

Thanks for the reply.

So I'm still seeing this issue even after turning on Camel transacted=true.

 http://camel.apache.org/schema/spring";
xmlns:km="http:///messaging/esb"/>




http://xsdrepo-stg.foundationmedicine.com/messaging/esb/ESBMessageV3.xsd"/>

/km:FMIMessage/km:Header/km:Route/text()


Route1


   
org.apache.camel.ValidationException

   
${exception.message}









As far as the connection between the client and Broker I'm using NMS and
configured a durable publisher and subscriber. So I'm not sure this would be
the case I would have expected an exception if it could not submit a
message.

As far as the network brokers I'm only using a single broker.

Thanks

Mike





--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Help-with-a-Failover-testing-that-shows-missing-messages-tp4707916p4708356.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Help with a Failover testing that shows missing messages

[mtod]

Thanks I'll give it a try and report back.

Mike




--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Help-with-a-Failover-testing-that-shows-missing-messages-tp4707916p4708038.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Help with a Failover testing that shows missing messages

[mtod]

Thanks for the reply.

The messages were missing across all clients.

Not sure what you referring to about Camel Ack mode.

I  add the Camel file using an import in the ActiveMQ file

...

 

Here is my Camel Code:


http://www.springframework.org/schema/beans";
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
  xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
  http://camel.apache.org/schema/spring
http://camel.apache.org/schema/spring/camel-spring.xsd
  http://activemq.apache.org/schema/core
http://activemq.apache.org/schema/core/activemq-core.xsd";>




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







 





http://camel.apache.org/schema/spring";
xmlns:km="http://xsdrepo.foundationmedicine.com/messaging/esb";> 



 
http://xsdrepo.foundationmedicine.com/messaging/esb/ESBMessageV3.xsd"/>
 

/km:FMIMessage/km:Header/km:Route/text()


Route1



org.apache.camel.ValidationException 



${exception.message}










--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Help-with-a-Failover-testing-that-shows-missing-messages-tp4707916p4707937.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Help with a Failover testing that shows missing messages

[mtod]

I setup a fail-over test and ran it over a 12 day term I sent about 100K
messages to the system. What I found was that messages were getting dropped. 

•   [2/10/2016 7:23:54 PM] > Missing Message : 8993 
<<
•   [2/14/2016 7:00:34 PM] > Missing Message : 38404
<<
•   [2/18/2016 3:05:58 AM] > Missing Message : 63431
<<
•   [2/19/2016 8:08:05 AM] > Missing Message : 73697
<<
•   [2/19/2016 9:11:56 PM] > Missing Message : 77764
<<

I really can’t figure out why this would happen any ideas would be greatly
appreciated. 

My Setup:

•   3 Node cluster of ActiveMQ V5.13.0
•   Running zookeeper V 3.4.7
•   3 Redhat servers
•   1 Windows 10 desktop running NMS clients
•   1 Windows Server running 2008 running NMS clients

Test setup:

•   1 NMS Client publishing an XML messages every 10 seconds
o   Connection failover:(tcp://:61616,tcp://
:61616,tcp:// :61616?initialReconnectDelay=100)
o   1 millisecond delay between messages
•   Camel route:
o   NMS client places the incoming messages into a queue.
o   Then Camel routes the message to a Topic
o   NMS clients read the messages off the Topic.
•   4 subscribers reading from a Topic
o   Connection failover:(tcp://:61616,tcp://
:61616,tcp:// :61616?initialReconnectDelay=100)
•   Failover batch script:
o   Reboots a single node every 5 mins.




--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Help-with-a-Failover-testing-that-shows-missing-messages-tp4707916.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

ActiveMQ 5.13 leveldb cluster failing over weekend

[mtod]

I setup a 3 node ActiveMQ / Leveldb cluster using 5.13 Activemq running on
RedHat in a VM.
I'm also using the java wrapper.

It seems to run fine I ran 50K messages thru for a test and failed over many
times.

But when left alone over a weekend some of the nodes fail. See below from
ActiveMQ log.

Has anyone run into this?

2016-01-07 15:05:49,435 | INFO  | Unable to read additional data from server
sessionid 0x2520de0943f, likely server has closed socket, closing socket
connection and attempting reconnect | org.apache.zookeeper.ClientCnxn |
WrapperSimpleAppMain-SendThread(appdev042.corp.local:2181)
2016-01-07 15:05:49,677 | INFO  | Slave stopped |
org.apache.activemq.leveldb.replicated.MasterElector | ActiveMQ
BrokerService[localhost] Task-8
2016-01-07 15:05:50,440 | INFO  | Client will use DIGEST-MD5 as SASL
mechanism. | org.apache.zookeeper.client.ZooKeeperSaslClient |
WrapperSimpleAppMain-SendThread(appdev041.corp.local:2181)
2016-01-07 15:05:50,441 | INFO  | Opening socket connection to server
appdev041.corp.local/10.150.32.101:2181. Will attempt to SASL-authenticate
using Login Context section 'Client' | org.apache.zookeeper.ClientCnxn |
WrapperSimpleAppMain-SendThread(appdev041.corp.local:2181)
2016-01-07 15:05:50,442 | INFO  | Socket connection established to
appdev041.corp.local/10.150.32.101:2181, initiating session |
org.apache.zookeeper.ClientCnxn |
WrapperSimpleAppMain-SendThread(appdev041.corp.local:2181)
2016-01-07 15:05:50,448 | INFO  | Session establishment complete on server
appdev041.corp.local/10.150.32.101:2181, sessionid = 0x2520de0943f,
negotiated timeout = 4000 | org.apache.zookeeper.ClientCnxn |
WrapperSimpleAppMain-SendThread(appdev041.corp.local:2181)
2016-01-07 15:05:50,453 | WARN  | unprocessed event state: SaslAuthenticated
| org.apache.activemq.leveldb.replicated.groups.ZKClient |
WrapperSimpleAppMain-EventThread
2016-01-07 15:05:50,490 | INFO  | Using the pure java LevelDB
implementation. | org.apache.activemq.leveldb.LevelDBClient | ActiveMQ
BrokerService[localhost] Task-9
2016-01-07 15:05:50,492 | INFO  | Attaching to master:
tcp://appdev043.corp.local:60854 |
org.apache.activemq.leveldb.replicated.SlaveLevelDBStore | ActiveMQ
BrokerService[localhost] Task-9
2016-01-07 15:05:50,493 | INFO  | Slave started |
org.apache.activemq.leveldb.replicated.MasterElector | ActiveMQ
BrokerService[localhost] Task-9
2016-01-07 15:05:50,937 | ERROR | Could not refresh JMS Connection for
destination 'esb.*' - retrying using FixedBackOff{interval=5000,
currentAttempts=17673, maxAttempts=unlimited}. Cause: Could not create
Transport. Reason: java.io.IOException: Broker named 'localhost' does not
exist. | org.apache.camel.component.jms.DefaultJmsMessageListenerContainer |
Camel (esbRoute1) thread #0 - JmsConsumer[esb.*]
2016-01-07 15:05:51,030 | INFO  | Slave skipping download of:
log/12c00b6a.log |
org.apache.activemq.leveldb.replicated.SlaveLevelDBStore |
hawtdispatch-DEFAULT-1
2016-01-07 15:05:51,178 | INFO  | Slave requested:
135ad8bd.index/CURRENT |
org.apache.activemq.leveldb.replicated.SlaveLevelDBStore |
hawtdispatch-DEFAULT-1
2016-01-07 15:05:51,180 | INFO  | Slave requested:
135ad8bd.index/29.sst |
org.apache.activemq.leveldb.replicated.SlaveLevelDBStore |
hawtdispatch-DEFAULT-1
2016-01-07 15:05:51,180 | INFO  | Slave requested:
135ad8bd.index/28.log |
org.apache.activemq.leveldb.replicated.SlaveLevelDBStore |
hawtdispatch-DEFAULT-1
2016-01-07 15:05:51,181 | INFO  | Slave requested:
135ad8bd.index/MANIFEST-26 |
org.apache.activemq.leveldb.replicated.SlaveLevelDBStore |
hawtdispatch-DEFAULT-1
2016-01-07 15:05:51,187 | INFO  | Attaching... Downloaded 0.02/4670.44 kb
and 1/4 files | org.apache.activemq.leveldb.replicated.SlaveLevelDBStore |
hawtdispatch-DEFAULT-1
2016-01-07 15:05:51,194 | INFO  | Attaching... Downloaded 744.92/4670.44 kb
and 2/4 files | org.apache.activemq.leveldb.replicated.SlaveLevelDBStore |
hawtdispatch-DEFAULT-1
2016-01-07 15:05:51,209 | INFO  | Attaching... Downloaded 4669.99/4670.44 kb
and 3/4 files | org.apache.activemq.leveldb.replicated.SlaveLevelDBStore |
hawtdispatch-DEFAULT-1
2016-01-07 15:05:51,210 | INFO  | Attaching... Downloaded 4670.44/4670.44 kb
and 4/4 files | org.apache.activemq.leveldb.replicated.SlaveLevelDBStore |
hawtdispatch-DEFAULT-1
2016-01-07 15:05:51,211 | INFO  | Attached |
org.apache.activemq.leveldb.replicated.SlaveLevelDBStore |
hawtdispatch-DEFAULT-1
2016-01-07 15:05:58,082 | INFO  | Client session timed out, have not heard
from server in 3592ms for sessionid 0x2520de0943f, closing socket
connection and attempting reconnect | org.apache.zookeeper.ClientCnxn |
WrapperSimpleAppMain-SendThread(appdev041.corp.local:2181)
2016-01-07 15:05:58,227 | INFO  | Slave stopped |
org.apache.activemq.leveldb.replicated.MasterElector | ActiveMQ
BrokerService[localhost] Task-12
2016-01-07 15:05:58,435 | INFO  | Client will use DIGEST-MD5 as SASL
mechanism. | org.apache.zookeeper.client.Zo

Re: replicatedLevelDB errors after failover

[mtod]

Was this ever resolved?

I'm testing a leveldb cluster and was performing some fail over and I now
have the same problem.

 
 



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/replicatedLevelDB-errors-after-failover-tp4674550p4705479.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: suppress error from Camel Route on slave

[mtod]

That's what I would like to happen but the question is how?

Thanks

Mike



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/suppress-error-from-Camel-Route-on-slave-tp4705457p4705478.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

suppress error from Camel Route on slave

[mtod]

I'm running ActiveMQ 5.13 on a leveldb cluster.
My ActiveMQ.xml config contains a Camel route in an include file.



I route xml from one queue to a topic but when slave is in standby mode I
keep getting this error :

INFO   | jvm 1| 2015/12/28 18:10:26 | ERROR | Could not refresh JMS
Connection for destination 'esb.*' - retrying using
FixedBackOff{interval=5000, currentAttempts=181, maxAttempts=unlimited}.
Cause: Could not create Transport. Reason: java.io.IOException: Broker named
'localhost' does not exist.

Is there a way to suppress this error or Non-Error due to it being a slave?

Thanks

Mike




--
View this message in context: 
http://activemq.2283324.n4.nabble.com/suppress-error-from-Camel-Route-on-slave-tp4705457.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: LevelDB setup

[mtod]

Thanks for reaching out Tim.

I would prefer not to use Kerberos right now but I have no examples to
follow.

I'm just want to get something running so I can run some fail-over tests.
I tried the link but looks like I would have to install Kerberos Servers
etc.

I'll reach out to the zookeeper mailing list thanks again.

Mike



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

Re: LevelDB setup

[mtod]

Does anyone have an example of setting up LevelDB other then the ActiveMQ web
site?

I followed them and can't get this to work.

Thanks

Mike



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

Re: LevelDB setup

[mtod]

To follow on I'm also getting :

 INFO | Using the pure java LevelDB implementation.
 INFO | Ignoring IO exception, java.io.IOException:
com.google.common.base.Objects.firstNonNull(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
java.io.IOException:
com.google.common.base.Objects.firstNonNull(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
at
org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:39)[activemq-client-5.12.1.jar:5.12.1]
at
org.apache.activemq.leveldb.LevelDBClient.might_fail(LevelDBClient.scala:552)[activemq-leveldb-store-5.12.1.jar:5.12.1]
at
org.apache.activemq.leveldb.LevelDBClient.replay_init(LevelDBClient.scala:667)[activemq-leveldb-store-5.12.1.jar:5.12.1]
at
org.apache.activemq.leveldb.LevelDBClient.start(LevelDBClient.scala:558)[activemq-leveldb-store-5.12.1.jar:5.12.1]
at
org.apache.activemq.leveldb.DBManager.start(DBManager.scala:648)[activemq-leveldb-store-5.12.1.jar:5.12.1]
at
org.apache.activemq.leveldb.LevelDBStore.doStart(LevelDBStore.scala:312)[activemq-leveldb-store-5.12.1.jar:5.12.1]
at
org.apache.activemq.leveldb.replicated.MasterLevelDBStore.doStart(MasterLevelDBStore.scala:110)[activemq-leveldb-store-5.12.1.jar:5.12.1]
at
org.apache.activemq.util.ServiceSupport.start(ServiceSupport.java:55)[activemq-client-5.12.1.jar:5.12.1]
at
org.apache.activemq.leveldb.replicated.ElectingLevelDBStore$$anonfun$start_master$1.apply$mcV$sp(ElectingLevelDBStore.scala:230)[activemq-leveldb-store-5.12.1.jar:5.12.1]
at
org.fusesource.hawtdispatch.package$$anon$4.run(hawtdispatch.scala:330)[hawtdispatch-scala-2.11-1.21.jar:1.21]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)[:1.7.0_85]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)[:1.7.0_85]
at java.lang.Thread.run(Thread.java:745)[:1.7.0_85]
 INFO | Stopped
LevelDB[/opt/activemq/apache-activemq-5.12.1/bin/activemq-data]




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

LevelDB setup

[mtod]

I'm trying to setup a leveldb cluster on Redhat 3 node cluster.

I have ActiveMQ 5.12.1 zookeeper 3.4.6 installed but I keep getting this
error.

 INFO | Initiating client connection,
connectString=appdev041.corp.local:2181,appdev042.corp.local:2181,appdev043.corp.local:2181
sessionTimeout=2000
watcher=org.apache.activemq.leveldb.replicated.groups.ZKClient@745e3cad
 WARN | Could not login: the client is being asked for a password, but the
Zookeeper client code does not currently support obtaining a password from
the user. Make sure that the client is configured to use a ticket cache
(using the JAAS configuration setting 'useTicketCache=true)' and restart the
client. If you still get this message after that, the TGT in the ticket
cache has expired and must be manually refreshed. To do so, first determine
if you are using a password or a keytab. If the former, run kinit in a Unix
shell in the environment of the user who is running this Zookeeper client
using the command 'kinit ' (where  is the name of the client's
Kerberos principal). If the latter, do 'kinit -k -t  ' (where
 is the name of the Kerberos principal, and  is the location
of the keytab file). After manually refreshing your cache, restart this
client. If you continue to see this message after manually refreshing your
cache, ensure that your KDC host's clock is in sync with this host's clock.
 WARN | SASL configuration failed: javax.security.auth.login.LoginException:
No password provided Will continue connection to Zookeeper server without
SASL authentication, if Zookeeper server allows it.

My loging.config is configured :

activemq-domain {
org.apache.activemq.jaas.PropertiesLoginModule required
org.apache.activemq.jaas.properties.user="users.properties"
org.apache.activemq.jaas.properties.group="groups.properties";
};

Client {
com.sun.security.auth.module.Krb5LoginModule required
useKeyTab=false
useTicketCache=true;
};

My activemq.xml is set to:



and






I'm not sure what's going on thanks for the help.

Thanks

Mike






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

Network of Brokers using 5.12.1 duplicate messages

[mtod]

I'm trying to setup a network of brokers using 3 servers running 5.12.1

For my test I have a single queue the receives messages that are then
content routed to a topic. The topic is subscribed to by 3 clients.

The system seems to be working except I keep getting this message: 

2015-10-19 16:11:57,709 | WARN  | Duplicate message add attempt rejected.
Destination: TOPIC://trfTrackingEvent, Message id:
ID:APPDEV041-57596-1445281015540-9:1:1:800:1 |
org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Transport:
tcp:///XX.XXX.XX.XXX:59394@61616

Any idea why this is being reported?

My Brokers : (Broker_A, Broker_B, Broker_C)

My Broker_B Setup:







  


Thanks
Mike




--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Network-of-Brokers-using-5-12-1-duplicate-messages-tp4703129.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: ActiveMQ 5.12.0 and SQL Server Persistence

[mtod]

Fixed added












--
View this message in context: 
http://activemq.2283324.n4.nabble.com/ActiveMQ-5-12-0-and-SQL-Server-Persistence-tp4702242p4702249.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

ActiveMQ 5.12.0 and SQL Server Persistence

[mtod]

I have ActiveMQ 5.12 using Persistence on SQL Server in my development
environment.
I need to setup a staging environment but I keep getting this error.

Note:

>ActiveMQ 5.12.0
>MS JDBC 4.1
>OS Windows 2012 R2

2015-09-23 15:56:49,354 | INFO  | Using Persistence Adapter:
JDBCPersistenceAdapter(org.apache.commons.dbcp2.BasicDataSource@715a0b19) |
org.apache.activemq.broker.BrokerService | main
2015-09-23 15:56:49,947 | INFO  | Database adapter driver override not found
for : [microsoft_jdbc_driver_4_2_for_sql_server].  Will use default
implementation. | org.apache.activemq.store.jdbc.JDBCPersistenceAdapter |
main
2015-09-23 15:56:50,385 | WARN  | Could not create JDBC tables; they could
already exist. Failure was: CREATE TABLE ACTIVEMQ_MSGS(ID BIGINT NOT NULL,
CONTAINER VARCHAR(250), MSGID_PROD VARCHAR(250), MSGID_SEQ BIGINT,
EXPIRATION BIGINT, MSG BLOB, PRIMARY KEY ( ID ) ) Message: Column,
parameter, or variable #6: Cannot find data type BLOB. SQLState: S0006
Vendor code: 2715 |
org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter | main
2015-09-23 15:56:50,385 | WARN  | Failure details: Column, parameter, or
variable #6: Cannot find data type BLOB. |
org.apache.activemq.store.jdbc.JDBCPersistenceAdapter | main
com.microsoft.sqlserver.jdbc.SQLServerException: Column, parameter, or
variable #6: Cannot find data type BLOB.
at
com.microsoft.sqlserver.jdbc.SQLServerException.makeFromDatabaseError(SQLServerException.java:217)[sqljdbc41.jar:]
at
com.microsoft.sqlserver.jdbc.SQLServerStatement.getNextResult(SQLServerStatement.java:1635)[sqljdbc41.jar:]
at
com.microsoft.sqlserver.jdbc.SQLServerStatement.doExecuteStatement(SQLServerStatement.java:865)[sqljdbc41.jar:]
at
com.microsoft.sqlserver.jdbc.SQLServerStatement$StmtExecCmd.doExecute(SQLServerStatement.java:762)[sqljdbc41.jar:]
at
com.microsoft.sqlserver.jdbc.TDSCommand.execute(IOBuffer.java:6276)[sqljdbc41.jar:]
at
com.microsoft.sqlserver.jdbc.SQLServerConnection.executeCommand(SQLServerConnection.java:1793)[sqljdbc41.jar:]
at
com.microsoft.sqlserver.jdbc.SQLServerStatement.executeCommand(SQLServerStatement.java:184)[sqljdbc41.jar:]
at
com.microsoft.sqlserver.jdbc.SQLServerStatement.executeStatement(SQLServerStatement.java:159)[sqljdbc41.jar:]
at
com.microsoft.sqlserver.jdbc.SQLServerStatement.execute(SQLServerStatement.java:735)[sqljdbc41.jar:]
at
org.apache.commons.dbcp2.DelegatingStatement.execute(DelegatingStatement.java:291)[commons-dbcp2-2.1.jar:2.1]
at
org.apache.commons.dbcp2.DelegatingStatement.execute(DelegatingStatement.java:291)[commons-dbcp2-2.1.jar:2.1]
at
org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter.doCreateTables(DefaultJDBCAdapter.java:111)[activemq-jdbc-store-5.12.0.jar:5.12.0]
at
org.apache.activemq.store.jdbc.JDBCPersistenceAdapter.init(JDBCPersistenceAdapter.java:303)[activemq-jdbc-store-5.12.0.jar:5.12.0]
at
org.apache.activemq.broker.LockableServiceSupport.preStart(LockableServiceSupport.java:89)[activemq-broker-5.12.0.jar:5.12.0]
at
org.apache.activemq.util.ServiceSupport.start(ServiceSupport.java:54)[activemq-client-5.12.0.jar:5.12.0]
at
org.apache.activemq.broker.BrokerService.doStartPersistenceAdapter(BrokerService.java:651)[activemq-broker-5.12.0.jar:5.12.0]
at
org.apache.activemq.broker.BrokerService.startPersistenceAdapter(BrokerService.java:640)[activemq-broker-5.12.0.jar:5.12.0]
at
org.apache.activemq.broker.BrokerService.start(BrokerService.java:604)[activemq-broker-5.12.0.jar:5.12.0]
at
org.apache.activemq.console.command.StartCommand.runTask(StartCommand.java:88)[activemq-console-5.12.0.jar:5.12.0]
at
org.apache.activemq.console.command.AbstractCommand.execute(AbstractCommand.java:62)[activemq-console-5.12.0.jar:5.12.0]
at
org.apache.activemq.console.command.ShellCommand.runTask(ShellCommand.java:154)[activemq-console-5.12.0.jar:5.12.0]
at
org.apache.activemq.console.command.AbstractCommand.execute(AbstractCommand.java:62)[activemq-console-5.12.0.jar:5.12.0]
at
org.apache.activemq.console.command.ShellCommand.main(ShellCommand.java:104)[activemq-console-5.12.0.jar:5.12.0]
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native 
Method)[:1.7.0_80]
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)[:1.7.0_80]
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)[:1.7.0_80]
at java.lang.reflect.Method.invoke(Method.java:606)[:1.7.0_80]
at
org.apache.activemq.console.Main.runTaskClass(Main.java:262)[activemq.jar:5.12.0]
at
org.apache.activemq.console.Main.main(Main.java:115)[activemq.jar:5.12.0]

Thanks

Mike



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/ActiveMQ-5-12-0-and-SQL-Server-Persistence-tp4702242.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: ActiveMQ JDBC persistence with MSSql

[mtod]

Thanks for the quick reply.

Good catch that resolved the problem.

I was using the default activemq config and I guess they have not updated
the documentation.

Mike




--
View this message in context: 
http://activemq.2283324.n4.nabble.com/ActiveMQ-JDBC-persistence-with-MSSql-tp4701883p4701885.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

ActiveMQ JDBC persistence with MSSql

[mtod]

I'm trying to setup a MSSQL JDBC persistence and I keep getting the same
error.

My setup is ActiveMQ 5.12.0 on Windows 2012 R2 with JAVA 1.8

I downloaded and installed the MS Drivers.

*My ActiveMQ.xml is using the default and the only thing I added was :*










*Console Error:*

ERROR: *org.springframework.beans.factory.CannotLoadBeanClassException:
Cannot find class [org.apache.commons.dbcp.BasicDataSource]* for bean with
name 'mssql-ds' defined in class path resource [activemq.xml
]; nested exception is java.lang.ClassNotFoundException:
org.apache.commons.dbcp.BasicDataSource
org.springframework.beans.factory.CannotLoadBeanClassException: Cannot find
class [org.apache.commons.dbcp.BasicDataSource] for bean with name
'mssql-ds' defined in class path resource [activemq.xml]; nest
ed exception is java.lang.ClassNotFoundException:
org.apache.commons.dbcp.BasicDataSource


I tried placing the commons-dbcp2-2.1 into the /lib folder and no luck same
with the drivers.

Thanks

Mike



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/ActiveMQ-JDBC-persistence-with-MSSql-tp4701883.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

ActiveMQ embedded camel issue on stand by servers

[mtod]

I'm running ActiveMQ 5.12.0 in a leveldb cluster and I'm using the Camel
functionality built in to ActiveMQ.

I keep getting this error on the stand by servers.

ERROR | Could not refresh JMS Connection for destination 'esb.*' - retrying
in 5000 ms. Cause: Could not create Transport. Reason: java.io.IOException:
Broker named 'localhost' does not exist.

My route is defined in a separate file and I use an import to include in the
activemq.xml file outside of the broker.






--
View this message in context: 
http://activemq.2283324.n4.nabble.com/ActiveMQ-embedded-camel-issue-on-stand-by-servers-tp4701829.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Help with Setting up leveldb

[mtod]

I'm trying to setup ActiveMQ 5.12.0 using a 3 node leveldb cluster but I keep
getting SASL Warnings.
I can't seem to figure out whats going on.

*ActiveMQ Console:*

WARN | SASL configuration failed: javax.security.auth.login.LoginException:
No JAAS configuration section named 'Client' was found in specified JAAS
configuration file: 'C:\ActiveMQ\apache-activemq-5.12.0
bin\..\conf\login.config'. Will continue connection to Zookeeper server
without SASL authentication, if Zookeeper server allows it.

*Login.config:*

activemq-domain {
org.apache.activemq.jaas.PropertiesLoginModule required
org.apache.activemq.jaas.properties.user="users.properties"
org.apache.activemq.jaas.properties.group="groups.properties";
};

*ActiveMQ.xml :*



   



Thanks for the help
Mike



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Help-with-Setting-up-leveldb-tp4701826.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

ActiveMQ 5.11.1 missing data in the Web Console

[mtod]

I just upgraded to 5.11.1 and everything seems to work except for the Web
Console.

When I log on there is no data in the Main page "Broker" or any queues,
topics, etc.
The page is there just no data.

I checked and double checked the conf and can't seems to find anything.

Thanks

Mike



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/ActiveMQ-5-11-1-missing-data-in-the-Web-Console-tp4696819.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: ActiveMQ 5.11 Dynamic Camel Route - Message Namespaces

[mtod]

Just getting back to this.

So it's sounds like there's no resolution to this namespace issue.

Short of removing name spaces from the messages or not using this feature.

Thanks

Mike 



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/ActiveMQ-5-11-Dynamic-Camel-Route-Message-Namespaces-tp4693314p4696246.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: ActiveMQ 5.11 Dynamic Camel Route - Message Namespaces

[mtod]

Here's the response.

 INFO | Created default XPathFactory
com.sun.org.apache.xpath.internal.jaxp.XPathFactoryImpl@343985bd
 INFO | Creating new XPath expression in pool. Namespaces on XPath
expression: [me: {system ->
http://camel.apache.org/xml/variables/system-properties},{env ->
http://camel.apache.org/xml/variables/environment-variables},{in ->
http://camel.apache.org/xml/in/},{function ->
http://camel.apache.org/xml/function/},{out ->
http://camel.apache.org/xml/out/}]
 INFO | Namespaces discovered in message:
{xmlns:km=[http://xsdrepo.foundationmedicine.com/messaging/esb],
xmlns:xsi=[http://www.w3.org/2001/XMLSchema-instance],
xmlns:bm=[http://xsdrepo-dev.foundationmedicine.com/messaging/esbbamevent]}.

Mike



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/ActiveMQ-5-11-Dynamic-Camel-Route-Message-Namespaces-tp4693314p4693426.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: ActiveMQ 5.11 Dynamic Camel Route - Message Namespaces

[mtod]

Thanks for the reply

This is more to do with the current ActiveMQ update then Camel
on 5.10 this worked fine and I have had it in production for close to a
year.

My testing with 5.11 when using my exist configuration works fine but when I
try the new dynamic route update option in 5.11 that allows you to move the
Camel routes into the new routes.xml is when the errors around namespaces
and a few other configurations have issues.

I tried the XPath attributes you recommended but no luck I get the same
error.

Maybe I should have used a different subject line :)

Thanks

Mike



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/ActiveMQ-5-11-Dynamic-Camel-Route-Message-Namespaces-tp4693314p4693415.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: ActiveMQ 5.11 Dynamic Camel Route - Message Namespaces

[mtod]

Does no one have any idea of how we can use namespaces in the dynamic route
update?

Mike



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/ActiveMQ-5-11-Dynamic-Camel-Route-Message-Namespaces-tp4693314p4693409.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

ActiveMQ 5.11 Dynamic Camel Route - Message Namespaces

[mtod]

I'm trying to migrate to ActiverMQ 5.11 using the new dynamic routing option.

Using 5.10 I was able to place a name space in an external camel file such
as:

http://camel.apache.org/schema/spring";
xmlns:km="http://xsdrepo.foundationmedicine.com/messaging/esb";>




http://xsdrepo.foundationmedicine.com/messaging/esb/ESBMessageV3.xsd"/>

/km:FMIMessage/km:Header/km:Route/text()


Route1


   
org.apache.camel.ValidationException

${exception.message}







If I try doing the same in the new ActiveMQ 5.11 routes.xml it fails on the
namespace km :

*Error*

Reason: javax.xml.xpath.XPathExpressionException:
com.sun.org.apache.xpath.internal.domapi.XPathStylesheetDOM3Exception:
Prefix must resolve to a namespace: km]
org.apache.camel.builder.xml.InvalidXPathExpression: Invalid xpath:
/km:FMIMessage/km:Header/km:Route/text(). Reason:
javax.xml.xpath.XPathExpressionException:
com.sun.org.apache.xpath.internal.domapi
.XPathStylesheetDOM3Exception: Prefix must resolve to a namespace: km

*Source :*

http://camel.apache.org/schema/spring";   
xmlns:km="http://xsdrepo.foundationmedicine.com/messaging/esb";>





http://xsdrepo.foundationmedicine.com/messaging/esb/ESBMessageV3.xsd"/>

/km:FMIMessage/km:Header/km:Route/text()


Route1



org.apache.camel.ValidationException

${exception.message}







Thanks

Mike



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/ActiveMQ-5-11-Dynamic-Camel-Route-Message-Namespaces-tp4693314.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: ActiveMQ 5.11 Dynamic Camel Route updates

[mtod]

The Routes keep running under User anonymous.

*I have tried both :*












*And*












*AuthorizationPlugin config:*



















  









*But I keep getting this error:*

2015-03-15 08:08:08,826 | WARN  | Failed to add Connection
ID:FM-WLTP082-18846-1426432083439-6:1 |
org.apache.activemq.broker.TransportConnection | ActiveMQ Transport:
tcp:///127.0.0.1:18868@61616
java.lang.SecurityException: User anonymous is not authorized to create:
topic://ActiveMQ.Advisory.Connection
at
org.apache.activemq.security.AuthorizationBroker.addDestination(AuthorizationBroker.java:115)[activemq-broker-5.11.0.jar:5.11.0]
at
org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:172)[activemq-broker-5.11.0.jar:5.11.0]
at
org.apache.activemq.broker.MutableBrokerFilter.addDestination(MutableBrokerFilter.java:177)[activemq-broker-5.11.0.jar:5.11.0]
at
org.apache.activemq.broker.MutableBrokerFilter.addDestination(MutableBrokerFilter.java:177)[activemq-broker-5.11.0.jar:5.11.0]
at
org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:462)[activemq-broker-5.11.0.jar:5.11.0]
at
org.apache.activemq.broker.jmx.ManagedRegionBroker.send(ManagedRegionBroker.java:297)[activemq-broker-5.11.0.jar:5.11.0]
at
org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:152)[activemq-broker-5.11.0.jar:5.11.0]
at
org.apache.activemq.broker.scheduler.SchedulerBroker.send(SchedulerBroker.java:169)[activemq-broker-5.11.0.jar:5.11.0]
at
org.apache.activemq.advisory.AdvisoryBroker.fireAdvisory(AdvisoryBroker.java:633)[activemq-broker-5.11.0.jar:5.11.0]
at
org.apache.activemq.advisory.AdvisoryBroker.fireAdvisory(AdvisoryBroker.java:564)[activemq-broker-5.11.0.jar:5.11.0]
at
org.apache.activemq.advisory.AdvisoryBroker.fireAdvisory(AdvisoryBroker.java:559)[activemq-broker-5.11.0.jar:5.11.0]
at
org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBroker.java:98)[activemq-broker-5.11.0.jar:5.11.0]
at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:97)[activemq-broker-5.11.0.jar:5.11.0]
at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:97)[activemq-broker-5.11.0.jar:5.11.0]
at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:97)[activemq-broker-5.11.0.jar:5.11.0]
at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:97)[activemq-broker-5.11.0.jar:5.11.0]
at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:97)[activemq-broker-5.11.0.jar:5.11.0]
at
org.apache.activemq.plugin.RuntimeConfigurationBroker.addConnection(RuntimeConfigurationBroker.java:178)[activemq-runtime-config-5.11.0.jar:5.11.0]
at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:97)[activemq-broker-5.11.0.jar:5.11.0]
at
org.apache.activemq.security.SimpleAuthenticationBroker.addConnection(SimpleAuthenticationBroker.java:103)[activemq-broker-5.11.0.jar:5.11.0]
at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:97)[activemq-broker-5.11.0.jar:5.11.0]
at
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:97)[activemq-broker-5.11.0.jar:5.11.0]
at
org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableBrokerFilter.java:102)[activemq-broker-5.11.0.jar:5.11.0]
at
org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableBrokerFilter.java:102)[activemq-broker-5.11.0.jar:5.11.0]
at

Re: ActiveMQ 5.11 Dynamic Camel Route updates

[mtod]

I was able to get this working except for authorization.

Thanks



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/ActiveMQ-5-11-Dynamic-Camel-Route-updates-tp4693120p4693136.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: ActiveMQ 5.11 Dynamic Camel Route updates

[mtod]

Thanks for the reply

I have the basic functionality working but I'm finding that I can't place
any beans in the route.xml and get it to work.

My existing route file is listed below.

I'm trying to duplicate that in the routes.xml and it just throws errors.
I have tried moving the beans to the activemq.xml no luck.

I cleaned it up by removing the camelcontext and replacing it with 
etc but no luck.

My example:

http://www.springframework.org/schema/beans";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
  http://camel.apache.org/schema/spring
http://camel.apache.org/schema/spring/camel-spring.xsd
  http://activemq.apache.org/schema/core
http://activemq.apache.org/schema/core/activemq-core.xsd";>




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


























http://camel.apache.org/schema/spring";
xmlns:km="http://xsdrepo.foundationmedicine.com/messaging/esb";>









http://xsd.x.com/messaging/esb/ESBMessageV3.xsd"/>

/km:FMIMessage/km:Header/km:Route/text()


Route1


   
org.apache.camel.ValidationException

${exception.message}







 



//*[local-name()='EventTime']/text()


//*[local-name()='LevelID']/text()


//*[local-name()='PRI']/text()


//*[local-name()='ServerName']/text()


//*[local-name()='ApplicationName']/text()


//*[local-name()='Logger']/text()


//*[local-name()='UniqueID']/text()


//*[local-name()='MessageText']/text()


//*[local-name()='Exception']/text()


//*[local-name()='Payload']/text()


//*[local-name()='ActionID']/text()


//*[local-name()='MemberName']/text()


//*[local-name()='DebugLineNumber']/text()


//*[local-name()='DebugFilePath']/text()




<${header.PRI}>1 ${header.DateValue}
${header.Hostname} ${header.ApplicationName} ${header.Logger}
${header.UniqueID} ${header.Message}







   
org.apache.camel.ValidationException

${exception.message}









Thanks 

Mike



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/ActiveMQ-5-11-Dynamic-Camel-Route-updates-tp4693120p4693129.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

ActiveMQ 5.11 Dynamic Camel Route updates

[mtod]

Does anyone have an example of how to configure Activemq.xml to use dynamic
route updates?

https://issues.apache.org/jira/browse/AMQ-5351
  
I can't seem to find any information on this update.

Thanks

Mike




--
View this message in context: 
http://activemq.2283324.n4.nabble.com/ActiveMQ-5-11-Dynamic-Camel-Route-updates-tp4693120.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

ActiveMQ Camel with Shiro Security

[mtod]

Are there any examples of setting up Shiro in XML supporting Camel Routes?

I have a Camel route that monitors a queue and sends the messages to a topic
based on xml content.

I keep getting the following error:

org.apache.shiro.authc.AuthenticationException: Unable to obtain
authentication credentials for newly established connection.  Authentication
is required.

Thanks

Mike



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/ActiveMQ-Camel-with-Shiro-Security-tp4683050.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

ActiveMQ 5.9.1 REST selector operation.

[mtod]

I'm trying to use the REST API to GET a response from a queue.

I set my url to :
http://appdev003:8161/api/message/xml2test.replyto.queue?type=queue&clientId=XML2Test&readTimeout=1000

I added a header for selector:
JMSCorrelationID='9595bb66-6fb7-4f6f-8bd5-ff86721f35f7'

I checked the message and the Correlation Id is set to the Guid above.

What I received back is not the filtered message I get what ever is on the
queue.

Details on the request:
Method  GET String  0   32  
Uri 
/api/message/xml2test.replyto.queue?type=queue&clientId=XML2Test&readTimeout=1000
   
Headers
map{Authorization=BasicYWRtaW46YWRtaW4=,Host=appdev003:8161,selector=JMSCorrelationID='5baaf583-7598-45cb-8620-2c030ae8d83c'}

I'm not sure what I'm doing wrong or if this feature works.

Thanks

Mike







--
View this message in context: 
http://activemq.2283324.n4.nabble.com/ActiveMQ-5-9-1-REST-selector-operation-tp4682822.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.