http://permalink.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://permalink.gmane.org/gmane.comp.java.activemq.user/34054 <pre>So I tried that and the client appears to be sending just fine, but the producer on the other side of the network connector that expects to hear back via the temp queue is not receiving the message. Chris On Wed, May 16, 2012 at 1:27 AM, Gary Tully &lt;gary.tully-Re5JQEeQqe8AvxtiuMwx3w&lt; at &gt;public.gmane.org&gt; wrote: </pre> Chris Robison 2012-05-16T17:13:41 http://permalink.gmane.org/gmane.comp.java.activemq.user/34053 <pre> mickhayes wrote Hi Michael, Yes Wireshark supports the OpenWire protocol. You need the "development version", and least version 1.7.1. Please share any findings, problems, enhancements which come to your mind… Thanks, metatech -- View this message in context: http://activemq.2283324.n4.nabble.com/Wireshark-packet-dissection-Openwire-tp4631635p4641525.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. </pre> metatech 2012-05-16T15:20:36 http://permalink.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://permalink.gmane.org/gmane.comp.java.activemq.user/34051 <pre>you need one additional bit of config, to disable the connection from tracking temp destination advisories so that it allows the request to go to the broker. factory.setWatchTopicAdvisories(false); or ?jms.watchTopicAdvisories=false on the connection factory broker url On 15 May 2012 23:30, Chris Robison &lt;chrisdrobison-Re5JQEeQqe8AvxtiuMwx3w&lt; at &gt;public.gmane.org&gt; wrote: </pre> Gary Tully 2012-05-16T07:27:50 http://permalink.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 wh</pre> Samslara 2012-05-16T02:22:56 http://permalink.gmane.org/gmane.comp.java.activemq.user/34049 <pre>I tried that last suggestion and it appears as though the allowTempAutoCreationOnSend is not working. The client keep receiving a "cannot send to a deleted destination" error. Chris On Mon, May 14, 2012 at 4:19 PM, Gary Tully &lt;gary.tully-Re5JQEeQqe8AvxtiuMwx3w&lt; at &gt;public.gmane.org&gt; wrote: </pre> Chris Robison 2012-05-15T22:30:10 http://permalink.gmane.org/gmane.comp.java.activemq.user/34048 <pre> I had tried setting that on the broker transport that the client uses, but saw zero traffic between the client and the broker. I'm guessing that it is only useful when set on the broker's end, which is what I think you're suggesting? I can't restart the broker right now, as most of my clients aren't configured to use failover yet, and they'll just die. But this Saturday, I have a maintenance window to update to the latest ActiveMQ. I'll add that then and configure my other clients to use failover. I'll look into checking via JMX. I'm very new to Java and JMS (about 3 weeks worth of experience), but learning fast. :) Thank you for your reply! -ste -----Original Message----- From: Gary Tully [mailto:gary.tully-Re5JQEeQqe8AvxtiuMwx3w&lt; at &gt;public.gmane.org] Sent: Tuesday, May 15, 2012 4:57 PM To: users-UzBZ5Px8zVWY1pf4d8vP8EB+6BGkLq7r&lt; at &gt;public.gmane.org Subject: Re: Messages not delivered after failover. the client sees the disconnect due to the firewall, but does the broker see the same disconnect? you may need </pre> shaun.t.erickson-4VXoybQyMkpl57MIdRCFDg< at >public.gmane.org 2012-05-15T21:07:01 http://permalink.gmane.org/gmane.comp.java.activemq.user/34047 <pre>the client sees the disconnect due to the firewall, but does the broker see the same disconnect? you may need to configure keep alive on the broker transport connector to ensure that it sees the client disconnect. You can check via jmx (jconsole), to verify that the consumer goes away. If it remains, then prefetched messages will still be inflight and not visible to other consumers till the connection is closed. The inflight count on the destination will also give an indication if this is the case. On 15 May 2012 20:39, &lt;shaun.t.erickson-4VXoybQyMkpl57MIdRCFDg&lt; at &gt;public.gmane.org&gt; wrote: </pre> Gary Tully 2012-05-15T20:57:28 http://permalink.gmane.org/gmane.comp.java.activemq.user/34046 <pre>One of the two issues has been resolved. The connection being reset was due to a firewall, between the broker and consumer, closing port 61616 due to inactivity. We've had the folks who maintain the firewall change its configuration so that it no longer does that. I'm still very troubled by the fact that messages could no longer be delivered after a failover event though. I very much need that to work properly. Can someone shed some light on this for me, please? -ste From: Erickson, Shaun T. Sent: Monday, May 14, 2012 2:29 AM To: 'users-UzBZ5Px8zVWY1pf4d8vP8EB+6BGkLq7r&lt; at &gt;public.gmane.org' Subject: RE: Messages not delivered after failover. (Not sure how I didn't get a subject on my initial email. Sorry.) I have noticed a pattern, since sending my previous email: the Connection reset SocketException appears to be happening every two hours, like clockwork. I have no idea why, though (yet). But it seems to me that once the connection is restored, the client should be able to receive messages again, but does</pre> shaun.t.erickson-4VXoybQyMkpl57MIdRCFDg< at >public.gmane.org 2012-05-15T19:39:52 http://permalink.gmane.org/gmane.comp.java.activemq.user/34045 <pre>I am using similar set up as described by jessezbj in the earlier post. I am having four brokers on the same machine. All the brokers have same brokername, but listen on different ports. I am not using multi-cast and auto-discovery. The problem is, if one of the broker hangs, rest of the brokers also hang. I do not get any exception in rest of the brokers or their consumers. Following is the activemq.xml that is used: [same xml is used for all the brokers by changing the ports] &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-2.0.xsd http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd http://activemq.apache.org/camel/schema/spring http://activemq.apache.org/camel/schema/spring/camel-spring.xsd"&gt; </pre> jay 2012-05-15T15:42:10 http://permalink.gmane.org/gmane.comp.java.activemq.user/34044 <pre>I will give that a shot. Thanks. But the reason I think something is wrong is that once the flooding starts, it doesn't stop until I restart the activemq service on one of the machines. The flooding occurs even if the session that created the queue is long since gone. It only takes one request-reply message to start this seeming loop between "add destination" and "remove destination". You can see that in the logs I've attached previously. It completely pegs the CPU on one machine pretty much crippling it. Mind you, at this point there are no producers and only consumers listening for new messages. The only way to stop this endless loop of messages is to restart the activemq service. I've been trying to reproduce it in different toy environments setup to be like things are in production and have been unsuccessful. I've seen the advisories going back and forth as they are logged but they don't loop endlessly like I'm seeing in production. I'm completely okay with the extra traffic caused by advisories, just </pre> Chris Robison 2012-05-14T22:53:48 http://permalink.gmane.org/gmane.comp.java.activemq.user/34043 <pre>this is expected, but the flooding impact should be minimal with a small number of brokers in the network and a reasonable number of connections. each network bridge will register interest in all temp destination advisories, so that it will be in a position to receive messages for those destinations. It can't know in advance which messages may be routed though it, so it needs to react to each advisory message and create a local temp destination. When the connection that creates the temp is closes, the temp destination gets closed and each broker reacts to that event via the remove temp advisory. Temp destinations are often pooled for serial request reply messages or multiplexed using selectors, to reduce the overhead of creation and propagation, in a network scenario. The other option is to use regular destinations for replys For temp destinations, there is an alternative solution that would require a little more configuration but which would reduce the overhead of unnecessary temp destination propagation</pre> Gary Tully 2012-05-14T22:19:04 http://permalink.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://permalink.gmane.org/gmane.comp.java.activemq.user/34041 <pre>The answer in the spirit of your short question - Yes, you can... -- View this message in context: http://activemq.2283324.n4.nabble.com/A-question-of-activemq-cpp-tp4623243p4632708.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. </pre> mikmela 2012-05-14T17:44:07 http://permalink.gmane.org/gmane.comp.java.activemq.user/34040 <pre>Evidently there is an OpenWire dissector available for WireShark, though I have not used it: https://bugs.wireshark.org/bugzilla/show_bug.cgi?id=7014 Bruce On Mon, May 14, 2012 at 1:19 AM, mickhayes &lt;mickhayes-Re5JQEeQqe8AvxtiuMwx3w&lt; at &gt;public.gmane.org&gt; wrote: </pre> Bruce Snyder 2012-05-14T15:51:53 http://permalink.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 JMSExce</pre> pepgrifell 2012-05-14T14:54:52 http://permalink.gmane.org/gmane.comp.java.activemq.user/34038 <pre>I've also tried removing the filter/selector from the receiver, and it still seems to receive nothing. I'm sure it's just something simple and dumb that has suddenly caused this problem, but I can't figure out what. -- View this message in context: http://activemq.2283324.n4.nabble.com/Messages-stuck-in-pending-tp4617979p4632003.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. </pre> Luke Noel-Storr 2012-05-14T11:22:11 http://permalink.gmane.org/gmane.comp.java.activemq.user/34037 <pre>I've added logging in the receiver and it never seems to receive the message. Messages are all auto-acknowledge. -- View this message in context: http://activemq.2283324.n4.nabble.com/Messages-stuck-in-pending-tp4617979p4631844.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. </pre> Luke Noel-Storr 2012-05-14T09:26:16 http://permalink.gmane.org/gmane.comp.java.activemq.user/34036 <pre>Hello, yes i've read this documentation the only thing i did succeed is to get a message from a queue (not a topic) using rest only if the message is sent to the queue when the rest client is active... so my question is : is the previously described scenario possible with rest and activemq? best regards Le 13/05/2012 03:00, jaskirat singh a écrit : </pre> Olivier Ziller 2012-05-14T07:23:20 http://permalink.gmane.org/gmane.comp.java.activemq.user/34035 <pre>Wondering if anyone has a wireshark plugin or similar for the OpenWire protocol that they are willing to share? ----- Michael Hayes B.Sc. (NUI), M.Sc. (DCU), SCSA SCNA -- View this message in context: http://activemq.2283324.n4.nabble.com/Wireshark-packet-dissection-Openwire-tp4631635.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. </pre> mickhayes 2012-05-14T07:19:26 http://permalink.gmane.org/gmane.comp.java.activemq.user/34034 <pre>(Not sure how I didn't get a subject on my initial email. Sorry.) I have noticed a pattern, since sending my previous email: the Connection reset SocketException appears to be happening every two hours, like clockwork. I have no idea why, though (yet). But it seems to me that once the connection is restored, the client should be able to receive messages again, but does not. If it makes any difference, the ActiveMQ 5.3.1 is running on Windows Server 2003 Enterprise Edition and the client with the 5.5.1 jars is running on Windows Server 2008 R2 Enterprise. As mentioned previously, the client consumer program is in use on several servers, where it's working fine - just this server is being persnickety. -ste From: Erickson, Shaun T. Sent: Sunday, May 13, 2012 11:18 PM To: 'users-UzBZ5Px8zVWY1pf4d8vP8EB+6BGkLq7r&lt; at &gt;public.gmane.org' Subject: I have a jms client whose consumers keep disappearing, when viewed from ActiveMQ's queue list. Either that or they appear there, but when a message is sent to the queue, th</pre> shaun.t.erickson-4VXoybQyMkpl57MIdRCFDg< at >public.gmane.org 2012-05-14T06:29:13 Search the mailing list at Gmane query http://search.gmane.org/?group=$group=gmane.comp.java.activemq.user