Re: Wierd skipping of messages using Websocket/activeMQ

I should say this behavior is also seen in the supplied demo websocket app. -- View this message in context: http://activemq.2283324.n4.nabble.com/Wierd-skipping-of-messages-using-Websocket-activeMQ-tp4680230p4680246.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Behavior when a message expires while it is processing

Hi, I am trying to understand the behavior when a message expires while it is being processed. I have the following flow setup in my test program. queue.start -> sleepProcessor -> queue.end The sleepProcessor takes the message from queue.start and sleeps for 5 seconds. I send a message to queue.

Wierd skipping of messages using Websocket/activeMQ

Hi all, First-time poster. I am using ActiveMQ 5.7.0 and the standard conf/activemq.xml file with websockets: I have modified the websocket web chat demo for an app I am building. I have it working, however there is a strange behavior. If I start the activeMQ server and co

Integrating ActiveMQ with Jetty 9.1 for websocket support

Hi, I am exploring various technologies in order to build a real-time web application. My current thinking is to use Jetty 9.1 as the app server and embedded ActiveMQ as the messaging broker. I want to take advantage of the JSR-356 websocket support in Jetty 9 with STOMP as the sub-protocol. Bu

Re: why apollo 1.7 only support openwire version 8?

thanks. but why the latest version don't support newer version, what's new in v9 and v10? On Fri, Apr 11, 2014 at 10:06 PM, Timothy Bish wrote: > On 04/11/2014 08:01 AM, Li Li wrote: >> >> I am using activemq 5.9's jar files. how to let server support higher >> version such as v9 or v10? >> >> Ex

Re: why apollo 1.7 only support openwire version 8?

On 04/11/2014 08:01 AM, Li Li wrote: I am using activemq 5.9's jar files. how to let server support higher version such as v9 or v10? Exception in thread "main" javax.jms.JMSException: Invalid version: 8, could not load org.apache.activemq.openwire.v8.MarshallerFactory at org.apache.ac

Re: Lengthy delays when using ActiveMQ Ajax Client

It doesn't sound right. Any chance you can write a test case for that and submit a Jira? https://github.com/apache/activemq/blob/trunk/activemq-web-demo/src/test/java/org/apache/activemq/web/AjaxTest.java Also, did you consider using WebSockets, as they are much better suit for this in-browser ki

Re: Messages not received after setting the topicPrefetch

Maybe some combination of constantPendingLimitStrategy and perfetch doesn't work well. Maybe you can try configuring prefetchRatePendingMessageLimitStrategy as explained here http://activemq.apache.org/slow-consumer-handling.html It'd be good to have a test case for this, to investigate further.

Re: non-durable topics & persistent messages

inline... > If I send a *persistent* message to a *non-durable* topic ( and topic > doesn't have durable consumers ), > > - is the message stored into database before sending non-durable subscribers ? no > - is an ACK sent to producer in anytime ? immediately > > So, what is persistent delivery m

why apollo 1.7 only support openwire version 8?

I am using activemq 5.9's jar files. how to let server support higher version such as v9 or v10? Exception in thread "main" javax.jms.JMSException: Invalid version: 8, could not load org.apache.activemq.openwire.v8.MarshallerFactory at org.apache.activemq.util.JMSExceptionSupport.create(J

Configuring Transports HTTPS. WINDOWS 7

ActiveMQ.xml: ... https://0.0.0.0:61620?maximumConnections=1000&wireformat.maxFrameSize=104857600"/> Follow activeMQ manual + libraries:xpp3_min- .jar and xmpull- .jar Add java code://For SSL Properties systemProps = System.getProperties();

Re: Persist Last Image

take at peek at http://activemq.apache.org/subscription-recovery-policy.html there is a nice (if trivial) custom example at https://github.com/apache/activemq/blob/20f384ce59b758a0f3c1b0e0620e2efd58ca230a/activemq-unit-tests/src/test/java/org/apache/activemq/test/retroactive/RetroactiveConsumerWit

how to get queue size from java/c++ client using openwire protocol in apollo?

I used to use activemq 5.9 and now want to switch to apollo. but I used to use Statistics Plugin to get queue size.