ActiveMQ send multiple files via a messages ?

Hi All, We have a use case where we want to send data from producer to consumer via a queue. One data-set contains few Strings, few files and few Integers. I would like to know if it is possible to send this entire data via one message. We are aware of ObjectMessage, BlobMessage, ByteMessage but

Re: Amazon MQ

Hi All, I am planing to switch the in-house running ActiveMQ to the AWS provided one. I will keep this community informed about the experience in this and any issues around it. I will also be doing performance testing. Thanks, Anuj -- Sent from:

Re: org.apache.activemq.SERIALIZABLE_PACKAGES property affecting Map Messages

Can someone check this please. I just wanted to know which library from "org." is being used here for MAP messages as mentioned above. -- Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: org.apache.activemq.SERIALIZABLE_PACKAGES property affecting Map Messages

> Try org.apache.activemq, since that's where MapMessage lives. Nope. doesn't work with "org.apache.activemq" or "org.apache". It only works with "org" -- Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: org.apache.activemq.SERIALIZABLE_PACKAGES property affecting Map Messages

Ok. I am able to make it work by adding "org" in the serializable package property. Details: -Dorg.apache.activemq.SERIALIZABLE_PACKAGES=java,*org*,com.test,test,local" Can anyone explain what exact package I need to add to make it work as "org" is huge ? Also shouldn't these packages be taken

org.apache.activemq.SERIALIZABLE_PACKAGES property affecting Map Messages

Hi, I am using ActiveMQv5.14.5 and observing below mentioned behavior with ActiveMQ. We have a use case where python producer using stomp send json data({'P1': False, 'end_date': '20170911'}) to Java Consmer where Java Consumer expect to receive it as jms MapMessage. When I run ActiveMQ broker

Re: "allowLinkStealing" as a client configuration

> Does restarting the broker without enabling link stealing also let you work > around the problem? Unfortunately No. Restarting broker also doesn't solve the problem. Only when you restart it with link stealing resolves the issue. Thanks, Anuj -- Sent from:

Re: "allowLinkStealing" as a client configuration

Hi, This problem is non-reproducible. I have tried many times with different configuration but not able to reproduce it. Even our clients using ActiveMQ sometimes face this suddenly in prod environment where dev/qa works fine. The worst part about this issues is to fix it. This does not get

Re: "allowLinkStealing" as a client configuration

I can only see warning message in broker logs: [2017-09-16 14:15:59.540-0400] [ActiveMQ NIO Worker 3] [org.apache.activemq.broker.TransportConnection] [WARN] [TransportConnection.java:org.apache.activemq.broker.TransportConnection:processAddConnection()::858] [Failed to add Connection

Re: "allowLinkStealing" as a client configuration

Any reason why this is happening? It says connected from "NULL" ? Sounds like a bug. Thanks, Anuj -- Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: ActiveMQv5.14 ObjectMessage Issues

Sorry, my bad. Was doing testing wrong way. I have corrected it and works fine. -- Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: ActiveMQv5.14 ObjectMessage Issues

Clients are running on older version : < 5.11.1 -- Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

ActiveMQv5.14 ObjectMessage Issues

Hi, Currently ActiveMQ broker is using ActiveMQ v5.14 while clients are still running on v5.11. In the client migration process, we are facing below problem with ObjectMessages: The cases when producer is migrated to 5.14 but consumer is still using the older version(5.11) are failing and

ActiveMQv5.14 ObjectMessage Issues

Hi, Currently ActiveMQ broker is using ActiveMQ v5.14 while clients are still running on v5.11. In the client migration process, we are facing below problem with ObjectMessages: The cases when producer is migrated to 5.14 but consumer is still using the older version(5.11) are failing and

Re: Temp Store is Full - False Positive?

I can see that "tmpDataDirectory" is not respected. Is there something I am doing wrong ? Any suggestions will be helpful. -- Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: ActiveMQ: Temp Store location

ActiveMQ XML: The directory "/local/mqbroker/tmp_store" is empty. Nothing is there. [amqdev@app1a (jupiter.c) /local/mqbroker/tmp_store]$ ls -al total 0 drwxrwxr-x 2 amqdev amqdev 6 Aug 31 09:13 . drwxr-xr-x 4 amqdev amqdev 36 Aug 31 09:13 .. Yeah, I enabled debug logs but didn't find

Re: Temp Store is Full - False Positive?

Can someone check this please ? -- Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: ActiveMQ: Temp Store location

Can someone check this please ? -- Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: ActiveMQ: Temp Store location

Can someone please check this ? -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-Temp-Store-location-tp4729704p4729980.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Temp Store is Full - False Positive?

Can someone please check this ? -- View this message in context: http://activemq.2283324.n4.nabble.com/Temp-Store-is-Full-False-Positive-tp4695836p4729979.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Temp Store is Full - False Positive?

The default location is also not respected. I can see that nothing is there under "data/localhost/tmp_storage " Thanks, Anuj -- View this message in context: http://activemq.2283324.n4.nabble.com/Temp-Store-is-Full-False-Positive-tp4695836p4729882.html Sent from the ActiveMQ - User mailing

Re: Temp Store is Full - False Positive?

Thanks Tim for the explanation. "tmpDataDirectory" property is not respected. Even after specifying this I can see that plist directory is created under levelDB directory only. [amqdev@app1a (jupiter.c) /local/mqbroker/leveldb]$ ls .log dirty.index lock nodeid.txt

Re: ActiveMQ: Temp Store location

"tmpDataDirectory" property is not respected. Even after specifying this I can see that plist directory is created under levelDB directory only. [amqdev@app1a (jupiter.c) /local/mqbroker/leveldb]$ ls .log dirty.index lock nodeid.txt plist.index store-version.txt

Re: Temp Store is Full - False Positive?

I am a bit confused here. Few questions, 1. Even if we are using levelDB for persistent store, does temp store is still kahadb ? 2. What is the location of temp store, is it same as levelDB store or something else ? (Similar question I asked

Re: Temp Store is Full - False Positive?

My configuration is: When this happened the size of persistent store was ~250 MB -- View this message in context: http://activemq.2283324.n4.nabble.com/Temp-Store-is-Full-False-Positive-tp4695836p4729806.html Sent from the ActiveMQ -

ActiveMQ: Temp Store location

Hi, I am using replicated levelDB with ActiveMQv5.14. I think by default the temp store location is same as persistent store location. Is there a way(config) I can use a different location for temp store. Thanks, Anuj -- View this message in context:

Re: Temp Store is Full - False Positive?

Hi, We have also faced the same issue with ActiveMQv5.14.5 recently couple of time and as you mentioned restart doesn't fix this. When I went to hard disk the size was normal. Only way to resolve this is restarting broker by clearing the persistent store. Any idea why this happened ? And it is

Re: Switch to Artemis from ActiveMQ v5.14.4?

Regarding interoperability: As you mentioned protocol interoperability is available but still It looks like code changes are required from the client side. To be more specific : Will clients using ActiveMQ client jar be able to connect to the broker running with Artemis ? Eg: Currently clients

Re: ActiveMQ: How to retain inflight messages post consumer restart

> That sounds like the remaining inflight messages are getting acknowledged > during the process of shutting down gracefully; even though your consumer > never received them. Is that accurate? If so, that still sounds like a > bug. My durable consumer received them in client ack mode and

Re: ActiveMQ: How to retain inflight messages post consumer restart

My bad Tim. I was normally shutting down the consumer instead of kill -9 It works fine with kill -9 Thanks, Anuj -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-How-to-retain-inflight-messages-post-consumer-restart-tp4727027p4727070.html Sent from the

ActiveMQ: How to retain inflight messages post consumer restart

Hi, Using Topics with durable subscribers. I am using client acknowledgement for my durable consumer. I acknowledge the message after every nth message. Which takes care of acknowledging all the messages received before that. I am facing an issue where consumer receives some messages (

Re: ActiveMQ with PostgreSQL: Not deleting persistent messages sent to a topic

I think doSetLaskAck is working fine perfectly as I can see that the value of last ackd message is getting updated properly. I have logged a bug request https://issues.apache.org/jira/browse/AMQ-6671 for the same. Thanks, Anuj -- View this message in context:

Re: ActiveMQ with PostgreSQL: Not deleting persistent messages sent to a topic

No. There is only one durable subscriber, I have verified it. This is happening everytime, it's reproducible. More details: 1. 1 producer 1 durable subscriber. Subscriber is in auto_ack mode. 2. Producer sent 100 persistent messages to consumer 3. Consumer successfully consumed them. 4. DB

ActiveMQ with PostgreSQL: Not deleting persistent messages sent to a topic

Hi, Using ActiveMQv5.11.1 I am evaluating ActiveMQ with PostgreSQL JDBC adapter. I ran a test case where a durable subscriber was listening from a topic and a publisher is publishing persistent messages. I observed that the messages were stored in the DB (ACTIVEMQ_MSGS table) but even after

Re: ActiveMQ JDBC with journaling enabled

Yes I was talking about ActiveMQ 5.x Can you also clarify about the first point where it says that journaled JDBC store is incompatible with the JDBC master/slave. What does it exactly mean ? Link which says this:

ActiveMQ JDBC with journaling enabled

Hi, I was evaluating ActiveMQ's JDBC based persistent store with journaling enabled. Have couple of doubts: 1. I was reading https://access.redhat.com/documentation/en-US/Fuse_Message_Broker/5.4/html/Clustering_Guide/files/Failover-MasterSlave-JDBC.html which says that the journaled JDBC store

ActiveMQ master slave with data replication

Hi, I want to use ActiveMQ's master-slave topology where one broker is master and other attaches as a slave. But we don't have any shared file system for it. I know one way to do this is with replicated levelDB but since it is deprecated, I don't want to go ahead with this. Is there any way we

Re: Queue size from client side

Statistics plugin requires config changes in broker xml. I am looking for a way to get the queueSize from the client side itself without changing anything in broker. Thanks, Anuj -- View this message in context:

Re: Queue size from client side

Problem with JMX is I can't specify failover url : "service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi" I am using master slave topology and I don't know which broker is master and which is slave at any point of time, So I have to maintain the list of broker URLs and keep trying until

Queue size from client side

Hi, How to check Queue size from ActiveMQ java client ? Thanks, Anuj -- View this message in context: http://activemq.2283324.n4.nabble.com/Queue-size-from-client-side-tp4714102.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

In memory scheduler support in ActiveMQ

Hi, I am using replicated levelDB in ActiveMQv5.11.1. I have a use case of delayed message handling. I have gone through the documentation and it looks like I can't use it with leveldb (Only kahadb supports scheduler) I have also seen couple of posts about In-memory scheduler

Re: 'AllowLinkStealing' does not work for TCP transport with leveldb persistent store

Thanks Tim. It works by specifying in connection URL. Also just wanted to check if this can be enabled only for a particular topic/queue OR may be a way to specify this from client side ? Thanks, Anuj -- View this message in context:

Re: 'AllowLinkStealing' does not work for TCP transport with leveldb persistent store

Hi, Broker config is attached in last update. I have also verified same behavior by overriding addConnection() : /@Override public void addConnection(ConnectionContext context, ConnectionInfo info) throws Exception { LOG.info("Allowed link stealing is : " +

Re: 'AllowLinkStealing' does not work for TCP transport with leveldb persistent store

Broker config: Consumer code: public class ActiveMQReceiver implements MessageListener { private static final Logger LOG = LoggerFactory.getLogger(ActiveMQReceiver.class); public

'AllowLinkStealing' does not work for TCP transport with leveldb persistent store

Hi, I am using ActiveMQv5.11.1 with levelDB replication. I want to use 'allowLinkStealing' option for TCP transport. I tried but it doesn;t seems to be removing old connections and adding new one. Thanks, Anuj -- View this message in context:

Re: Proper way to stop ActiveMQ

I got it. Thanks What I did: Created my own plugin which extends BrokerPluginSupport. By this I can override start() and stop() methods. Thanks, Anuj -- View this message in context: http://activemq.2283324.n4.nabble.com/Proper-way-to-stop-ActiveMQ-tp4704801p4704882.html Sent from the

Re: Proper way to stop ActiveMQ

My requirement : I need to execute some code when I stop the broker. What is the best way to do this ? Thanks, Anuj -- View this message in context: http://activemq.2283324.n4.nabble.com/Proper-way-to-stop-ActiveMQ-tp4704801p4704802.html Sent from the ActiveMQ - User mailing list archive

Proper way to stop ActiveMQ

Hi, I am using /apache-activemq-5.11.1/bin/activemq.jar to start the ActiveMQ broker. But while stopping the broker, I am observing that BrokerService.stop() is not called. I want to know what should be the ideal way to stop the ActiveMQ broker if we are using activemq.jar from downloaded package

ActiveMQ-5.11 leveld error : "java.lang.NoClassDefFoundError: Could not initialize class org.fusesource.leveldbjni.JniDBFactory "

Hi, I am using replicated leveldb and broker was running fine. Suddenly after a restart we ran into below issue where broker was continuously throwing below exception and not able to start. org.apache.activemq.leveldb.util.Log$class#debug 112 DEBUG] - Could not load factory: org.fusesource.l

Zookeeper session times out with ActiveMQ broker

Hi, We are using replicated leveldb and frequently facing issue with the broker where it's session with zookeeper times out. And because of this master re-election happens and broker restarts. We have already patched https://issues.apache.org/jira/browse/AMQ-5082 changes in broker. I am not

Re: Durable client removal caused broker to shutdown in replicated leveldb

As we can see that before 'ArrayIndexOutOfBoundsException' we got below logs: 20150817 18:24:42.582 EDT (ActiveMQ NIO Worker 6) org.apache.activemq.leveldb.util.Log$class#debug 112 DEBUG] - on rollback, the transaction TX:ID:app1.net-38906-1439632105449-7:13:42 does not exist That's why I am

Durable client removal caused broker to shutdown in replicated leveldb

hi, I am using replicated leveldb with ActiveMQ.5.11.1. We have recently observed an issue where when client connection removal caused broker to shutdown. This is very weird. The client is a durable consumer who uses transactions and calls commit after each 10 messages. Can someone suggest what

Re: Durable client removal caused broker to shutdown in replicated leveldb

Did anyone get a chance to look at this ? -- View this message in context: http://activemq.2283324.n4.nabble.com/Durable-client-removal-caused-broker-to-shutdown-in-replicated-leveldb-tp4701209p4701232.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: An IOException was thrown while starting slave broker

Any updates here ? -- View this message in context: http://activemq.2283324.n4.nabble.com/An-IOException-was-thrown-while-starting-slave-broker-tp4700041p4700106.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

An IOException was thrown while starting slave broker

Hi, We are getting below exception when we are trying to start slave broker in replicated leveldb. Broker was able to come up and run properly. But I am not sure why this exception was thrown here: java.lang.RuntimeException: An IOException was thrown (should never happen in this method).

Re: An IOException was thrown while starting slave broker

Sometimes we get different error: java.lang.RuntimeException: org.fusesource.hawtbuf.proto.InvalidProtocolBufferException: Protocol message end-group tag did not match expected tag. at org.apache.activemq.leveldb.record.CollectionKey$Buffer.bean(CollectionKey.java:262) at

Re: ActiveMQ replicated leveldb with 2 brokers(replica = 1)

That also means that during a network partition, both brokers can serve clients. Is that really what you want? Can you please elaborate what does during a network partition means ? As per my understanding, both the brokers will be using same 'zkpath' in zookeeper, and master election happens

Re: ActiveMQ replicated leveldb with 2 brokers(replica = 1)

Hi Jim, But I am using replica =1 and (quorum = replica/2+1) AND quorum != (no of broker/2 +1). So in my case a single broker can also serve the client(1/2 +1 = 1) Thanks, Anuj -- View this message in context:

ActiveMQ 5.12 release date ?

Hi, I just want to know about ActiveMQ-5.12 release date. It has a very important fix https://issues.apache.org/jira/browse/AMQ-5082 for leveldb replication. Any updates on release date ? Thanks, Anuj -- View this message in context:

Re: ActiveMQ replicated leveldb with 2 brokers(replica = 1)

Any updates here. -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-replicated-leveldb-with-2-brokers-replica-1-tp4699679p4699739.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

ActiveMQ replicated leveldb with 2 brokers(replica = 1)

Hi, I am looking to move to using LevelDB replication. We will only have 2 nodes to run ActiveMq on, one for the master and one for the slave. We also intend to run ZooKeeper on 3 nodes. My intention is that if one server goes down ActiveMQ will continue to operate. I have had to set the

Re: AMQ 5.10 Replication LevelDB 2 nodes

Hi, We also want to use exact same setup. What I understand from ActiveMQ docs is that: if sync = quorum_mem, it means the update is considered complete when it has hit quorum(in this case it's 1 = 1/2+1) memory. So synchronous updates to the master's memory and async to the slave's memory.

Not able to disconnect http(REST) clients

Hi, I am using ActiveMQ-5.11. I am running embedded Jetty server and using MessageServlet as mentioned http://activemq.apache.org/rest.html to send and consume. Once I create a consumer or producer to messages, I am not able to disconnect it later. I can see in Jconsole that these

Re: Selectors and cursor for Topics

Actually out of four, two are having the same selectors(one java and one stomp perl consumer) and when we faced this issue, one(java) was getting the messages properly while other(perl) was not. After restarting the perl consumer, it was able to receive messages properly. (Using Amq-5.11.1) Also

Selectors and cursor for Topics

Hi, I was going through the http://activemq.2283324.n4.nabble.com/selectors-don-t-browse-td4695104.html to understand selectors and cursors for queues. I want to understand the behavior of cursors for topics ? Usecase: I am using 4 different durable subscribers on a topic, Each is having

JDBC for ActiveMQ-5.11

Hi, We are using ActiveMQ-5.11 with kahadb shared storage. I just want to understand the aspects of using JDBC for persistence store. I know that kahadb is the default database for ActiveMQ and JDBC was used with old versions. Does ActiveMQ gods suggest using JDBC in ActiveMQ ? Thanks, Anuj

Thread behaviour for persistence and non-persistence messages

Hi, Does ActiveMQ uses parallel threads for queuing the messages for persistence and non-persistence messages ? Does broker have a thread pool, from which threads are allocated to the process of message enqueuing ? I want to understand the threading model of this aspect? Thanks, Anuj --

IS it possible to increase the threads in broker

Hi, Is there a way to increase kahadb read/write threads and ActiveMQ task threads? If there is a pool, can we configure the thread pool size ? ActiveMQ Journal Checkpoint Worker, ActiveMQ Data File Writer, KahaDB Scheduler and ActiveMQ BrokerService[mqbrokerprod] Task-24650 Thanks, Anuj

Request response with ActiveMQ

Hi, I am trying to achieve request-response with ActiveMQ. This is how my listener looks like. We are using JMSTemplate to send the messages. This is the source code of producer who sends the messages and then wait for specified time. I just want to make sure whether we should use send call and

Re: ActiveMQ topic: Messages are not delived to a client

Hi, I forgot to mention one point. We recently upgraded to ActiveMQ-5.11.1. And only after this upgrade, we saw this issue. We have encountered this twice. Can some one please check or atleast let me know if there were some changes related to this in 5.11.1 Details: Suddenly a consumer stop

ActiveMQ slave broker opening it's connector

Hi, Using ActiveMQ-5.11.1. Topology : [shared-storage-master-slave ] with kahadb Kahadb store location is on NFS. Yesterday we faced a strange issue where suddenly failover broker opened it's transport connector and started accepting connections. Both primary and failover were serving the

Re: ActiveMQ master-slave topology issue[BUG]

And even in master broker's log, there were no activity for the same time.. What could cause this ? started. [20150425 08:03:19.893 EDT (ActiveMQ Journal Checkpoint Worker) org.apache.activemq.store.kahadb.MessageDatabase#checkpointUpdate 1517 DEBUG] - Checkpoint started. [20150425

Re: ActiveMQ topic: Messages are not delived to a client

Hi Tim, Yes. 3 consumers were connected to that topic out of which two were durable and one(this) was non-durable. I have jconsole monitoring for the broker and from jconsole I can see that all enqueued message were received by the durable consumers but some messages were missing for

Re: ActiveMQ master-slave topology issue[BUG]

Hi, I got the logs in this order only and after further checking the system I got to know that NFS(where we put kahadb and broker logs) was slow during that time. I can understand the delay in logs or I/O operations are slow during that time but it does not justify why failover also open it's

ActiveMQ topic: Messages are not delived to a client

Hi, Using ActiveMQ :5.10.0 We faced a strange issue where some messages sent on a topic are not received by the client. This is non durable client. The issue here is those mesasges are showing as inflight in jconsole which means broker sent those messages and acknowledgment is not received by

ActiveMQ conenction problem in Amazon AWS

Hi, We are facing an issue where perl clients (STOMP) are showing below errors while connecting to the ActiveMQ broker running in Amazon AWS. *Details: * When I run client consumer, it is not able to connect to the broker and keep on retrying. After 1 or 2 retries, it is able to connect to the

Re: java.lang.OutOfMemoryError in consumer application

Hi, It checked it and it was because of the client application was running more processes then the ulimit configured. Thanks, Anuj -- View this message in context: http://activemq.2283324.n4.nabble.com/java-lang-OutOfMemoryError-in-consumer-application-tp4691751p4691810.html Sent from the

java.lang.OutOfMemoryError in consumer application

Hi, We sometimes face : Exception in thread ActiveMQ Transport: tcp://mqbroker/*.*.*.*:61616@35637 java.lang.OutOfMemoryError: unable to create new native thread at java.lang.Thread.start0(Native Method) at java.lang.Thread.start(Thread.java:714) at

Queue Browser In ActiveMQ-5.10

Hi, I am browsing queue messages periodically using below method: I have list of Queues and I am creating single session for all the browsers. Is this the correct way of browsing or I should use create separate connections/sessions ? public MapString, Listlt;GearMessage

Re: ActiveMQ Stomp producer messages size limitation

Hi, I am sending the complete stack trace, Please see below: [I have added 'maxFrameSize' in broker URI, I didn't change anything on client size: I have tried with and without 'maxframesize' but result is always same. I am getting below error]: *[20150204 19:00:54:306 stomp_client.py:80 ERROR]

Re: ActiveMQ Stomp producer messages size limitation

Another concern here: As Tim mentioned : You need to configure a large maxFrameSize on the STOMP transportConnector in your Broker configuration, see: http://activemq.apache.org/xml-configuration.html I looked into the source code of ActiveMQ. I don't think changing the 'maxFrameSize' will

LevelDB performance for STOMP clients

Hi, I was benchmarking latencies(time taken by a message to reach from producer to consumer) for levelDB with STOMP (perl and python) producers with different message sizes. I was consistently seeing latency almost double for levelDB compare to kahadb. I have tested it with different variations

Re: Facing Failed to remove inactive durable subscriber

*java.lang.NullPointerException* here. Attaching the complete stack trace: [20150121 03:35:33.852 EST (ActiveMQ Durable Subscriber Cleanup Timer) org.apache.activemq.broker.region.TopicRegion#doCleanup 102 ERROR] - Failed to remove inactive durable subscriber *java.lang.NullPointerException *

Facing Failed to remove inactive durable subscriber

Hi, Using ActiveMQ 5.10 I am facing below error *sometimes* when broker tries to remove inactive durable subscriber because of long-time inactivity. And after this error, it stays forever in broker. /org.apache.activemq.broker.region.TopicRegion#doCleanup 102 ERROR] - Failed to remove inactive

Re: Facing Failed to remove inactive durable subscriber

Did anyone get a chance to look at this ? -- View this message in context: http://activemq.2283324.n4.nabble.com/Facing-Failed-to-remove-inactive-durable-subscriber-tp4690820p4690909.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: kahadb corruption: Checkpoint failed java.io.IOException: Input/output error

Hi, Yes !! The broker process was still running. I verified it with ps command. I have updated the JIRA with details as you mentioned in last update. Thanks, Anuj -- View this message in context:

Re: kahadb corruption: Checkpoint failed java.io.IOException: Input/output error

Hi, There was some failures on filer because of which applications (ActiveMQ) was not able to read/write on kahadb. As you mentioned that kahadb should handle this if master broker is not writing than failover should take over; I have logged a request

Re: kahadb corruption: Checkpoint failed java.io.IOException: Input/output error

Hi, Master was not completely killed. Master has stopped it's transport connectors and plugins but it didn't release it's lock from the kahadb. Thanks, Anuj -- View this message in context:

Re: kahadb corruption: Checkpoint failed java.io.IOException: Input/output error

Did anyone get a chance to look at this ? -- View this message in context: http://activemq.2283324.n4.nabble.com/kahadb-corruption-Checkpoint-failed-java-io-IOException-Input-output-error-tp4690378p4690442.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: sendTimeOut for python stomp client

Please respond !! -- View this message in context: http://activemq.2283324.n4.nabble.com/sendTimeOut-for-python-stomp-client-tp4690239p4690441.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

kahadb corruption: Checkpoint failed java.io.IOException: Input/output error

Hi, Broker verison : 5.10.0 using Master-slave topology with shared kahadb. Today we facing very critical production issue due to Kahadb. We got below mentioned error in broker logs, and after that broker stopped it's transport connectors and stopped it's services but still it didn't release

Re: kahadb corruption: Checkpoint failed java.io.IOException: Input/output error

Attaching the complete stack trace for more details. ActiveMQ_prod_25_Jan.txt http://activemq.2283324.n4.nabble.com/file/n4690379/ActiveMQ_prod_25_Jan.txt -- View this message in context:

sendTimeOut for python stomp client

Hi, I can see that send_timeout can be configured for java clients connecting to the broker. Is there any send timeout configuration exist for Stomp python client as well ? Thanks, Anuj -- View this message in context:

ActiveMQ Stomp producer messages size limitation

Hi, I am not able to send message more than 100MB to ActiveMQ broker. Producer throws below exception: /[20150113 03:16:59:609 stomp_client.py:80 ERROR] Received an error: org.apache.activemq.transport.stomp.ProtocolException: The maximum data length was exceeded at

java.net.ConnectException: Connection refused in client logs

Hi, We have seen this warning lot of time in client side logs. java.net.ConnectException: Connection refused As we can see in stacktrace that this is not generated from ActiveMQ code or any JMSException. This is coming from lower layer. Can someone help me to understand this exception? When can

Connection refused from broker

Hi, ActiveMQ version: 5.10 This is very weird issue where the client was not able to connect to the broker until it restarted. We didn't see any errors/warn in broker logs and even client logs just says: /[ 2014-12-14 00:00:01,692 [referenceDataSubscriberContainer-11660]

Re: LevelDB: Invalid log position WARN after destroying durable subscriber

Can you point to to that thread ? -- View this message in context: http://activemq.2283324.n4.nabble.com/LevelDB-Invalid-log-position-WARN-after-destroying-durable-subscriber-tp4688904p4689114.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

LevelDB: Invalid log position WARN after destroying durable subscriber

Hi, Using ActiveMQ 5.10. We are getting below warning messages after durable subscription gets destroyed because it's offlineDurableSubscriberTimeout expired. *From the logs: * 20141215 23:28:42.279 EST (ActiveMQ Durable Subscriber Cleanup Timer)

ActiveMQ-5.11 release date ?

Hi, Any updates about releasing date of ActiveMQ-5.11 ? Thanks, Anuj -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-5-11-release-date-tp4688846.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

LevelDB indexWriteBufferSize and logWriteBufferSize

Hi, As mentioned on ActiveMQ wiki: *logWriteBufferSize : 4194304 (4 MB) : That maximum amount of log data to build up before writing to the file system. IndexWriteBufferSize : 6291456 (6 MB) : Amount of index data to build up in memory before converting to a sorted on-disk file.* According to

  1   2   3   >