http://blog.gmane.org/gmane.comp.java.activemq.user hourly 1 1901-01-01T00:00+00:00 http://gmane.org/img/gmane-25t.png http://gmane.org http://comments.gmane.org/gmane.comp.java.activemq.user/34120 <pre>Hi, I've got an ActiveMQ 5.3.0 broker running in one JVM. &lt;transportConnectors&gt; &lt;transportConnector name="openwire" uri="tcp://localhost:19616"/&gt; &lt;/transportConnectors&gt; Another application (different JVM but currently on the same machine) connects to that broker to receive messages from a single queue through a MessageListener: failover://(tcp://localhost:19616?keepAlive=true)?startupMaxReconnectAttempts=5 The message frequency is rather low (5-500 per hour) and can drop to zero over multiple hours (during the night). Every now and then, the MessageListener simply doesn't get any more messages and we have to restart the application for a reconnect despite the failover protocol (as seen above). We've tried various connection URI parameters but so far, the issue keeps popping up every few weeks. I somehow doubt it has to do with some timeout because, yesterday, it happened during the day during normal business, not in the night after hours of inactivity. When the problem happens, the message producer can still happily add new messages which are then simply piled up. We first thought that the broker would stop accepting connections at some point but we now have a monitoring agent for Nagios that regularly tries to connect to ActiveMQ to check if anything is wrong on that side, but that proved to be in vain. So, everything is solid on the broker side. The client used to run ActiveMQ 5.3.0, too (just the ActiveMQConnectionFactory, no broker). We also tried 5.5.1 on the client side but nothing has changed. I was wondering if anyone has a good idea on this problem. Thanks a lot, Jeremias Maerki </pre> Jeremias Maerki 2012-05-25T10:23:54 http://comments.gmane.org/gmane.comp.java.activemq.user/34114 <pre>Hello, We are using a network of brokers but it's giving us some problems with load balancing. Most of the messages are being delivered to the remote broker instead of being shared between the network connector and the broker's consumer. If a broker has 5 consumers and 1 network connector, and receives 50 messages, it processes 5-10 in its consumers and the rest outside We are using prefetch = 1 for the consumers, so we set prefetchSize=1 for the network connector. We have tried both with and without conduitSubscriptions. The only configuration that have worked was setting a high prefetch in consumers and network connector, but that was only for testing purpose, as we cant modify the consumer's prefetch size. So we need to know if there's any way to make it work with prefetch = 1 in the consumers. The expected behaviour in the case explained before would be processing 25 messages in the broker's consumers and send 25 to the network connector. Thanks -- View this message in context: http://activemq.2283324.n4.nabble.com/NetworkConnectors-and-prefetch-tp4652677.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. </pre> RickSnz 2012-05-24T11:38:05 http://comments.gmane.org/gmane.comp.java.activemq.user/34112 <pre>Hi, We are running activemq 5.5.1 in an active/passive failover configuration with JDBC Persistence to an Oracle backend. The default strategy for determining whether the current master has failed is for the secondary server to attempt to get a lock on the database table, waiting indefinitely for the lock to be granted. This is not working (at least in our context) as, after a relatively short time in operation (a handful of hours at most) the connection to Oracle is dropped. Activemq doesn't notice this, so the secondary sits there happily waiting for a lock it can now never get and, in the event of a failure, won't serve any clients as it is not a master. Is there some way to change the decision mechanism to, eg, a polling strategy? Or can anyone suggest another resolution to this problem? Alex. </pre> Alex Hooper 2012-05-24T10:45:31 http://comments.gmane.org/gmane.comp.java.activemq.user/34111 <pre>Hello, I'm trying to use MQTT protocol between ActiveMQ broker and JMS client. Broker is started with MQTT transport: &lt;transportConnector name="mqtt" uri="mqtt://0.0.0.0:61616"/&gt; One queue and one topic are configured. 1. For testing I use HermesJMS tool. I've configured the tool with MQTT jars (from /apache-activemq-5.6.0/lib/optional folder) and brockerURL: mqtt://localhost:61616 When I try to open connection (just open an queue tab-panel) I receive such exception: javax.jms.JMSException: java.io.EOFException at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:49) at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1362) at org.apache.activemq.ActiveMQConnection.ensureConnectionInfoSent(ActiveMQConnection.java:1466) at org.apache.activemq.ActiveMQConnection.setClientID(ActiveMQConnection.java:396) at hermes.impl.jms.ConnectionManagerSupport.createConnection(ConnectionManagerSupport.java:174) ... at hermes.browser.tasks.ThreadPool.run(ThreadPool.java:170) at java.lang.Thread.run(Thread.java:619) Caused by: java.io.EOFException at java.io.DataInputStream.readByte(DataInputStream.java:250) at org.apache.activemq.transport.mqtt.MQTTWireFormat.unmarshal(MQTTWireFormat.java:80) at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:229) at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:221) at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:204) ... 1 more Broker logs: WARN | Transport Connection to: tcp://127.0.0.1:2442 failed: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too (&gt;30000) long: tcp://127.0.0.1:2442 2. I've tried to test with my small test client based on ActiveMQ without any success. 2.1. with mqtt://localhost:61616 Logs: 2012-05-24 12:22:03.029 [FINE] org.apache.activemq.transport.mqtt.MQTTProtocolConverter onActiveMQCommand Do not know how to process ActiveMQ Command ConnectionInfo {commandId = 1, responseRequired = true, connectionId = ID:BK5N00025814-8614-1337854948615-2:1, clientId = ID:BK5N00025814-8614-1337854948615-1:1, clientIp = null, userName = null, password = *****, brokerPath = null, brokerMasterConnector = false, manageable = true, clientMaster = true, faultTolerant = false, failoverReconnect = false} 2.2. with failover://(mqtt://localhost:61616) it always tries to reconnect after approx. 30 seconds. 3. When I tried to send messages from MQTT client (mqtt-client-1.2-uber.jar) - everything was fine. Question: Are there any tricks in configuration of MQTT protocol for ActiveMQ JMS clients? I did find any information on the documentation page. Thanks in advance. Best regards, Dmytro Pishchukhin </pre> Dmytro Pishchukhin 2012-05-24T10:29:26 http://comments.gmane.org/gmane.comp.java.activemq.user/34105 <pre>I attempt to put a text message on a queue using HTTP. The admin shows the enqueued *and* dequeued counters both incremented by one. The broker log excerpt follows. I must be doing something it doesn't like. Any assistance will be apreciated. Thanks. 2012-05-23 12:09:56,040 | DEBUG | call servlet MessageServlet | org.eclipse.jetty.servlet.ServletHandler | qtp32489992-25 - /demo/message/request?type=queue 2012-05-23 12:09:56,040 | DEBUG | destination uri=request | org.apache.activemq.web.MessageServletSupport | qtp32489992-25 - /demo/message/request?type=queue 2012-05-23 12:09:56,040 | DEBUG | request (queue) | org.apache.activemq.web.MessageServletSupport | qtp32489992-25 - /demo/message/request?type=queue 2012-05-23 12:09:56,040 | DEBUG | Sending message to: queue://request with text: this is a test23MAY12:12:09:56 | org.apache.activemq.web.MessageServlet | qtp32489992-25 - /demo/message/request?type=queue 2012-05-23 12:09:56,040 | DEBUG | localhost Message ID:d22275-3380-1337789359310-3:1:1:1:1 sent to queue://request | org.apache.activemq.broker.region.Queue | ActiveMQ Task-1 2012-05-23 12:09:56,040 | DEBUG | request toPageIn: 1, Inflight: 0, pagedInMessages.size 0, enqueueCount: 1, dequeueCount: 0 | org.apache.activemq.broker.region.Queue | BrokerService[localhost] Task-1 2012-05-23 12:09:56,040 | DEBUG | Async client internal exception occurred with no exception listener registered: java.lang.IllegalStateException: DISPATCHED,initial | org.apache.activemq.ActiveMQConnection | ActiveMQ Session Task-1 java.lang.IllegalStateException: DISPATCHED,initial at org.eclipse.jetty.server.AsyncContinuation.dispatch(AsyncContinuation.java:403) at org.eclipse.jetty.server.AsyncContinuation.resume(AsyncContinuation.java:810) at org.apache.activemq.web.MessageServlet$Listener.onMessageAvailable(MessageServlet.java:368) at org.apache.activemq.ActiveMQMessageConsumer.dispatch(ActiveMQMessageConsumer.java:1320) at org.apache.activemq.ActiveMQSessionExecutor.dispatch(ActiveMQSessionExecutor.java:131) at org.apache.activemq.ActiveMQSessionExecutor.iterate(ActiveMQSessionExecutor.java:202) at org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:122) at org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:43) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) at java.lang.Thread.run(Thread.java:619) 2012-05-23 12:09:56,055 | DEBUG | Sent! to destination: queue://request message: ActiveMQTextMessage {commandId = 0, responseRequired = false, messageId = ID:d22275-3380-1337789359310-3:1:1:1:1, originalDestination = null, originalTransactionId = null, producerId = null, destination = queue://request, transactionId = null, expiration = 0, timestamp = 1337789396040, arrival = 0, brokerInTime = 0, brokerOutTime = 0, correlationId = null, replyTo = null, persistent = true, type = null, priority = 5, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = null, marshalledProperties = null, dataStructure = null, redeliveryCounter = 0, size = 0, properties = null, readOnlyProperties = false, readOnlyBody = false, droppable = false, text = this is a test23MAY12:12:09:56} | org.apache.activemq.web.WebClient | qtp32489992-25 - /demo/message/request?type=queue 2012-05-23 12:09:56,055 | DEBUG | scope null||/demo/message/request &lt; at &gt; o.e.j.w.WebAppContext{/fileserver,file:/C:/apache-activemq-5.6.0/webapps/fileserver/} | org.eclipse.jetty.server.handler.ContextHandler | qtp32489992-25 - /demo/message/request?type=queue 2012-05-23 12:09:56,055 | DEBUG | RESPONSE /demo/message/request 200 | org.eclipse.jetty.server.Server | qtp32489992-25 - /demo/message/request?type=queue 2012-05-23 12:09:56,055 | DEBUG | filled 0/0 | org.eclipse.jetty.http.HttpParser | qtp32489992-25 ----- Stephen Vincent -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-5-6-IllegalStateException-MessageServlet-java-368-tp4651797.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. </pre> Steve.V. 2012-05-23T16:23:21 http://comments.gmane.org/gmane.comp.java.activemq.user/34101 <pre>Hi everybody, I am developing some plugins for ActiveMQ and because I have more than one plugin in my configuration I would like to connect them, that is to have a reference from the one to another. If you can help me with the configuration and some examples of how can I achieve this. So from one class that extends a BrokerFilter I want to have a reference to another one that is also working as a plugin (also extends BrokerFilter). Thanks... -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-Plugin-references-tp4651507.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. </pre> mandjeo 2012-05-23T12:15:05 http://comments.gmane.org/gmane.comp.java.activemq.user/34098 <pre>Hi everyone, I was searching for the ActiveMQ-rar 5.5.1 source code, but the -source.jar file contains nothing other than a list of dependencies and legal notes. http://repo1.maven.org/maven2/org/apache/activemq/activemq-rar/5.5.1/ Can you help me where can I find it, and how come the source jar is empty? Thanks, -Peter- -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-rar-source-tp4651281.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. </pre> Croo 2012-05-23T08:30:56 http://comments.gmane.org/gmane.comp.java.activemq.user/34094 <pre>Hey Folks, We are excited to have interest from Active MQ at CodeMaps.org. Welcome to the CodeMaps.org community! We have been hearing feedback, and improving the usefulness of the site by leaps and bounds :-) We were wondering if you guys could do us a quick favor. Would you take 5-minutes, go to the site, and tag code as being performance-sensitive, messaging, integration pattern, needs-refactoring, or something similar. We believe that with people tagging the Active MQ codebase - it will become an awesome community resource. Please go to *http://www.codemaps.org/c/Apache_ActiveMQ*, signup, and tag at least 3 classes or methods to help. Your feedback is important to us as it helps us help you guys - so let us know your thoughts. Thanks and Regards, CodeMaps Team </pre> Abhishek Rakshit 2012-05-23T01:33:59 http://comments.gmane.org/gmane.comp.java.activemq.user/34092 <pre>Is there a 64-bit release of ActiveMQ NMS? I have not found one and have had problems building from source. </pre> Mark Webb 2012-05-22T21:25:11 http://comments.gmane.org/gmane.comp.java.activemq.user/34087 <pre> Hi all, We have a disk array available and two servers and are ready for setting up a master-slave brokers based on SAN. We have mounted the shared storage partition to the same path of two servers. Now create a directory or write some files on one server in the mounted directory, we cannot see the directory or files on the another server in the same mounted directory except for remount. What's wrong or what others tools we need to synchronize files between two servers? Thanks! -- Wangyin SuoNayi2006-9Onoh4P/yGk&lt; at &gt;public.gmane.org </pre> SuoNayi 2012-05-22T09:58:58 http://comments.gmane.org/gmane.comp.java.activemq.user/34084 <pre>Hi, I have been trying to integrate the active mq with JBOss as 7. I have constantly running into errors and exceptions. I try to post them on jboss forum. They are saying that its active mq that neds to resolve this. SO, if some one can please post a small tutorial of sorts on how to do this integration, it would be of great help. THanks Ram -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-and-Jboss-AS-7-tp4649224.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. </pre> bondrk 2012-05-22T01:51:27 http://comments.gmane.org/gmane.comp.java.activemq.user/34078 <pre>Hi, We had recently done changes in our application that uses ActiveMQ. Upon building and deploying the app, an exception was prompted during start-up: ... Caused by: org.xml.sax.SAXParseException: cvc-elt.1: Cannot find the declaration of element 'beans'. at com.sun.org.apache.xerces.internal.util.ErrorHandlerWrapper.createSAXParseException(ErrorHandlerWrapper.java:195) at com.sun.org.apache.xerces.internal.util.ErrorHandlerWrapper.error(ErrorHandlerWrapper.java:131) at com.sun.org.apache.xerces.internal.impl.XMLErrorReporter.reportError(XMLErrorReporter.java:384) at com.sun.org.apache.xerces.internal.impl.XMLErrorReporter.reportError(XMLErrorReporter.java:318) at com.sun.org.apache.xerces.internal.impl.xs.XMLSchemaValidator.handleStartElement(XMLSchemaValidator.java:1916) at com.sun.org.apache.xerces.internal.impl.xs.XMLSchemaValidator.startElement(XMLSchemaValidator.java:705) at com.sun.org.apache.xerces.internal.impl.XMLNSDocumentScannerImpl.scanStartElement(XMLNSDocumentScannerImpl.java:400) at com.sun.org.apache.xerces.internal.impl.XMLNSDocumentScannerImpl$NSContentDriver.scanRootElementHook(XMLNSDocumentScannerImpl.java:626) at com.sun.org.apache.xerces.internal.impl.XMLDocumentFragmentScannerImpl$FragmentContentDriver.next(XMLDocumentFragmentScannerImpl.java:3103) at com.sun.org.apache.xerces.internal.impl.XMLDocumentScannerImpl$PrologDriver.next(XMLDocumentScannerImpl.java:922) at com.sun.org.apache.xerces.internal.impl.XMLDocumentScannerImpl.next(XMLDocumentScannerImpl.java:648) at com.sun.org.apache.xerces.internal.impl.XMLNSDocumentScannerImpl.next(XMLNSDocumentScannerImpl.java:140) at com.sun.org.apache.xerces.internal.impl.XMLDocumentFragmentScannerImpl.scanDocument(XMLDocumentFragmentScannerImpl.java:511) at com.sun.org.apache.xerces.internal.parsers.XML11Configuration.parse(XML11Configuration.java:808) at com.sun.org.apache.xerces.internal.parsers.XML11Configuration.parse(XML11Configuration.java:737) at com.sun.org.apache.xerces.internal.parsers.XMLParser.parse(XMLParser.java:119) at com.sun.org.apache.xerces.internal.parsers.DOMParser.parse(DOMParser.java:235) at com.sun.org.apache.xerces.internal.jaxp.DocumentBuilderImpl.parse(DocumentBuilderImpl.java:284) at org.springframework.beans.factory.xml.DefaultDocumentLoader.loadDocument(DefaultDocumentLoader.java:75) at org.springframework.beans.factory.xml.XmlBeanDefinitionReader.doLoadBeanDefinitions(XmlBeanDefinitionReader.java:388) We did not do any changes on the dependencies nor the ActiveMQ XML file. Kindly help advise. The ActiveMQ XML initial contents are: &lt;beans xmlns="http://www.springframework.org/schema/beans" xmlns:amq="http://activemq.apache.org/schema/core" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd"&gt; ... Regards, Gianne -- View this message in context: http://activemq.2283324.n4.nabble.com/org-xml-sax-SAXParseException-cvc-elt-1-Cannot-find-the-declaration-of-element-beans-tp4648157.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. </pre> gctan 2012-05-21T14:08:05 http://comments.gmane.org/gmane.comp.java.activemq.user/34074 <pre>I followed the advice found on this link: http://activemq.apache.org/jms-bridge-with-oracle-aq.html and got most of the way there. However, I am reading Oracle Object types off the Oracle AQ and as a result I get a JMS-137 error "Payload factory must be specified for destinations with ADT payloads". I do not understand how I can specify the Factory I have created in the configuration to handle the custom payload. When writing a simple program to read messages off the Oracle AQ I simple do: ORADataFactory orad = new DataFactory(); QueueReceiver receiver = ((AQjmsSession)queueSession).createReceiver(queue, orad); queueConnection.start(); Does anyone know how to do this? If so, help would be much appreciated a I have googled this to death. Thanks, J -- View this message in context: http://activemq.2283324.n4.nabble.com/Oracle-AQ-JMS-Bridge-with-Active-MQ-tp4647863.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. </pre> Lister 2012-05-21T08:34:48 http://comments.gmane.org/gmane.comp.java.activemq.user/34073 <pre>Hello again, We are from AMQ 5.4.0 to 5.6.0, and there appears to be a new uniqueness constraint in network connector names in network-of-brokers configurations. Here's our setup: - N copies of a producer application; each copy of the producer application consists of an embedded broker with 2 network connectors pointing at an embedded broker in the consumer application - 1 consumer application; the consumer application consists of an embedded broker with 2 transport connectors Messages in the consumer application are sent to the embedded broker, which pushes those messages to the embedded broker in the consumer application over the network/transport connectors, and are consumed by listeners on the embedded broker in the consumer application. In AMQ 5.4.0, the name of the network connectors in the embedded broker in the producer application were not required to be unique across copies of the application, ie. for each copy of the producer application used the same name for each network connector. In AMQ 5.6.0, we receive the following error when starting a second copy of the producer application: In the producer application: Network connection between vm://producerBroker#4 and tcp://localhost/127.0.0.1:61616 shutdown due to a remote error: javax.jms.InvalidClientIDException: Broker: consumerBroker - Client: networkConnector1_producerBroker_outbound already connected from tcp://127.0.0.1:62961 In the consumer application: Async error occurred: javax.jms.InvalidClientIDException: Broker: consumerBroker - Client: networkConnector1_producerBroker_outbound already connected from tcp://127.0.0.1:62963 javax.jms.InvalidClientIDException: Broker: consumerBroker - Client: networkConnector1_producerBroker_outbound already connected from tcp://127.0.0.1:62963 at org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBroker.java:223) at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:85) at org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBroker.java:65) at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:85) at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:85) at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:85) at org.apache.activemq.security.SimpleAuthenticationBroker.addConnection(SimpleAuthenticationBroker.java:97) at org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableBrokerFilter.java:91) at org.apache.activemq.broker.TransportConnection.processAddConnection(TransportConnection.java:715) at org.apache.activemq.broker.jmx.ManagedTransportConnection.processAddConnection(ManagedTransportConnection.java:79) at org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:139) at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:292) at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:150) at org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50) at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113) at org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:229) at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83) at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:222) at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:204) at java.lang.Thread.run(Thread.java:680) Is this a regression or a new requirement. If it's a new requirement, what strategy would you recommend to ensure uniqueness in network connector names? Thanks in advance, Geoff. </pre> Geoffrey Arnold 2012-05-20T20:45:03 http://comments.gmane.org/gmane.comp.java.activemq.user/34065 <pre>Hi, I am trying to get JMSXUserID to pass from producer (client) to consumer (server) but am having no luck. My client is a .NET app using NMS V1.5.0.2194, with STOMP V1.5.2.2508. My server is a Java app using (indirectly via an internal framework) activemq-core-5.3.0. My understanding was that all I needed to do was: 1. From the client, connect to the broker using a given user name and password: this.connection = this.factory.CreateConnection(userName, password); this.session = (Session)this.connection.CreateSession(AcknowledgementMode.AutoAcknowledge); 2. Set populateJMSXUserID="true" in the broker configuration: &lt;broker useJmx="true" persistent="false" xmlns="http://activemq.apache.org/schema/core" destroyApplicationContextOnStop="true" populateJMSXUserID="true" useAuthenticatedPrincipalForJMSXUserID="true"&gt; 3. From the server, obtain the JMSXUserID from the message headers: userId = (String) headers.get("JMSXUserID"); With that in place, I was expecting to see the JMSXUserID come through server-side, but it didn't. Even though I couldn't find any documentation stating it was necessary, I then tried enabling security on the broker. I confirmed that my client and server could only connect with the credentials I set up, but still the JMSXUserID was not passed through. I noticed a number of bug reports around JMSXUserID propagation and decided to upgrade my AMQ 5.5.0 to 5.6.0. But still no joy. Am I missing something obvious here? Can anyone give me some guidance on how to get JMSXUserID to correctly propagate from my client to server? I'd prefer to have broker security disabled if possible. -- View this message in context: http://activemq.2283324.n4.nabble.com/JMSXUserID-propagation-not-working-tp4644649.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. </pre> gauche 2012-05-18T15:26:39 http://comments.gmane.org/gmane.comp.java.activemq.user/34059 <pre>We are upgrading from AMQ 5.4.0 to 5.6.0, and noticed two issues right off the bat: - The "activemq-all-5.6.0.jar" library is now bundled with the SLF4J Log4J binding, trumping the JDK 1.4 binding already in our classpath. As a workaround we have switched to using the individual libraries (activemq-core, activemq-pool, geronimo-j2ee-management, geronimo-jms, kahadb, xbean-spring); are there any other libraries we should be including? - Upon startup we are now seeing the following messages... could you point us to what settings we need to change?: "Store limit is 0 mb, whilst the max journal file size for the store is: 32 mb, the store will not accept any data when used." "Temporary Store limit is 0 mb, whilst the max journal file size for the temporary store is: 32 mb, the temp store will not accept any data when used." Finally, are there any other caveats or settings we should verify? For example, is the KahaDB log file format compatible with 5.4.0? Thanks in advance for your help, and congratulations on the release! Geoff. PS. I am happy to confirm that an issue we previously reported is indeed fixed: https://issues.apache.org/jira/browse/AMQ-2722 </pre> Geoffrey Arnold 2012-05-18T04:24:02 http://comments.gmane.org/gmane.comp.java.activemq.user/34057 <pre>We’re running *ActiveMQ 5.4.2 *in production. The last few days we’ve had clients unable to connect because of the /java.io.IOException: Too many open/ files error. We’ve been able to temporarily solve the problem by increasing the maximum heap size, however, the problem seems to come back a few days later. Do you have any suggestions how on we can more reliably solve this problem? Do we need to consider upgrading our production server? Thank you for your time in advance. John Boyer ================ ACTIVEMQ LOG OUTPUT ================ 012-05-17 14:09:36,251 | WARN | EXCEPTION | org.eclipse.jetty.util.log | qtp2112152548-3274 - Acceptor0 SelectChannelConnector&lt; at &gt;0.0.0.0:8161 java.io.IOException: Too many open files at sun.nio.ch.ServerSocketChannelImpl.accept0(Native Method) at sun.nio.ch.ServerSocketChannelImpl.accept(ServerSocketChannelImpl.java:145) at org.eclipse.jetty.server.nio.SelectChannelConnector$1.acceptChannel(SelectChannelConnector.java:74) at org.eclipse.jetty.io.nio.SelectorManager$SelectSet.doSelect(SelectorManager.java:656) at org.eclipse.jetty.io.nio.SelectorManager.doSelect(SelectorManager.java:193) at org.eclipse.jetty.server.nio.SelectChannelConnector.accept(SelectChannelConnector.java:134) at org.eclipse.jetty.server.AbstractConnector$Acceptor.run(AbstractConnector.java:793) at org.eclipse.jetty.util.thread.QueuedThreadPool$2.run(QueuedThreadPool.java:436) at java.lang.Thread.run(Thread.java:619) -- View this message in context: http://activemq.2283324.n4.nabble.com/java-io-IOException-Too-many-open-files-v5-4-2-tp4643701.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. </pre> johneboyer 2012-05-17T22:07:40 http://comments.gmane.org/gmane.comp.java.activemq.user/34052 <pre>I have a question concerning the consumption process on hierarchical queues in combination with wildcards. Defined Queues: "A.B.C.D" Subscribers subscribes to "A.B.&gt;" Now messages are published to C and D. In which order does the subscriber receive the messages? First all messages from C and then D? What happen when a pool of subscriber exists? -- View this message in context: http://activemq.2283324.n4.nabble.com/Consumption-order-on-hierarchical-queues-using-wildcards-tp4641049.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. </pre> mwessel 2012-05-16T09:05:30 http://comments.gmane.org/gmane.comp.java.activemq.user/34050 <pre>Hello, I'm having an issue when sending a number of messages that starts producer flow control between two brokers and when the networkConnector between the two is setup as duplex. The setup I have is I have two brokers, A and B. I also have two consumers on B subscribed to two topics, topic1 and topic2. I then have two producers on A which are publishing on topic1 and topic2. So when I startup the consumer on B on topic1 and have it consume messages slowly, and then I produce a large number of messages to topic1 on A so that producer flow control is triggered and the producer on A is held back from sending more because of this. I then start the consumer on topic2 on B and have it consume quickly. When I produce to topic2 on A the messages do not flow like they should. Rather they hold on the networkConnector until 5 messages make it to topic1 and then 5 messages all get sent right away to topic2. It seems like this burst of messages always matches the prefetchSize of the networkConnector. Also when I stop the consumer on topic1 all the messages being held back for topic1 gets send right away and topic1 receives messages like normal. This problematic behavior goes away when duplex="false". Can anyone provide me with any insight into why this is happening and how to get around it? P:topic1 -\ /-&gt; C:topic1 (slow) P:topic2 --&gt; A --&gt; B --&gt; C:topic2 (fast) networkConnector definition: &lt;networkConnectors&gt; &lt;networkConnector uri="static:(tcp://localhost:61617)" duplex="true" conduitSubscriptions="true" dynamicOnly="true" networkTTL="7" suppressDuplicateQueueSubscriptions="true" decreaseNetworkConsumerPriority="true" alwaysSyncSend="true" bridgeTempDestinations="true" prefetchSize="5" /&gt; &lt;/networkConnectors&gt; -- View this message in context: http://activemq.2283324.n4.nabble.com/duplex-and-producer-flow-control-tp4639822.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. </pre> Samslara 2012-05-16T02:22:56 http://comments.gmane.org/gmane.comp.java.activemq.user/34042 <pre>May 8, 2012 - Habarisoft is pleased to announce version 3.1 of its Delphi and Free Pascal client library for Apache ActiveMQ. With Habari Client for ActiveMQ, Delphi and Free Pascal developers can build integrated solutions, connecting applications using the peer-to-peer and the publish and subscribe communication model. New in this release: * support for 'client-individual' acknowledgment mode * improved chat demo, improved throughput test utility * VisualMM - FastMM4 visual memory allocation monitoring demo * Extended RTTI supression * ReceiveNoWait improvement * GUID transaction identifier * Tested with Apache ActiveMQ 5.3.2, 5.4.3, 5.5.1 and 5.6.0 Home page, documentation and demo download: http://www.habarisoft.com/habari_activemq.html Regards </pre> Michael Justin 2012-05-14T19:14:09 http://comments.gmane.org/gmane.comp.java.activemq.user/34039 <pre>hi, We are migrating from JBoss4.2.3 to JBoss6.1. We have ActiveMQ integrated in JBoss 4 and it works ok. Following this link: http://activemq.apache.org/outbound-communication.html http://activemq.apache.org/outbound-communication.html I have migrated to JBoss 6. The application is deployed correctly but when I try to send a message to a queue I get this error: Caused by: java.lang.UnsupportedOperationException: This producer can only send messages to: HomeTAOEventsQueue at org.apache.activemq.ActiveMQMessageProducer.send(ActiveMQMessageProducer.java:459) [:4.1.1] at org.apache.activemq.ActiveMQQueueSender.send(ActiveMQQueueSender.java:139) [:4.1.1] This error is thrown in the class ActiveMQMessageProducer. I have debbuged the application and when the method ActiveMQMessageProducer.send is called, it does this comparation (can't find how to tag code): public void send(Destination destination, Message message, int deliveryMode, int priority, long timeToLive) throws JMSException { checkClosed(); if (destination == null) { if( info.getDestination() == null ) { throw new UnsupportedOperationException("A destination must be specified."); } throw new InvalidDestinationException("Don't understand null destinations"); } ActiveMQDestination dest; if( destination == info.getDestination() ) { dest = (ActiveMQDestination) destination; } else if ( info.getDestination() == null ) { dest = ActiveMQDestination.transform(destination); } else { throw new UnsupportedOperationException("This producer can only send messages to: " + this.info.getDestination().getPhysicalName()); } if (dest == null) { throw new JMSException("No destination specified"); } this.session.send(this, dest, message, deliveryMode, priority, timeToLive); stats.onMessage(); } The code 'destination == info.getDestination()' returns false ! 'info.getDestination()' returns an ActiveMQQueue object instantiaded in constructor and its physicalName is 'HomeTAOEventsQueue'. 'destination' is a ActiveMQQueue passed as a parameter when calling the 'sender' method. Its physicalName is 'HomeTAOEventsQueue'. In the line I posted above, the comparision returns "false" but I don't know why ... Any help ? Thanks ! pd: I can post configuration files if needed. -- View this message in context: http://activemq.2283324.n4.nabble.com/error-This-producer-can-only-send-messages-to-in-JBoss6-with-embedded-ActiveMQ4-1-1-tp4632351.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.</pre> pepgrifell 2012-05-14T14:54:52 Search the mailing list at Gmane query http://search.gmane.org/?group=$group=gmane.comp.java.activemq.user