from:"abhijith"

Hi,

I am trying out artemis and creating different JMS queues from client
programatically.  Code itself works, but when I log into JMX, I see that few
queues are listed under "Core/Queue" with jms.queue.# prefix, but they don't
appear under "JMS/Queue".  I don't understand how this could happen.  

Attaching the image showing the same.  Any insight into why this could
happen, would be helpful.  Thanks.


 



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-JMX-not-showing-queues-tp4711375.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Artemis create topic programatically

Hi,

I am trying to create topic programatically.  Please find below my code

@Test
   public void testCreateTopic() throws Exception {
ConnectionFactory cf =
ActiveMQJMSClient.createConnectionFactoryWithHA(JMSFactoryType.CF, server1,
server2);
Connection conn = cf.createConnection();

Session session = conn.createSession(false,
Session.AUTO_ACKNOWLEDGE);

Topic topic = session.createTopic("TestTopic");

String topicName = topic.getTopicName();

   
assertFalse(topicName.startsWith(ActiveMQDestination.JMS_TOPIC_ADDRESS_PREFIX));

Topic replyTopic = session.createTopic(topicName);

MessageConsumer consumer = session.createConsumer(replyTopic);

conn.start();

MessageProducer producer = session.createProducer(replyTopic);

producer.send(session.createMessage());

assertNotNull(consumer.receive(1));
}

I also have the right permissions 










But I keep getting the error 

"javax.jms.JMSException: There is no topic with name TestTopic".  Similar
code works for queues.  Please let me know if I am doing something wrong.

Thanks
Abhi





--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-create-topic-programatically-tp4711388.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Artemis JMX not showing queues

First I am creating a connection factory using 

ActiveMQConnectionFactory cf =
ActiveMQJMSClient.createConnectionFactoryWithHA(JMSFactoryType.CF, server1,
server2);

Then I am creating client representation of queue

Queue queue = ActiveMQJMSClient.createQueue("x");

after that 

Connection cf = cf.createConnection();
Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
TextMessage message = session.createTextMessage(messageToSend);
MessageProducer producer = session.createProducer(queue);
producer.send(message);

I think queue got created because address-settings has 
true by default.

Please let me know if you need any further info

Thanks
Abhi




--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-JMX-not-showing-queues-tp4711375p4711387.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Artemis failover on initial connection

2016-05-11 Thread abhijith

Hi,

I have a HA cluster with one master and one slave.  I am creating connection
factory with below settings.

HashMap map = new HashMap();
map.put("host", "artemis01-mydev");
map.put("port", "61616");
map.put(TransportConstants.SSL_ENABLED_PROP_NAME, true);
TransportConfiguration server1 = new
TransportConfiguration(NettyConnectorFactory.class.getName(), map);
HashMap map2 = new HashMap();
map2.put("host", "artemis02-mydev");
map2.put("port", "61616");
map.put(TransportConstants.SSL_ENABLED_PROP_NAME, true);
TransportConfiguration server2 = new
TransportConfiguration(NettyConnectorFactory.class.getName(), map2);

ActiveMQConnectionFactory cf =
ActiveMQJMSClient.createConnectionFactoryWithHA(JMSFactoryType.CF, server1,
server2);
cf.setRetryInterval(1000);
cf.setReconnectAttempts(1);
cf.setRetryIntervalMultiplier(1.0);
cf.setInitialConnectAttempts(1);
cf.setFailoverOnInitialConnection(true);

 cf.setCallTimeout(2000);

Problem is connection factory is trying to receive cluster topology from
slave which is 'artemis02-dev' and errors out.  Its not falling back to
master to receive the topology.  It works fine if it connects to master
first time itself. 

I thought by setting setFailoverOnInitialConnection() will do that.  I am
not able to figure out how to solve this.  Any help is greatly appreciated.

Thanks
Abhi



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-failover-on-initial-connection-tp4711844.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Artemis - Duplicate message detected - message will not be routed.

2016-05-13 Thread abhijith

Hi,

I am trying to run transaction failover test which is present below on my
local server cluster 

https://github.com/apache/activemq-artemis/blob/master/examples/features/ha/transaction-failover/src/main/java/org/apache/activemq/artemis/jms/example/TransactionFailoverExample.java

As I read the documentation I do not have to do anything in broker.xml.  But
I am getting an error when it tries to commit second time on the backup.  Am
I missing any configuration here?


Exception in thread "main" javax.jms.JMSException: Duplicate message
detected - message will not be routed. Message
information:ServerMessage[messageID=64,durable=true,userID=c17404b9-188d-11e6-a620-2e54f7ea8757,priority=4,
bodySize=281, timestamp=Thu May 12 18:06:19 EDT 2016,expiration=0,
durable=true,
address=jms.queue.exampleQueue,properties=TypedProperties[_AMQ_DUPL_ID=14630907630599,__AMQ_CID=bdcf1883-188d-11e6-a620-2e54f7ea8757]]@1256539883
at
org.apache.activemq.artemis.core.protocol.core.impl.ChannelImpl.sendBlocking(ChannelImpl.java:376)
at
org.apache.activemq.artemis.core.protocol.core.impl.ActiveMQSessionContext.simpleCommit(ActiveMQSessionContext.java:301)
at
org.apache.activemq.artemis.core.client.impl.ClientSessionImpl.commit(ClientSessionImpl.java:509)
at
org.apache.activemq.artemis.core.client.impl.DelegatingSession.commit(DelegatingSession.java:161)
at
org.apache.activemq.artemis.jms.client.ActiveMQSession.commit(ActiveMQSession.java:213)
at TransactionFailoverExample.main(TransactionFailoverExample.java:114)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at com.intellij.rt.execution.application.AppMain.main(AppMain.java:144)

Thanks
Abhi




--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-Duplicate-message-detected-message-will-not-be-routed-tp4711878.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

[Artemis] Issue with static connectors

2016-05-13 Thread abhijith

Hi,

We have a setup Artemis broker sits behind SSL offloading hardware.

client ---TLS---> VIP(ssl-offload) ---TCP--> Artemis broker

We have a HA setup with one master and one broker. I have followed the
examples and add two TransportConfigurations one for each.
ActiveMQConnectionFactory connectionFactory =
ActiveMQJMSClient.createConnectionFactoryWithHA(
JMSFactoryType.CF, masterConfig, slaveConfig);

Since Artemis client uses by default RoundRobinConnectionLoadBalancingPolicy
to pick initial connector and first one is random sometimes its picking
slaveConfig to connect. Because we have VIP in front, connection itself is
successful all the time even though broker behind it might be down.

Naturally connector gets an error while trying to download clusterTopology.
When this happens, instead of trying other available connector Artemis
client errors out. I think this is wrong behavior. It should try out all
available connectors before erroring out. Please let me know if I am
missing something here or any comments or thoughts are welcome.

Exception in thread "main" javax.jms.JMSRuntimeException: Failed to create
session factory
at
org.apache.activemq.artemis.jms.client.JmsExceptionUtils.convertToRuntimeException(JmsExceptionUtils.java:88)
at
org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory.createContext(ActiveMQConnectionFactory.java:267)
at
org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory.createContext(ActiveMQConnectionFactory.java:253)
at
org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory.createContext(ActiveMQConnectionFactory.java:243)
at com.abhiz.artemis.QueueExample.main(QueueExample.java:47)
Caused by: javax.jms.JMSException: Failed to create session factory
at
org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory.createConnectionInternal(ActiveMQConnectionFactory.java:735)
at
org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory.createContext(ActiveMQConnectionFactory.java:260)
... 3 more
Caused by: ActiveMQConnectionTimedOutException[errorType=CONNECTION_TIMEDOUT
message=AMQ119013: Timed out waiting to receive cluster topology.
Group:null]
at
org.apache.activemq.artemis.core.client.impl.ServerLocatorImpl.createSessionFactory(ServerLocatorImpl.java:828)
at
org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory.createConnectionInternal(ActiveMQConnectionFactory.java:732)
... 4 more

--
View this message in context:
http://activemq.2283324.n4.nabble.com/Artemis-Issue-with-static-connectors-tp4711907.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Artemis slave goes down after master comes back up

Hi,

I am seeing a behavior in Artemis HA which I can't really explain why. 

I ran the example successfully provided here: 
https://github.com/apache/activemq-artemis/tree/master/examples/features/ha/replicated-failback-static
 

Then bought up both master and slave manually which are present under
target/server0 and target/server1 folder respectively.  Both of them came up
successfully and I was able to send/receive messages

I bought server0(master) down and server1(slave) took over servicing as
expected.  Then I got server0(master) back up which made server1(slave) shut
down after syncing information to server0(master).

I am not sure if this is expected behavior.  I was expecting slave back to
slave mode rather than shut itself down. Is there anyway this behavior can
be changed?

Thanks
Abhi



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-slave-goes-down-after-master-comes-back-up-tp4711403.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

[Artemis] Error message in log file for cluster on v1.3

2016-07-02 Thread abhijith

Hi,

We have a master/slave configuration with static connectors. This was
working fine till we upgraded to v1.3 yesterday.

With 1.3 we are constantly seeing below ERROR message being logged.

21:12:59,991 ERROR [org.apache.activemq.artemis.core.client] AMQ214016:
Failed to create netty connection: java.nio.channels.ClosedChannelException

With the frequency of the log, I thought it might be the slave connection.
But slave itself declares as backup, so I am pretty sure master/slave setup
is fine.

19:48:23,936 ERROR [org.apache.activemq.artemis.core.client] AMQ214016:
Failed to create netty connection: java.nio.channels.ClosedChannelException
19:48:26,004 ERROR [org.apache.activemq.artemis.core.client] AMQ214016:
Failed to create netty connection: java.nio.channels.ClosedChannelException
19:48:28,054 ERROR [org.apache.activemq.artemis.core.client] AMQ214016:
Failed to create netty connection: java.nio.channels.ClosedChannelException

19:48:30,168 INFO [org.apache.activemq.artemis.core.server] AMQ221109:
Apache ActiveMQ Artemis Backup Server version 1.3.0 [null] started, waiting
live to fail before it gets active
19:48:31,316 INFO [org.apache.activemq.artemis.core.server] AMQ221024:
Backup server
ActiveMQServerImpl::serverUUID=1a465752-3ca0-11e6-bc64-020820d3a150 is
synchronized with live-server.
19:48:31,410 INFO [org.apache.activemq.artemis.core.server] AMQ221031:
backup announced

It does not give any other error message. So kind of lost on why this is
happening. Messages itself flow through fine.

Thanks
Abhi

--
View this message in context:
http://activemq.2283324.n4.nabble.com/Artemis-Error-message-in-log-file-for-cluster-on-v1-3-tp4713397.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Artems: ParallelGC vs CMS

2017-02-08 Thread abhijith

Yes, we tested with G1 settings in load test environment. Old gen was still
increasing with it albeit a bit slower than parallel GC, so we never moved
ahead with it.



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artems-ParallelGC-vs-CMS-tp4721722p4721737.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Artems: ParallelGC vs CMS

2017-02-07 Thread abhijith

Hi,

Has there any test done for Artemis using CMS GC?

Context: We were using default parallel GC with 6G RAM and were facing an
issue where old gen was filling up without full GC being run. We use Netty
Transport configuration and have one master/slave setup with static
configuration. Our monitoring alerts for total memory usage were firing.
So we ran some tests and found that old gen was growing very slowly in case
of CMS, but very rapidly in case of parallel GC.

We switched to using CMS, but after changing to CMS we started seeing
connection errors when session factory is trying to create a new connection.
This was happening consistently which forced us to roll back. After
rollback with parallel gc we do not see this issue at all. We are kind of
confused on how selection of GC can affect creating new connections. Any
insight would be really helpful.

GG parameters: "-XX:+UseFastAccessorMethods -Xms8G -Xmx8G
-XX:+UseConcMarkSweepGC -XX:+CMSIncrementalMode
-XX:CMSIncrementalDutyCycleMin=10 -XX:CMSIncrementalDutyCycle=20
-XX:+CMSIncrementalPacing -XX:+CMSClassUnloadingEnabled "

Caused by:
org.apache.activemq.artemis.api.core.ActiveMQIllegalStateException:
AMQ119024: Could not select a TransportConfiguration to create
SessionFactory
at
org.apache.activemq.artemis.core.client.impl.ServerLocatorImpl.createSessionFactory(ServerLocatorImpl.java:773)
~[artemis-core-client-1.4.0.jar:1.4.0]
at
org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory.createConnectionInternal(ActiveMQConnectionFactory.java:756)
~[artemis-jms-client-1.4.0.jar:1.4.0]
... 122 common frames omitted

Thanks
Abhi

--
View this message in context:
http://activemq.2283324.n4.nabble.com/Artems-ParallelGC-vs-CMS-tp4721722.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: [Artemis] Error message in log file for cluster on v1.3

2016-09-15 Thread abhijith

We are still facing this issue.  Anyone know why this is happening?



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-Error-message-in-log-file-for-cluster-on-v1-3-tp4713397p4716576.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

[Artemis] Messages stuck in "Delivering" state infinitely

2016-09-16 Thread abhijith

Hi,

We found that few messages were not getting delivered by Artemis.  When we
ran count-messages using JMX it was returning correct number of messages on
queue.  But listMessages was returning empty.  

Then listDeliveringMessages showed all the messages.  But messages were
stuck in this state infinitely.  Had to restart Artemis to get messages back
on to the queue.  


Is there any way to move messages which are stuck out of delivering state? 
I could not find any JMX operation for this.

Thanks
Abhi



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-Messages-stuck-in-Delivering-state-infinitely-tp4716589.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: [Artemis] Messages stuck in "Delivering" state infinitely

2016-09-16 Thread abhijith

Yes, we did see few dangling connections and I got the connection id's for
the same.  Right now there is no JMX operation to close single connection
based on connectionId.  The only way I could do this was to close all
existing connections for the given user.



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-Messages-stuck-in-Delivering-state-infinitely-tp4716589p4716596.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: [Artemis] Browse scheduled and delivering messages

2016-10-18 Thread abhijith

Thanks, our requirement is not really performance intensive.  It's only done
on critical issues which needs immediate support.  

On another note, what is the best way to read messages with body? 
listMessages() operation does not retrieve body contents.

~Abhi



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-Browse-scheduled-and-delivering-messages-tp4717972p4718023.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: [Artemis] Browse scheduled and delivering messages

2016-10-18 Thread abhijith

I am assuming you are referring to JMSBrowser.  

We have locked down Queues and Topics with authentication and authorization. 
We would have to create a management role just for browsing which I am
trying to avoid.  Also, this user would be super user who could essentially
read from everywhere.



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-Browse-scheduled-and-delivering-messages-tp4717972p4718043.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

[Artemis] Browse scheduled and delivering messages

2016-10-17 Thread abhijith

Hi,

We are trying to monitor Artemis queues for support purpose and one of our
requirement is to be able to look at messages body.  

I found that I can view body of the message using browse() operation which
is exposed via JMX.  But browse only accounts for messages which are not in
scheduled or delivering state.  

Is there any JMX operation to browse through scheduled and delivering state
messages as well?

Thanks
Abhi




--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-Browse-scheduled-and-delivering-messages-tp4717972.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

[Artemis] Split broker.xml

2017-01-09 Thread abhijith

Hi,

Is there anyway to split broker.xml file into smaller configuration?  Our
list of JMS objects are growing and broker.xml is getting bigger and bigger.  
We would like to have small set of files, preferably one xml file for each
JMS object.  

Can I include multiple server configuration(s) in bootstrap.xml?  I can also
try XML
imports(https://stackoverflow.com/questions/5121052/can-we-import-xml-file-into-another-xml-file),
but wanted to check if there is any better way here first.

Thanks
Abhi



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-Split-broker-xml-tp4720894.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

[Artemis] WebConsole (Hawt.io artemis plugin)

2016-12-23 Thread abhijith

Hi,

I know there was a big discussion about adding webconsole to Artemis. I am
not sure if any conclusion was reached on that. It is a huge benefit for
our production support. So, would very much like to see that feature
getting added in future releases.

For now I was trying to play around with hawt.io to check if we can put a UI
in front of Artemis JMX. Stumbled upon
https://github.com/rh-messaging/artemis-hawtio which quipped my interest.

Had few questions regarding the same.

1. Is the above plugin open sourced? I did not see any license information
on the same.
2. Do I need to do anything extra to enable Jolokia in Artemis? I have the
standard bootstrap.xml which defines Jolokia and when artemis boots up I do
see the message that "01:55:57,801 INFO [org.apache.activemq.artemis]
AMQ241002: Artemis Jolokia REST API available at
http://localhost:8161/jolokia;. But When I access
"http://localhost:8161/jolokia/read/org.apache.activemq.artemis:module=Core,type=Server/Version;
I get 404.
3. Not able to get the above plugin working even after following
instructions. Raised an issue on the github repo but no response
yet(https://github.com/rh-messaging/artemis-hawtio/issues/27). Not sure if
this is the right forum to even ask for help on this one.

Any help regarding the same is much needed. Thanks in advance.

--
View this message in context:
http://activemq.2283324.n4.nabble.com/Artemis-WebConsole-Hawt-io-artemis-plugin-tp4720702.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Artemis 1.x support model

2017-03-22 Thread abhijith

Congrats everyone on successful release. 

We are using Artemis v1.4 today and would like to know support model for 1.x
version after major version update.  Is there any plan to deprecate 1.x
version in near future and not accept any more bug submission? 

We are trying to determine when to upgrade to 2.x and knowing the
deprecation timeline would help us making this decision.

Thanks

Abhi



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-1-x-support-model-tp4723981.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: [Artemis] [Bug] Consume from non-durable jms topic

2017-04-06 Thread abhijith

Good to know.  Thanks.  Appreciate the help



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-Bug-Consume-from-non-durable-jms-topic-tp4724597p4724667.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

[Artemis] [Bug] Consume from non-durable jms topic

2017-04-05 Thread abhijith

Hi,

We are using Artemis 1.4.0 version and have a jms topic defined.  We have
defined two specific roles for all topics, one to send and another to
consume

artemis-roles.properties:
sendtopic=testtopicuser
consumetopic=testtopicuser

broker.xml:
 
 
 
 
 

When I try to send to this topic, it works fine.  But when I try to consume
from this topic it fails giving below error.  If I add  permission, it works
fine.  Is this a bug in Artemis or am I missing something?  Any help is
greatly appreciated.

javax.jms.JMSSecurityException: AMQ119032: User: testtopicuser does not have
permission='CREATE_NON_DURABLE_QUEUE' on address jms.topic.exampleTopic

at
org.apache.activemq.artemis.core.protocol.core.impl.ChannelImpl.sendBlocking(ChannelImpl.java:409)
at
org.apache.activemq.artemis.core.protocol.core.impl.ChannelImpl.sendBlocking(ChannelImpl.java:307)
at
org.apache.activemq.artemis.core.protocol.core.impl.ActiveMQSessionContext.createQueue(ActiveMQSessionContext.java:590)
at
org.apache.activemq.artemis.core.client.impl.ClientSessionImpl.internalCreateQueue(ClientSessionImpl.java:1620)
at
org.apache.activemq.artemis.core.client.impl.ClientSessionImpl.createTemporaryQueue(ClientSessionImpl.java:314)
at
org.apache.activemq.artemis.jms.client.ActiveMQSession.createConsumer(ActiveMQSession.java:690)
at
org.apache.activemq.artemis.jms.client.ActiveMQSession.createConsumer(ActiveMQSession.java:353)
at
org.apache.activemq.artemis.jms.client.ActiveMQSession.createConsumer(ActiveMQSession.java:325)
at
BasicSendReceiveTopicISTest.testBasicSendReceiveForStringMessage(BasicSendReceiveTopicISTest.java:59)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:85)
at org.testng.internal.Invoker.invokeMethod(Invoker.java:639)
at org.testng.internal.Invoker.invokeTestMethod(Invoker.java:816)
at org.testng.internal.Invoker.invokeTestMethods(Invoker.java:1124)
at
org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:125)
at org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:108)
at org.testng.TestRunner.privateRun(TestRunner.java:774)
at org.testng.TestRunner.run(TestRunner.java:624)
at org.testng.SuiteRunner.runTest(SuiteRunner.java:359)
at org.testng.SuiteRunner.runSequentially(SuiteRunner.java:354)
at org.testng.SuiteRunner.privateRun(SuiteRunner.java:312)
at org.testng.SuiteRunner.run(SuiteRunner.java:261)
at org.testng.SuiteRunnerWorker.runSuite(SuiteRunnerWorker.java:52)
at org.testng.SuiteRunnerWorker.run(SuiteRunnerWorker.java:86)
at org.testng.TestNG.runSuitesSequentially(TestNG.java:1215)
at org.testng.TestNG.runSuitesLocally(TestNG.java:1140)
at org.testng.TestNG.run(TestNG.java:1048)
at org.testng.IDEARemoteTestNG.run(IDEARemoteTestNG.java:72)
at org.testng.RemoteTestNGStarter.main(RemoteTestNGStarter.java:127)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at com.intellij.rt.execution.application.AppMain.main(AppMain.java:147)
Caused by: ActiveMQSecurityException[errorType=SECURITY_EXCEPTION
message=AMQ119032: User: testtopicuser does not have
permission='CREATE_NON_DURABLE_QUEUE' on address jms.topic.exampleTopic]
... 37 more





--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-Bug-Consume-from-non-durable-jms-topic-tp4724597.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: [Artemis] [Bug] Consume from non-durable jms topic

2017-04-05 Thread abhijith

Thanks for the reply and thats interesting.  Does this mean, in order to
listen to a topic you would always need 2 roles?  createNonDurableQueue and
consume?

Trying to understand difference with Queue.  We don't need to have
createDurableQueue role to consume from a queue..right?



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-Bug-Consume-from-non-durable-jms-topic-tp4724597p4724599.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: [Artemis] [Bug] Consume from non-durable jms topic

2017-04-07 Thread abhijith

Looking to move to 2.0 directly.  Are there any pitfalls which we need to be
aware of?  Hoping 1.4 JMS client is fully compatible with 2.0 broker.



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-Bug-Consume-from-non-durable-jms-topic-tp4724597p4724745.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: [Artemis] Error message in log file for cluster on v1.3

2017-07-17 Thread abhijith

Resurrecting this thread as we are still facing this issue in v2.1.  Any
suggestions on how to take it out?  There is no issue is performance or
message delivery except filling up of logs.  Its very annoying and makes
debugging almost impossible.



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-Error-message-in-log-file-for-cluster-on-v1-3-tp4713397p4728605.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: [Artemis] Error message in log file for cluster on v1.3

2017-07-17 Thread abhijith

Yep will do that.  Will it be fine If I give a docker compose file based on
https://github.com/vromero/activemq-artemis-docker?

I need to bring up couple of nginx load balancers with ssl offloading as
well.  I will set it up with self signed certs




--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-Error-message-in-log-file-for-cluster-on-v1-3-tp4713397p4728611.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: [Artemis] Error message in log file for cluster on v1.3

2017-07-17 Thread abhijith

I can check if by directly setting SSL example with static connectors.  This
error message is appearing only when cluster is setup with TLS.



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-Error-message-in-log-file-for-cluster-on-v1-3-tp4713397p4728619.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Artemis v2.1 Spring MessageListener Netty StackOverflow

2017-07-06 Thread abhijith

https://github.com/netty/netty/issues/6931 



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-v2-1-Spring-MessageListener-Netty-StackOverflow-tp4728139p4728291.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Artemis v2.1 Spring MessageListener Netty StackOverflow

We have a load balancer in front on Artemis which does ssl offloading.  To
handle this we have custom ConnectionLoadBalancingPolicy.  This policy
determines which transport configuration to use for initial connection



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-v2-1-Spring-MessageListener-Netty-StackOverflow-tp4728139p4728141.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Artemis v2.1 Spring MessageListener Netty StackOverflow

Please find above stacktrace.  I will try to get test case for this, but it
is not repeatable on my Mac.  I can get this only on Solaris.  Will see if I
can repeat it consistently.



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-v2-1-Spring-MessageListener-Netty-StackOverflow-tp4728139p4728146.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Artemis v2.1 Spring MessageListener Netty StackOverflow

Hi all,

We are facing a weird issue while using Spring
DefaultMessageListenerContainer with Artemis v2.1 client. 

We have below piece of code on our custom policy which is run on a Solaris
box.
try (ServerLocatorImpl serverLocator = new ServerLocatorImpl(false,
transportConfiguration)) {
serverLocator.setCallTimeout(3000);
serverLocator.createSessionFactory();
} 

The same piece of code was working on Artemis 1.4.  But with 2.1, netty is
giving a stack overflow error.  Not sure why this is happening.  I know
netty library was updated.  I tried to use netty-all:4.1.12-final to see if
the issue is resolved with no success.  Can I just revert back to previous
netty version?  any help is really appretiated.

Caused by: java.lang.StackOverflowError
at java.util.zip.ZipCoder.getBytes(ZipCoder.java:86)
at java.util.zip.ZipFile.getInputStream(ZipFile.java:355)
at java.util.jar.JarFile.getInputStream(JarFile.java:447)
at
sun.misc.URLClassPath$JarLoader$2.getInputStream(URLClassPath.java:977)
at sun.misc.Resource.cachedInputStream(Resource.java:77)
at sun.misc.Resource.getByteBuffer(Resource.java:160)
at java.net.URLClassLoader.defineClass(URLClassLoader.java:454)
at java.net.URLClassLoader.access$100(URLClassLoader.java:73)
at java.net.URLClassLoader$1.run(URLClassLoader.java:368)
at java.net.URLClassLoader$1.run(URLClassLoader.java:362)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:361)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
at java.lang.ClassLoader.defineClass1(Native Method)
at java.lang.ClassLoader.defineClass(ClassLoader.java:763)
at
java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142)
at java.net.URLClassLoader.defineClass(URLClassLoader.java:467)
at java.net.URLClassLoader.access$100(URLClassLoader.java:73)
at java.net.URLClassLoader$1.run(URLClassLoader.java:368)
at java.net.URLClassLoader$1.run(URLClassLoader.java:362)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:361)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
at java.lang.ClassLoader.defineClass1(Native Method)
at java.lang.ClassLoader.defineClass(ClassLoader.java:763)
at
java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142)
at java.net.URLClassLoader.defineClass(URLClassLoader.java:467)
at java.net.URLClassLoader.access$100(URLClassLoader.java:73)
at java.net.URLClassLoader$1.run(URLClassLoader.java:368)
at java.net.URLClassLoader$1.run(URLClassLoader.java:362)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:361)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
at java.lang.ClassLoader.defineClass1(Native Method)
at java.lang.ClassLoader.defineClass(ClassLoader.java:763)
at
java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142)
at java.net.URLClassLoader.defineClass(URLClassLoader.java:467)
at java.net.URLClassLoader.access$100(URLClassLoader.java:73)
at java.net.URLClassLoader$1.run(URLClassLoader.java:368)
at java.net.URLClassLoader$1.run(URLClassLoader.java:362)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:361)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
at java.lang.ClassLoader.defineClass1(Native Method)
at java.lang.ClassLoader.defineClass(ClassLoader.java:763)
at
java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142)
at java.net.URLClassLoader.defineClass(URLClassLoader.java:467)
at java.net.URLClassLoader.access$100(URLClassLoader.java:73)
at java.net.URLClassLoader$1.run(URLClassLoader.java:368)
at java.net.URLClassLoader$1.run(URLClassLoader.java:362)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:361)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at

Re: Artemis v2.1 Spring MessageListener Netty StackOverflow

Exception in thread "main"
org.springframework.beans.factory.BeanCreationException: Error creating bean
with name 'messageListenerContainer' defined in c.p.c.MySpringConfiguration:
Invocation of init method failed; nested exception is
java.lang.StackOverflowError
at
org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1628)
at
org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:555)
at
org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:483)
at
org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:306)
at
org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:230)
at
org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:302)
at
org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:197)
at
org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:761)
at
org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:867)
at
org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:543)
at
c.p.c.MySpringApplicationContainer.startComponent(MySpringApplicationContainer.java:78)
at
org.picocontainer.injectors.AbstractInjectionFactory$LifecycleAdapter.start(AbstractInjectionFactory.java:84)
at
org.picocontainer.behaviors.AbstractBehavior.start(AbstractBehavior.java:169)
at
org.picocontainer.behaviors.Stored$RealComponentLifecycle.start(Stored.java:132)
at org.picocontainer.behaviors.Stored.start(Stored.java:110)
at
org.picocontainer.DefaultPicoContainer.decorateComponent(DefaultPicoContainer.java:671)
at
org.picocontainer.DefaultPicoContainer.getComponent(DefaultPicoContainer.java:657)
at
org.picocontainer.DefaultPicoContainer.getComponent(DefaultPicoContainer.java:677)
at
c.p.c.MyEngineBuilder.installApplication(MyEngineBuilder.java:442)
Caused by: java.lang.StackOverflowError
at java.util.HashMap.hash(HashMap.java:338)
at java.util.HashMap.get(HashMap.java:556)
at java.util.jar.Manifest.getAttributes(Manifest.java:126)
at java.net.URLClassLoader.isSealed(URLClassLoader.java:542)
at
java.net.URLClassLoader.getAndVerifyPackage(URLClassLoader.java:405)
at
java.net.URLClassLoader.definePackageInternal(URLClassLoader.java:419)
at java.net.URLClassLoader.defineClass(URLClassLoader.java:451)
at java.net.URLClassLoader.access$100(URLClassLoader.java:73)
at java.net.URLClassLoader$1.run(URLClassLoader.java:368)
at java.net.URLClassLoader$1.run(URLClassLoader.java:362)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:361)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
at java.lang.ClassLoader.defineClass1(Native Method)
at java.lang.ClassLoader.defineClass(ClassLoader.java:763)
at
java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142)
at java.net.URLClassLoader.defineClass(URLClassLoader.java:467)
at java.net.URLClassLoader.access$100(URLClassLoader.java:73)
at java.net.URLClassLoader$1.run(URLClassLoader.java:368)
at java.net.URLClassLoader$1.run(URLClassLoader.java:362)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:361)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
at java.lang.ClassLoader.defineClass1(Native Method)
at java.lang.ClassLoader.defineClass(ClassLoader.java:763)
at
java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142)
at java.net.URLClassLoader.defineClass(URLClassLoader.java:467)
at java.net.URLClassLoader.access$100(URLClassLoader.java:73)
at java.net.URLClassLoader$1.run(URLClassLoader.java:368)
at java.net.URLClassLoader$1.run(URLClassLoader.java:362)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:361)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)

Re: Artemis v2.1 Spring MessageListener Netty StackOverflow

Thanks Justin...appreciate your quick help on this.  Looks like v4.1.4.final
is working.  Will run some more tests and confirm next week.

It is netty issue and I will raise a bug for them. But, since Artemis is
really dependent on this, should Artemis have netty 4.1.4.final dependency
instead of 4.1.9.final??



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-v2-1-Spring-MessageListener-Netty-StackOverflow-tp4728139p4728149.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Artemis v2.1 Spring MessageListener Netty StackOverflow

https://github.com/netty/netty/issues/6931  -- Opened an issue in Netty
backlog



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-v2-1-Spring-MessageListener-Netty-StackOverflow-tp4728139p4728150.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Artemis v2.1 Spring MessageListener Netty StackOverflow

2017-07-06 Thread abhijith

To close this loop, Netty guys suggested to increase stack size(Xss) instead
of downgrading version.  Bumping stack size from 256K to 1024K worked and we
don't see the error anymore.

Thanks everyone for quick help



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-v2-1-Spring-MessageListener-Netty-StackOverflow-tp4728139p4728286.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Artemis v2.0 JDK8 dependency

Thanks for the clarification.  I will use CLI tool.

Question: Can I use anycast prefix to still have 'jms.queue' appended?  We
have built some conventions around this prefix and checking if we have
change it.  



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-v2-0-JDK8-dependency-tp4725798p4725922.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Artemis v2.0 JDK8 dependency

You have downgrade dependencies to be JDK7 compatible.  You could just
include 
http://www.mojohaus.org/extra-enforcer-rules/enforceBytecodeVersion.html and
it will flag any issues including dependencies.



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-v2-0-JDK8-dependency-tp4725798p4725910.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Artemis v2.0 JDK8 dependency

sorry, any suggestion here?



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-v2-0-JDK8-dependency-tp4725798p4725888.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Artemis v2.0 JDK8 dependency

2017-05-08 Thread abhijith

Thanks for the info.  Our broker itself is running on Jdk8, so that is not a
problem.  

Its the client I am concerned about.  We have a mixture of Jdk7 and jdk8
clients(publishers and consumers).  So, we would like to give them an option
to use either and upgrade to jdk8 at their convenient time.

We do use JAAS module to hook up our custom authentication mechanism.  We
are also using netty connectors both for cluster and also from client to
server.  We are using JMS currently and have no plans to switch to AMQP.

With these constraints, do you guys recommend to upgrade to 2.0 or it is
better to stay in 1.x?



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-v2-0-JDK8-dependency-tp4725798p4725816.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Artemis v2.0 JDK8 dependency

Thanks for the clarification.  

Since we are talking about upgrade had one more question.

Is defining JMS queues using  tag in broker.xml not valid anymore in
Artemis v2.0?  I looked at JMS examples and it has been moved to new
 model.  But I could still see bunch of references of it under
tests/integration-tests.



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-v2-0-JDK8-dependency-tp4725798p4725893.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Artemis v2.0 JDK8 dependency

Another note which is on v1.5.4.  This version also suffers from same
bytecode compatibility issues.

[INFO] --- maven-enforcer-plugin:1.4.1:enforce (enforce) @
credit-artemis-client ---
[INFO] Restricted to JDK 1.7 yet
org.apache.activemq:artemis-journal:jar:1.5.4:test contains
org/apache/activemq/artemis/core/io/AbstractSequentialFile$1.class targeted
to JDK 1.8
[INFO] Restricted to JDK 1.7 yet
org.apache.activemq:artemis-core-client:jar:1.5.4:compile contains
org/apache/activemq/artemis/api/config/ActiveMQDefaultConfiguration.class
targeted to JDK 1.8
[INFO] Restricted to JDK 1.7 yet
org.apache.activemq:artemis-jdbc-store:jar:1.5.4:test contains
org/apache/activemq/artemis/jdbc/store/drivers/AbstractJDBCDriver$1.class
targeted to JDK 1.8
[INFO] Restricted to JDK 1.7 yet
org.apache.activemq:artemis-commons:jar:1.5.4:compile contains
org/apache/activemq/artemis/api/core/ActiveMQAddressExistsException.class
targeted to JDK 1.8
[INFO] Restricted to JDK 1.7 yet
org.apache.activemq:artemis-server:jar:1.5.4:test contains
org/apache/activemq/artemis/api/core/management/MessageCounterInfo.class
targeted to JDK 1.8
[INFO] Restricted to JDK 1.7 yet
org.apache.activemq:artemis-service-extensions:jar:1.5.4:test contains
org/apache/activemq/artemis/service/extensions/ActiveMQServiceExtensionLogger.class
targeted to JDK 1.8
[INFO] Restricted to JDK 1.7 yet
org.apache.activemq:artemis-jms-server:jar:1.5.4:test contains
org/apache/activemq/artemis/jms/bridge/ActiveMQJMSBridgeLogger.class
targeted to JDK 1.8
[INFO] Restricted to JDK 1.7 yet
org.apache.activemq:artemis-native:jar:1.5.4:test contains
org/apache/activemq/artemis/jlibaio/LibaioContext$1.class targeted to JDK
1.8
[INFO] Restricted to JDK 1.7 yet
org.apache.activemq:artemis-cli:jar:1.5.4:test contains
org/apache/activemq/artemis/cli/Artemis.class targeted to JDK 1.8
[INFO] Restricted to JDK 1.7 yet
org.apache.activemq:artemis-dto:jar:1.5.4:test contains
org/apache/activemq/artemis/dto/AppDTO.class targeted to JDK 1.8
[INFO] Restricted to JDK 1.7 yet
org.apache.activemq:artemis-jms-client:jar:1.5.4:compile contains
org/apache/activemq/artemis/api/jms/ActiveMQJMSClient.class targeted to JDK
1.8
[INFO] Restricted to JDK 1.7 yet
org.apache.activemq:artemis-selector:jar:1.5.4:compile contains
org/apache/activemq/artemis/selector/filter/ArithmeticExpression$1.class
targeted to JDK 1.8

I think JDK8 dependency should be clarified in documentation.





--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Artemis-v2-0-JDK8-dependency-tp4725798p4725907.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Artemis v2.0 JDK8 dependency