Re: Message timestamp and clock synchronization

Thanks a lot! Do you know more options for the general set message property problem? though it is not needed for now. I would still like to know of a way. rajdavies wrote: > >> problem: >> http://old.nabble.com/How-to-set-message-property-in-broker-filter-to26362561.html > -- View this mess

Message timestamp and clock synchronization

Hi, It seems that a message gets its timestamp at the producer side. The problem is that one cannot expect a sender has its system clock synchronized with that of the servers; neither the users know how to run/turn on the clock sync services. The two consequences are 1) the time-to-live message

Re: How to set message property in broker filter

Posting the online URL of itself should help: http://old.nabble.com/How-to-set-message-property-in-broker-filter-to26362561.html Thanks a lot!! rajdavies wrote: > > sry hackingbear - I can't remember the original context of this > conversation - a little help pls! :) > &

Re: How to set message property in broker filter

f as seen in the debugger. So I still have no way to set the property at the broker level. Any other idea? Thanks rajdavies wrote: > > f you are setting a jms property - make sure messageSend.getMessage() > returns a javax.jms.Message and set the property there. It should work > O

Minimal client-side install and OSGI requirements

Hi, Up to now, we have just included the activemq-all-5.3.jar along with our client program. This JAR is pretty large. I want to see what are the minimum AMQ JARs we need to bundle instead of the big one. In addition, as the client program is written in Eclipse/OSGI, currently bundled in one of o

Re: How to set message property in broker filter

I call the setStringProperty() and setProperty() to the message parameter ('messageSend' in http://activemq.apache.org/maven/activemq-core/apidocs/org/apache/activemq/broker/BrokerFilter.html#send%28org.apache.activemq.broker.ProducerBrokerExchange,%20org.apache.activemq.command.Message%29) Are y

How to force client disconnect from broker?

Hi, To prevent client for idling too long and occupying the connection, is it possible to force the client to disconnect from the broker (e.g. through BrokerFilter)? Similar to session timeout in a HTTP server. Thanks -- View this message in context: http://old.nabble.com/How-to-force-client

How to set message property in broker filter

Hi, I have BrokerFilter that tries to set message property filter in the broker filter (so to prevent malice clients from setting bad property.) However, I tried to set the properties in the send(), preProcessDispatch(), messageDelivered() methods, but none of the properties are passed to the con

Re: Network broker and filter predicate

Well... I figure I just need to change the selector value in string form using the setSelector() instead of fooling around with this additional predicate. hackingbear wrote: > > OK, I got it to use v5 OpenWire, but the exact problem occurs in v5 as > well. > > What can I do? (L

Re: Network broker and filter predicate

OK, I got it to use v5 OpenWire, but the exact problem occurs in v5 as well. What can I do? (Looks like I can just create my own BooleanPredicate class that extends DataStructure either because I don't have a data struct type ID to use.) WARN DemandForwardingBridge Caught an exception processin

Network broker and filter predicate

Hi, In our setup, we have a backbone broker running the verbatim AMQ 5.3 and a 5.3 broker without our own BrokerFilter (gateway broker.) The gateway broker is for serving clients connecting from the Internet. One thing the broker does is to ensure only the right messages can be consumed, like:

Number of JMS connections per app server

Hi, Our server currently creates one JMS connection and then create sessions for each listener. So it means all listeners are sharing the sae connection. I believe this is the standard JMS practice. The question whether such arrangement would affect performance. i.e. could a slow listener blocks

Re: Severe performance hit upgrading to 5.2.0 from 5.1

Hi, Has anyone experienced the same sluggishness sending transacted persistent messages with AMQ 5.2 and the default ActiveMQ Persistence store? Is there any reason that it is much slower than the Kaha store? Thanks hackingbear wrote: > > Test case written, bug filed. >

AMQ Persistence vs Kaha: Re: Severe performance hit upgrading to 5.2.0 from 5.1

store, comparing to AMQ Persistence store. Thanks hackingbear wrote: > > Test case written, bug filed. > > https://issues.apache.org/activemq/browse/AMQ-2136 > > -- View this message in context: http://www.nabble.com/Severe-performance-hit-upgrading-to-5.2.0-from-5.1-tp22016698p

Re: Severe performance hit upgrading to 5.2.0 from 5.1

Test case written, bug filed. https://issues.apache.org/activemq/browse/AMQ-2136 -- View this message in context: http://www.nabble.com/Severe-performance-hit-upgrading-to-5.2.0-from-5.1-tp22016698p22141040.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Prefetch=0 how to?

The latest codes in the SVN still seems to receive from two receivers. Maybe I miss something? Anyway, I have written a test case which depends on nothing but AMQ. I was using 5.1 and this bug shows up in 5.1; I tried running it in 5.2 for several times, and it always works. [What prevents me fro

Re: Prefetch=0 how to?

o be working fine. Can you try modifying it to > reproroduce the problem? BTW. What version are you using? > > > Cheers > -- > Dejan Bosanac > > Open Source Integration - http://fusesource.com/ > ActiveMQ in Action - http://www.manning.com/snyder/ > Blog - http://www.nigh

Re: Severe performance hit upgrading to 5.2.0 from 5.1

Hi, any help on this? 5.2 shouldn't be a few times slower, but I can't find out why. All the other configs are out-of-box defaults. hackingbear wrote: > > Hi, > > I upgraded to 5.2.0 last week and witness my application performance > dropped substantially. I wrote

Re: Prefetch=0 how to?

sorry, a small correction: hackingbear wrote: > > - Server 1 receives user message 2, and so try to get a token, get token > B, but get stuck. > I meant: - Server 1 receives user message 2, and so try to get a token, but get stuck. token B never arrives -- View this messag

Prefetch=0 how to?

Hi, I have two server components in my system. A gateway server and multiple application server. The gateway server communicates with external system and does the following: 1. receive tokens from the external system and place them in a queue (the token queue.) 2. receive business requests from

Severe performance hit upgrading to 5.2.0 from 5.1

Hi, I upgraded to 5.2.0 last week and witness my application performance dropped substantially. I wrote a simple test which does: producer: loop create a temporary reply queue send a short object message to a non-persistent, non-durable queue read from reply queue delete the re

EOFException on idling listener in ActiveMQ 5.0.0

Ever since I switched over to 5.0.0, I got these EOF exception when I start a listener but do not do anything with it. This does not happen in 4.1. Is this a bug in 5.0? thx ERROR Server [AcitveMQ Connection Worker: tcp://localhost/127.0.0.1:61616|] JMS connection received asynchronous ex