Re: Testing against ActiveMQ with JMeter: how to set JMSPriority and JMSExpiration, values cannot be seen in Broker
As per the JMS specification, several headers, including JMSPriority, are set on send() by the JMS provider (ActiveMQ). This means that values specified by clients are overwritten. Here's the spec; see section 3.4.11, How Message Header Values are Set: http://download.oracle.com/otn-pub/jcp/7195-jms-1.1-fr-spec-oth-JSpec/jms-1_1-fr-spec.pdf?AuthParam=1399518519_977545569f47e0da60da93ab6d7b22f0 To set the priority, the producer's setPriority() or send(Destination destination, Message message, int deliveryMode, int priority, long timeToLive) needs to be used. I'm not sure how that can be accomplished with JMeter. -- View this message in context: http://activemq.2283324.n4.nabble.com/Testing-against-ActiveMQ-with-JMeter-how-to-set-JMSPriority-and-JMSExpiration-values-cannot-be-seen-r-tp4680960p4680975.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Use message selectors against messages on disk
Using selector should work regardless if the message is on disk or in memory.. If it's not then it's a bug. Do you have a test case showing it's broken? On Tue, May 13, 2014 at 12:28 PM, Benjamin Jansen bjansen-activ...@w007.org wrote: Hello, In ActiveMQ 5.x (I have tried 5.6.0 and 5.9.1), is it possible to use JMS message selectors against in-flight messages that have been put on disk? Based on my experimentation, it appears not, but I wanted to double-check, since I've found conflicting information on the Web. A comment on a blog post describing this behavior, claims that it has been fixed: http://bit.ly/1sJpdw4 OTOH, this issue seems to indicate that it will never be fixed in AMQ: https://issues.apache.org/jira/browse/AMQ-2217 Thanks for any insight. - Ben Jansen -- Hiram Chirino Engineering | Red Hat, Inc. hchir...@redhat.com | fusesource.com | redhat.com skype: hiramchirino | twitter: @hiramchirino
Re: MQTT to JMS conversion results in null message body.
I see a similar behavior with HTTP too. I do a HTTP GET with a timeout of 30s on a topic string say, a.b.c. And, from a mosquitto_pub client, I do a publish with/without retain flag to a/b/c. I get a HTTP STATUS 200 OK, but, the message body is null. What is going on ? -- View this message in context: http://activemq.2283324.n4.nabble.com/MQTT-to-JMS-conversion-results-in-null-message-body-tp4681107p4681147.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: How to close consumer from broker service embedded
kind of curious, why? you'd need to build your own callback/control bus for that... apache camel is a good option for doing that.. that way you can detect events and then make decisions to determine whether a consumer should close.. On Tue, May 13, 2014 at 12:51 AM, xita-de phamquan...@gmail.com wrote: Thanks for your reply:) I user Advisory Message to detect consumer join. When I would like to close consumer(From Advisory Message or from Broker, not from consumer side). How can I do? -- View this message in context: http://activemq.2283324.n4.nabble.com/How-to-close-consumer-from-broker-service-embedded-tp4681015p4681080.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. -- Christian Posta http://www.christianposta.com/blog twitter: @christianposta
Re: ActiveMQ-CPP MessageNotReadableException
On 05/07/2014 05:22 AM, spam trap wrote: I need to display the complete message sent from an application in debugging mode. However I get the MessageNotReadableException thrown when trying to access the body. Is there a way of making the message readable or otherwise displaying the body? Can you provide a bit more detail on what you are doing here, I'm not entirely clear on it. There are some tricks that you could do if you cast the Message object into the internal ActiveMQMessage types but without seeing some code its hard to help you with an exact solution. -- Tim Bish Sr Software Engineer | RedHat Inc. tim.b...@redhat.com | www.fusesource.com | www.redhat.com skype: tabish121 | twitter: @tabish121 blog: http://timbish.blogspot.com/
Re: ActiveMQ 5.9.1 and Camel HTTP component
On 10/05/14 11:09, Peter Hicks wrote: I am not sure if this is an ApacheMQ or a Camel question, but I'm experiencing the following issue in AMQ, so it's probably a good place to start. Follow-up for anyone interested - ActiveMQ doesn't include the HTTP client library by default, and it requires downloading... problem solved! Peter
ActiveMq 5.9.0 Settings
Dear Listers,We are sending a file that is 100MB to the ActivemQ queues, are there any settings on activemq that we need to take care of before doing this.ThanksVilas -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMq-5-9-0-Settings-tp4681141.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Testing against ActiveMQ with JMeter: how to set JMSPriority and JMSExpiration, values cannot be seen in Broker
Hi, I try to run priority focussed tests with JMeter 2.11 against ActiveMQ 5.8 and some queues defined in the broker xml config. I successfully managed to push messages into the queues by the JMeter-Samplers JMS-Point-Point and also JMS-Publisher. With both samplers I do set JMS properties whereas these are accepted by the broker and logged into the logfile when a message is received: - JMSType (e.g. text, binary) - JMSXGroupID - JMSXGroupSeq - JMSCorrelationID But the properties JMSPriority and JMSExpiration are ignored and never set at the message. I tried both samplers, different property data types, ..., but the values are always the defaults 4 respectively 0. I configured the queues to support message priority (http://activemq.apache.org/how-can-i-support-priority-queues.html) and I do understand that delivery to a client always in order of priority depends on different other settings (http://architects.dzone.com/articles/activemq-message-priorities), but the value provided by the producer should nevertheless be accepted and logged? Since JMSExpiration doesn't work too I guess it's a matter of providing those values from JMeter via the ActiveMQ-Client-Impl to the broker? Is it possible at all to set those message properties with JMeter and to test scenarios of message priority? Thanks, Tom -- View this message in context: http://activemq.2283324.n4.nabble.com/Testing-against-ActiveMQ-with-JMeter-how-to-set-JMSPriority-and-JMSExpiration-values-cannot-be-seen-r-tp4680960.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: activemq-client does not close properly connections to the broker
The EOF exception does mean the client closed the socket without properly shutting down the ActiveMQ Connection. From the client log snippet posted, it's unclear what's causing the same. Is it possible to attach a debugger to the client and put a break-point at the point the disconnect occurs? If neither the client nor the broker initiated the disconnect, perhaps there's a network hickup causing the same. -- View this message in context: http://activemq.2283324.n4.nabble.com/activemq-client-does-not-close-properly-connections-to-the-broker-tp4681005p4681006.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Use message selectors against messages on disk
On 05/13/2014 12:28 PM, Benjamin Jansen wrote: Hello, In ActiveMQ 5.x (I have tried 5.6.0 and 5.9.1), is it possible to use JMS message selectors against in-flight messages that have been put on disk? Based on my experimentation, it appears not, but I wanted to double-check, since I've found conflicting information on the Web. A comment on a blog post describing this behavior, claims that it has been fixed: http://bit.ly/1sJpdw4 OTOH, this issue seems to indicate that it will never be fixed in AMQ: https://issues.apache.org/jira/browse/AMQ-2217 Thanks for any insight. - Ben Jansen You can only use a selector against those messages that are paged in, so if you can tolerate greater memory usage you can increase the max page size for that destination in order to have more in memory messages. http://activemq.apache.org/per-destination-policies.html -- Tim Bish Sr Software Engineer | RedHat Inc. tim.b...@redhat.com | www.fusesource.com | www.redhat.com skype: tabish121 | twitter: @tabish121 blog: http://timbish.blogspot.com/
Re: Request / Reply in Network of Brokers
We have Network TTL=10 and decreaseNetworkConsumerPriority not set (so it defaults to false) So I'm going to try with decreaseNetworkConsumerPriority = true. Thanks for your help. Regards Laci On 08.05.2014 05:17, artnaseef [via ActiveMQ] wrote: Is this with the default Network TTL setting of 1? Sounds like that's the case and that decreaseNetworkConsumerPriority is false (also the default). So, even though the consumer is only on A, and a person can easily see it makes no sense to move the messages to broker B, in an ActiveMQ demand-forwarded network-of-brokers, brokers B and C are both going to create consumers as the means to allow consumers across the network to consume the messages, and to allow that consumer on Broker A to receive messages produced on the other brokers, causing messages to move from Broker A to Broker B. With the default round-robin delivery of messages, exactly half will go to broker A's immediate consumer, and the other half will go to broker B. Broker B will not return those messages to Broker A, nor forward them on to Broker C, due to exhaustion of the Network TTL of 1. Your best bet is to use the decreaseNetworkConsumerPriority=true which never sends messages to another broker when there is another local consumer. If you reply to this email, your message will be added to the discussion below: http://activemq.2283324.n4.nabble.com/Request-Reply-in-Network-of-Brokers-tp4680957p4680976.html To start a new topic under ActiveMQ - User, email ml-node+s2283324n2341805...@n4.nabble.com To unsubscribe from ActiveMQ, click here http://activemq.2283324.n4.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_codenode=2341804code=bGFjaWdhc0BnbWFpbC5jb218MjM0MTgwNHwtNTEyNTg4MDgz. NAML http://activemq.2283324.n4.nabble.com/template/NamlServlet.jtp?macro=macro_viewerid=instant_html%21nabble%3Aemail.namlbase=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespacebreadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml -- View this message in context: http://activemq.2283324.n4.nabble.com/Request-Reply-in-Network-of-Brokers-tp4680957p4680988.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: ActiveMq - 5.9- Loadtest JMSException when passing a huge file
On 05/13/2014 10:28 AM, vilas_tadoori wrote: Dear Listers, We have written a loader class to test the load on the ActiveMq queues. The queue number size is 7. When we are passing files upto 100MB it works fine and sends the data to the ActiveMQ queues. When we are passing a file above 100 MB till 200 MB , the loader class is getting an error message that is Javax.jms.JMSException:Software caused connection abort: socket write error. [cid:image003.jpg@01CF6EE5.95089ED0] Are you sure you aren't hitting the maxFrameSize setting in your broker config? This could account for the sudden disconnect after topping the 100mb mark as I think the default config ships with a 100mb value. Any advice on this will be appreciated Thanks Vilas CAUTION - Disclaimer * This e-mail contains PRIVILEGED AND CONFIDENTIAL INFORMATION intended solely for the use of the addressee(s). If you are not the intended recipient, please notify the sender by e-mail and delete the original message. Further, you are not to copy, disclose, or distribute this e-mail or its contents to any other person and any such actions are unlawful. This e-mail may contain viruses. Infosys has taken every reasonable precaution to minimize this risk, but is not liable for any damage you may sustain as a result of any virus in this e-mail. You should carry out your own virus checks before opening the e-mail or attachment. Infosys reserves the right to monitor and review the content of all messages sent to or from this e-mail address. Messages sent to or from this e-mail address may be stored on the Infosys e-mail system. ***INFOSYS End of Disclaimer INFOSYS*** image003.jpg (118K) http://activemq.2283324.n4.nabble.com/attachment/4681086/0/image003.jpg -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMq-5-9-Loadtest-JMSException-when-passing-a-huge-file-tp4681086.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. -- Tim Bish Sr Software Engineer | RedHat Inc. tim.b...@redhat.com | www.fusesource.com | www.redhat.com skype: tabish121 | twitter: @tabish121 blog: http://timbish.blogspot.com/
ActiveMQ 5.9.1 and Camel HTTP component
All, I am not sure if this is an ApacheMQ or a Camel question, but I'm experiencing the following issue in AMQ, so it's probably a good place to start. There are several web servers I need to retrieve a single XML file from, every 30 seconds. I want to publish this XML data on a topic for distribution to other systems, and it's been suggested I use Camel to do this. Under a camelContext, I have the following: route descriptionFeed 1/description from uri=timer://feed1timer?fixedRate=trueamp;delay=0amp;period=3/ to uri=http://www.example.com/feed1.xml/ to uri=activemq:topic:FEED1/ /route When I start ActiveMQ, the broker begins to start, but then shuts down immediately after the following debug (not error, seemingly) message is output: 2014-05-10 00:35:48,101 | DEBUG | Found component: http in registry: null | org.apache.camel.impl.DefaultComponentResolver | main If I remove the HTTP line from the route, the broker starts successfully and sends blank messages on to the topic - from this, it seems that it's just the HTTP component that's failing to load. This is the first time I've started to use Camel for this kind of activity - can anyone help out with where I might be going wrong? This is on an Ubuntu 14.04 machine with a clean install of ActiveMQ 5.9.1 under Java 1.8.0_05. Peter
Re: Use message selectors against messages on disk
Message selectors are applied to messages cached in memory, not on disk. On Tue, May 13, 2014 at 9:28 AM, Benjamin Jansen bjansen-activ...@w007.org wrote: Hello, In ActiveMQ 5.x (I have tried 5.6.0 and 5.9.1), is it possible to use JMS message selectors against in-flight messages that have been put on disk? Based on my experimentation, it appears not, but I wanted to double-check, since I've found conflicting information on the Web. A comment on a blog post describing this behavior, claims that it has been fixed: http://bit.ly/1sJpdw4 OTOH, this issue seems to indicate that it will never be fixed in AMQ: https://issues.apache.org/jira/browse/AMQ-2217 Thanks for any insight. - Ben Jansen -- Christian Posta http://www.christianposta.com/blog twitter: @christianposta
Trouble setting up ReplicatedLevelDB / zookeeper for AMQ 5.9.1
I've been banging my head against the wall for a few hours trying to get this going, but am unable to see where the issue is. I'm trying to setup a 3 broker / 3 zookeeper node config. Zookeeper start fine on all three servers, but when I start ActiveMQ on the master node I get the following in activemq.log. The activemq.xml config file is below the log output. Any help would be greatly appreciated. activemq.log ### 2014-05-15 15:13:08,590 | DEBUG | Using class path resource [activemq.xml] from activemq.xml | org.apache.activemq.xbean.XBeanBrokerFactory | main 2014-05-15 15:13:08,627 | INFO | Refreshing org.apache.activemq.xbean.XBeanBrokerFactory$1@2e3f8a3e: startup date [Thu May 15 15:13:08 ADT 2014]; root of context hierarchy | org.apache.activemq.xbean.XBeanBrokerFactory$1 | main 2014-05-15 15:13:09,482 | DEBUG | Bean factory for org.apache.activemq.xbean.XBeanBrokerFactory$1@2e3f8a3e: org.springframework.beans.factory.support.DefaultListableBeanFactory@3302a252: defining beans [org.springframework.beans.factory.config.PropertyPlaceholderConfigurer#0,org.apache.activemq.xbean.XBeanBrokerService#0,securityLoginService,securityConstraint,adminSecurityConstraint,securityConstraintMapping,adminSecurityConstraintMapping,securityHandler,contexts,jettyPort,Server]; root of factory hierarchy | org.apache.activemq.xbean.XBeanBrokerFactory$1 | main 2014-05-15 15:13:09,607 | DEBUG | Unable to locate MessageSource with name 'messageSource': using default [org.springframework.context.support.DelegatingMessageSource@22ebc6bf] | org.apache.activemq.xbean.XBeanBrokerFactory$1 | main 2014-05-15 15:13:09,610 | DEBUG | Unable to locate ApplicationEventMulticaster with name 'applicationEventMulticaster': using default [org.springframework.context.event.SimpleApplicationEventMulticaster@2a4354cb] | org.apache.activemq.xbean.XBeanBrokerFactory$1 | main 2014-05-15 15:13:09,956 | INFO | Using Persistence Adapter: Replicated LevelDB[/opt/sphere/activemq-5.9.1/data, dev1-server:2181, dev2-server:2181, dev3-server:2181//store/activemq/leveldb-stores] | org.apache.activemq.broker.BrokerService | main 2014-05-15 15:13:10,046 | DEBUG | addEvent: NONE = CONNECTING | org.apache.activemq.leveldb.replicated.groups.ZKClient | main 2014-05-15 15:13:10,046 | INFO | Starting StateChangeDispatcher | org.apache.activemq.leveldb.replicated.groups.ZKClient | ZooKeeper state change dispatcher thread 2014-05-15 15:13:10,057 | INFO | Client environment:zookeeper.version=3.4.5-1392090, built on 09/30/2012 17:52 GMT | org.apache.zookeeper.ZooKeeper | main 2014-05-15 15:13:10,057 | INFO | Client environment:host.name=dev1-server | org.apache.zookeeper.ZooKeeper | main 2014-05-15 15:13:10,057 | INFO | Client environment:java.version=1.7.0_25 | org.apache.zookeeper.ZooKeeper | main 2014-05-15 15:13:10,057 | INFO | Client environment:java.vendor=Oracle Corporation | org.apache.zookeeper.ZooKeeper | main 2014-05-15 15:13:10,057 | INFO | Client environment:java.home=/usr/lib/jvm/jdk1.7.0_25/jre | org.apache.zookeeper.ZooKeeper | main 2014-05-15 15:13:10,057 | INFO | Client environment:java.class.path=/opt/sphere/activemq-5.9.1/bin/activemq.jar | org.apache.zookeeper.ZooKeeper | main 2014-05-15 15:13:10,057 | INFO | Client environment:java.library.path=/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib | org.apache.zookeeper.ZooKeeper | main 2014-05-15 15:13:10,058 | INFO | Client environment:java.io.tmpdir=/opt/sphere/activemq-5.9.1/tmp | org.apache.zookeeper.ZooKeeper | main 2014-05-15 15:13:10,058 | INFO | Client environment:java.compiler=NA | org.apache.zookeeper.ZooKeeper | main 2014-05-15 15:13:10,058 | INFO | Client environment:os.name=Linux | org.apache.zookeeper.ZooKeeper | main 2014-05-15 15:13:10,058 | INFO | Client environment:os.arch=amd64 | org.apache.zookeeper.ZooKeeper | main 2014-05-15 15:13:10,058 | INFO | Client environment:os.version=3.2.0-32-virtual | org.apache.zookeeper.ZooKeeper | main 2014-05-15 15:13:10,058 | INFO | Client environment:user.name=devuser1 | org.apache.zookeeper.ZooKeeper | main 2014-05-15 15:13:10,058 | INFO | Client environment:user.home=/home/devuser1 | org.apache.zookeeper.ZooKeeper | main 2014-05-15 15:13:10,058 | INFO | Client environment:user.dir=/opt/sphere | org.apache.zookeeper.ZooKeeper | main 2014-05-15 15:13:10,059 | INFO | Initiating client connection, connectString=dev1-server:2181, dev2-server:2181, dev3-server:2181 sessionTimeout=2000 watcher=org.apache.activemq.leveldb.replicated.groups.ZKClient@2457c24c | org.apache.zookeeper.ZooKeeper | main 2014-05-15 15:13:10,075 | ERROR | Failed to start Apache ActiveMQ ([pubsub, null], org.linkedin.util.exceptions.InternalException: org.linkedin.zookeeper.client.ZooKeeperFactory) | org.apache.activemq.broker.BrokerService | main 2014-05-15 15:13:10,076 | INFO | Apache ActiveMQ 5.9.1 (pubsub, null) is shutting down | org.apache.activemq.broker.BrokerService | main 2014-05-15 15:13:10,077 | INFO | Connector openwire
Re: Trouble setting up ReplicatedLevelDB / zookeeper for AMQ 5.9.1
Ok, so after deleting everything in the data dirs, it starts up now. Maybe something was corrupt (?) I'll keep this post here for future users with the same issue. -- View this message in context: http://activemq.2283324.n4.nabble.com/Trouble-setting-up-ReplicatedLevelDB-zookeeper-for-AMQ-5-9-1-tp4681151p4681152.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: can someone please fix a typo (apache-karaf features-core.xml)
Hi That is not a typo, that is a version range, saying Spring 3.1 ... 3.9 is accepted. And the spring feature comes out of the box in Karaf, so its there you should look for the problem. On Sat, May 10, 2014 at 12:55 AM, Geurt Schimmel gschim...@schubergphilis.com wrote: karaf@root features:install activemq-broker Error executing command: No feature named 'spring' with version '[3.1,4)' available activemq-karaf/src/main/resources/features-core.xml, line 25: feature version=[3.1,4)spring/feature should read feature version=[3.1.4)spring/feature Thanks, Geurt -- Claus Ibsen - Red Hat, Inc. Email: cib...@redhat.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen hawtio: http://hawt.io/ fabric8: http://fabric8.io/
Re: Connecting to Master/Slave from client libs (MQTT, STOMP etc.) and failover
On Wed, May 14, 2014 at 4:12 PM, paddycarman paddy.car...@gmail.com wrote: Hi All, In a Master/Slave setup AFAIK, the individual brokers have different IP addresses. Let's say that a device would like to connect to a Master/Slave setup using a client lib (say MQTT). How do we do failover in this case? As far as I understand, the failover protocol is only for JMS connections. Correct. Failover is mostly a function of the client lib. * Should the client know the IP addresses of both the Master and Slave and handle connection failures on its own by connecting to the slave if the master fails? Yes. * Is there a way to advertise a single IP address for the Master/Slave setup and hide the details of the setup from the client? Yes. Use TCP load balancer in front of the master/slave pairs. Something like HAProxy should work. Thanks in advance. Paddy -- View this message in context: http://activemq.2283324.n4.nabble.com/Connecting-to-Master-Slave-from-client-libs-MQTT-STOMP-etc-and-failover-tp4681129.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. -- Hiram Chirino Engineering | Red Hat, Inc. hchir...@redhat.com | fusesource.com | redhat.com skype: hiramchirino | twitter: @hiramchirino
Activemq oracle AQ slow consumer
We use camel to route messages to oracle AQ, camel is running inside Activemq. Problem is that oracle consumes messages very slow and therefore the producer get's slow, hear is the flow: producer (external Java application) --- activemq (VirtuelTopic.x) -- activemq (Consumer.xx.VirtuelTopic.x) --- Oracle AQ JMS queue Step (Consumer.xx.VirtuelTopic.x) --- Oracle AQ JMS queue is done by camel. Problem is that Oracle AQ JMS queue consumers is very slow and therefore this affect all the way back to the producer. I would like to configure so activemq camel routes messages fast to Oracle AQ JMS and not get slow down because Oracle AQ JMS is slow. Is that possible to do ? Hear is some of my camel configuration: route descriptionCairo to T3OPDB/description from uri=activemq:queue:Consumer.XX.VirtualTopic.XX?concurrentConsumers=20 / to uri=T3OPDB:queue:QUEUE_OWNER.XX_IN_Q / /route bean id=T3OPDB class=org.apache.camel.component.jms.JmsComponent property name=connectionFactory bean class=org.springframework.jms.connection.SingleConnectionFactory property name=targetConnectionFactory bean class=oracle.jms.AQjmsConnectionFactory property name=jdbcURL value=jdbc:oracle:thin:@(DESCRIPTION=(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP)(HOST=oradb5.test.host)(PORT=1522)))(CONNECT_DATA=(SID=T3OPDB)))/ property name=username value=xxx/ property name=password value=xxx/ /bean /property property name=reconnectOnException value=true/ /bean /property /bean -- View this message in context: http://activemq.2283324.n4.nabble.com/Activemq-oracle-AQ-slow-consumer-tp4681161.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
ActiveMQ mqtt broker queuing and not publishing topics when clean session set to false
Using broker as ActiveMQ 5.9.0 and Client - Paho Java. Setting clean session as false as I need messages sent when client is offline. Getting messages sent when clent is offline but when client is online messages are queued and not sent from ActiveMQ. Messages which are sent when client is online are queued and get these messages when restart client PAHO. So, how do I get messages sent when client is online with clean session set to false. Is there any other setting to be done? -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-mqtt-broker-queuing-and-not-publishing-topics-when-clean-session-set-to-false-tp4681135.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Use message selectors against messages on disk
Hi Christian, Hi Tim, ceposta wrote Message selectors are applied to messages cached in memory, not on disk. Does this also apply to the JMSXMessageGroupID which has some special meaning and therefore handling? If a client consumes messages of a dedicated group, the broker will only dispatch those paged in in memory? Does the broker take care of paging in the next messages of this group if there are any as long as the client is connected? Or is a scenario possible where the client does not get more messages and then disconnects leaving messages for this group on disk? Thanks, Tom -- View this message in context: http://activemq.2283324.n4.nabble.com/Use-message-selectors-against-messages-on-disk-tp4681095p4681226.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Broker Hangs after some time - or does nothing.
Are you able to find the cause of this issue, I am facing same issue with 5.9.1. We are using 5.9.1 with leveldb, everything worked properly in our QA but when we migrate to prod we had seen the same behavoir you were describing. I was unable to capture number of connections or heap size etc from prod. I am not able to reproduce this in QA or DEV. Is this something to do with network connections? Any help would be appreciated. -- View this message in context: http://activemq.2283324.n4.nabble.com/Broker-Hangs-after-some-time-or-does-nothing-tp4677506p4681166.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Activemq on Docker
Hi, I'm trying to get activemq working on a Docker container. I've got the basic install going and I'm now trying to configure multicast discovery so that multiple containers can be connected together. I've turned on the multicast discovery and the containers are trying to connect. However the two activemq instances cannot create a network bridge as the multicast discovery protocol passes the hostname of the activemq instance rather than the ip address. The other container cannot resolve the passed hostname and the bridge fails. I've seen a number of posts around this and the general response that I can see is sort out your DNS setting or edit the /etc/hosts file. This doesn't really help in a dynamic environment such as a docker container. I was wondering if there was a workaround for this i.e. turning off DNS hostname resolution ? thanks for your help Noel
