Re: Killing activemq with connected JMS listener

You've registered a JMS ExceptionListener with the Connection ? On 18 Mar 2009, at 18:06, mffrench wrote: must add I tested the same code with other queuers (QPID, ...) and I get exception with these queuers ... mffrench wrote: yes my client is connected... and it only receive message (

Re: Killing activemq with connected JMS listener

Where are you suggesting an exception is thrown with no ExceptionListener ? On 19 Mar 2009, at 10:02, mffrench wrote: With ExceptionListener it's working well ! :) Anyway I think you should get this exception without any ExceptionListener ! javax.jms.JMSException: java.io.EOFException

Re: ActiveMQ 5.2 - broker stops sending messages

This looks similar to a known issue - AMQ-2009 - can you try the latest 5.3 snaphot ? cheers, Rob Rob Davies http://fusesource.com http://rajdavies.blogspot.com/ On 23 Mar 2009, at 19:53, Ron Reynolds wrote: i know it's a vague subject line and i'm almost certain it'

Re: Messages getting Stuck

y out a Fuse Message Broker version - its free, Apache licensed and built from Apache ActiveMQ (and any issues fixed by FUSE go back into Apache ActiveMQ too). If you still have problems - just shout louder :) cheers, Rob Rob Davies http://fusesource.com http://rajdavies.blogspot.com/

Re: Listeners consumerEventSource small precisions ...

Hi Eric-AWL On 20 Apr 2009, at 10:01, Eric-AWL wrote: Hi everybody I continue previous thread which describes how to use Advisory package and ConsumerEventSource.setConsumerListener. I will be in a network of brokers configuration where consumers are not directly created on the current

Re: Active MQ broker embedded with spring configuration problems

Thanks Andrew! On 6 May 2009, at 15:33, ee7arh wrote: Please also fix this page too: http://activemq.apache.org/networks-of-brokers.html Order should be: networkConnectors persistenceAdapter transportConnectors Bregards Andrew Gary Tully wrote: Hi Andrew, thanks. No need to raise a jira

Re: timeout parameter when amq gets max queue size

You should set the sendTimeout parameter on your ConnectionFactory cheers, Rob On 6 May 2009, at 12:40, liquidd wrote: I have amq (pure master-slave) with queue limit 1 mb. Queue A reaches that limit, so QueueSender.send method hungs. I set timeout parameter, but it looks like doesn't

Re: too many open files

more detail about your setup ?: How much memory did you allocate for your broker? What version of ActiveMQ are you running ? Are you using Topics or Queues ? Do you need the Queue messages to be persistent ? cheers, Rob Rob Davies http://fusesource.com http://rajdavies.blogspot.com/

Re: too many open files

thanks Arjen - need to get add a Faq entry for this! On 11 May 2009, at 06:51, Arjen van der Meijden wrote: There may be at one or more of these three issues that I ran into: - You actually have a too low setting for the open files. Try increasing it (see man ulimit etc, be careful that norm

Re: Restoring ActiveMQ

It can take a while - how long have you left it for ? On 13 May 2009, at 13:41, liquidd wrote: AMQ have more than 1.5M messages. After shutdown and restart amq it writes: jvm 1| INFO DefaultCamelContext- JMX enabled. Using InstrumentationLifecycleStrategy. jvm 1| INFO

Re: Publishing to Topic is very slow in higher loads ActiveMQ5.2.

Looks like you've heat a flow contorl problem - try disabling it - see http://activemq.apache.org/producer-flow-control.html cheers, Rob On 14 May 2009, at 11:33, KumarR wrote: Hi All , I am having problem with publishing messages to Topic. It's taking too much time to publish a messag

Re: a question about TTL(time to live) ...?

Unfortunately not in the current release - though using a Queue browser will have the same result - in forcing expired messages to be removed On 15 May 2009, at 08:55, angel7 wrote: thank you for your kind So, Isn't there how to remove automatically the message in queue after ttl , un

Re: Stomp support for implict creation of temporary destinations

list archive at Nabble.com. Best way to get started is to submit some patches - see http://activemq.apache.org/becoming-a-committer.html All contributions are gratefully received! cheers, Rob Rob Davies http://fusesource.com http://rajdavies.blogspot.com/

Re: too many open files

Are you sure you upped the max number of fds allowable per process ? On 18 May 2009, at 01:23, DataMover wrote: After a week of fighting with it, no matter what was done, we could not get it to work. We created a simple test, creating 1000 producers sending one message to 1000 queues.

Re: How to know whether embedded broker is stoped?

://activemq.apache.org/how-do-i-restart-embedded-broker.html basically call waitUntilStopped() after calling stop() on the broker cheers, Rob Rob Davies http://fusesource.com http://rajdavies.blogspot.com/

Re: Durable Subscriber and unclean disconnection

Have you disabled the maxInactivityDuration by setting it to zero ? If you have - your broker may not detect the transport socket has expired - and cleanly closed the connection. See - http://activemq.apache.org/configuring-wire-formats.html cheers, Rob On 18 May 2009, at 10:32, lyall wrote:

Re: Large number of queues (HowTo)

Awesome! - thanks for getting this info together! will put this on the Apache site On 18 May 2009, at 19:27, Jose Luna wrote: Hello, We have the requirement of creating a very large number of queues (tens of thousands) in a single broker. My searches turned up several others trying to

Re: Durable Subscriber and unclean disconnection

I should have explained - that although this is client-side configuration - there is a handshake between the client and broker on initialization. The lowest value of maxInactivityDuration is used by both peers of the transport (client and broker). So if your client bounced - or the network

Re: Concurrent message processing

Use more than one Session - or put the messages in a BlockingQueue and use a thread pool to process them concurrently Rob Davies Sent from my iPhone On 28 May 2009, at 05:38, Deepak Agrawal wrote: I am using activeMQ 5.1 and I want my consumer to process my message asynchronously

Re: JMSMessageID

ageID-tp23771041p23771041.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. The JMSMessageID is unique for every message in ActiveMQ cheers, Rob Rob Davies http://fusesource.com http://rajdavies.blogspot.com/

Re: Why do persistent messages exhaust memory and lock out consumers?

which version are you using ? On 11 Jun 2009, at 01:48, Elliot Barlas wrote: Scenario: -Minimal AMQ message broker with persistence enabled and default usage values of 64 MB memory limit, 10 GB temp store limit, and 100 GB persistent store limit -AMQ producer client sending 100 KB persistent

Re: NullPointerException in AMQMessageStore.addMessage in AMQ 5.2

Did you raise an issue - with stack trace ? On 12 Jun 2009, at 22:42, jydev wrote: Hi I posted this a while back and we are still having this issue. It seems happen only when there is "large" load, meaning maybe 1500-2500 messages in the queue. So my guess is we might be hitting some r

Re: How to get first 100 messages in the queue into an array

Well - the OOM must be a bug - will try it out on the latest On 17 Jun 2009, at 21:57, Vuppala wrote: I am using ActiveMQ-5.2.0. I have a scenario like, Queue can have a lot more than 100,000 messages. So, I am afraid I get OutOfMemory error if I tried to move them to a different queue in

Re: ActiveMQ.Advisory.Expired.Queue question

Nabble.com. Advisories are sent over topics - are you subscribing to a topic ? cheers, Rob Rob Davies http://fusesource.com http://rajdavies.blogspot.com/

Re: ActiveBlaze with .NET

Hi Todd, will be a while before we get round to doing a .NET client for blaze - we want to stabilize the Java client first cheers, Rob On 7 Jul 2009, at 05:04, tnine wrote: Hi all, I've recently had to pick up an existing .NET project. It's in C# 3.5. It's far too large to convert t

Re: ActiveBlaze with .NET

That would be great! Rob Davies Sent from my iPhone On 7 Jul 2009, at 10:01, tnine wrote: I'm still evaluating messaging systems, but this seems to be very close to what we need. Would it be possible for me to contribute .Net clients to this project? rajdavies wrote: Hi Todd,

Re: ActiveMQBrowser version 2.5.1 (GPLv2) has been released

done On 12 Jul 2009, at 21:45, Jose Luna wrote: Nice work. I wasn't aware that ActiveMQBrowser was an option for monitoring/administrationg activemq. Could someone with wiki access add this to the list at: http://activemq.apache.org/how-can-i-monitor-activemq.html JLuna - Origina

Re: AMQ Client/Server Compatibility

No - you need to update to version 4 (preferably 5) On 13 Jul 2009, at 19:02, Michael Dehmlow wrote: Does AMQ 2.2.6 Client work with AMQ 5.2 Server? -- View this message in context: http://www.nabble.com/AMQ-Client-Server-Compatibility-tp24466475p24466475.html Sent from the ActiveMQ - User ma

Re: AMQ Client/Server Compatibility

Ah - was referring to the Java client 4.x/5.x On 13 Jul 2009, at 20:48, Michael Dehmlow wrote: Are you talking AMQ client 2.4.x or 2.5.x or the client contained AMQ Package 4.x or 5.x? rajdavies wrote: No - you need to update to version 4 (preferably 5) On 13 Jul 2009, at 19:02, Michael

Re: Is it possible to have multiple queue receivers listening on the same queue, using message selectors (typically filtering on a correlation ID) to determine which listener actually receives the mes

Yes it does! On 14 Jul 2009, at 23:29, Dan Tran wrote: Hi does ActiveMQ supports this feature? Thanks -D -- View this message in context: http://www.nabble.com/Is-it-possible-to-have-multiple-queue-receivers-listening-on-the-same-queue%2C-using-message-selectors-%28typically-filtering-on-a

Re: Weird log message from stdout

some details on version/config may help ;) On 19 Jul 2009, at 17:01, Dan Tran wrote: Hello, I am seeing the following message on stdout Conn: 172.30.63.41.42867.090709212649 SYSSH200 qasj04 for each StreamMessage received and 172.30.63.41 is another host that has nothign to do with my

Re: send hangs using vm://

Hi Dan, can you try the latest snapshot ? - this looks like you've hit a resource limit (memory) and/or a bug thanks, Rob On 20 Jul 2009, at 02:42, Dan Tran wrote: Any one with an answer for this question? from reading activemq doc and forum, the lockup is understandable, how it wha

Re: Slow consumers slow down fast consumer queue requests

Does this behaviour change if you use the latest snapshot ? thanks, Rob On 20 Jul 2009, at 03:51, mquestioner wrote: Hi, We have a case where a consumer connected through a slow connection would slow down the fast consumer. I have already http://activemq.apache.org/slow-consumers.html and

Re: Windows clustered CIFS server as shared filesystem for ActiveMQ

orted it should work - if its going to fail - it will fail quickly (within a few minutes). Please let us know if it works! cheers, Rob Rob Davies http://fusesource.com http://rajdavies.blogspot.com/

Re: Windows clustered CIFS server as shared filesystem for ActiveMQ

Don't use journaledJDBC - just JDBC - or KahaDB - or the default (AMQPersistenceAdaptor) On 21 Jul 2009, at 17:57, Eric Gearhart wrote: On Mon, Jul 20, 2009 at 11:46 AM, Rob Davies wrote: Hi Eric, I'm not aware of anyone who has done this - but if flock() is supported it s

Re: WARN [org.apache.activemq.usage.Usage] - . Is it nessessary?

this message in context: http://www.nabble.com/WARN--org.apache.activemq.usage.Usage%3CMemory-usage-is-now-at-100-%3E.--Is-it-nessessary--tp24609194p24609194.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. Rob Davies I work here: http://fusesource.com My Blog: http

Re: WARN [org.apache.activemq.usage.Usage] - . Is it nessessary?

mailing list archive at Nabble.com. Rob Davies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/ -- View this message in context: http://www.nabble.com/WARN--org.apache.activemq.usage.Usage%3CMemory-usage-is-n

Re: destinationURI parameter is not work(priority,exclusive)

,true); firstCustomer.run(); secondCustomer.run(); thirdCustomer.run(); } } -- View this message in context: http://www.nabble.com/destinationURI-parameter-is-not-work%28priority%2Cexclusive%29-tp24691751p24691751.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. Rob Davies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/

Webinar this Thursday on trading performance and reliability for ActiveMQ

417&sessionid=1&key=E98BDE2DC3E34FAB67E8BE2FF0B43DC6&sourcepage=register cheers, Rob Rob Davies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/

Re: How to (automatically) activate Discarding DLQ Broker PLugin

't want expired messages in your DLQ - just set the property on the dead letter strategy - processExpired = false cheers, Rob Rob Davies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/

Re: How to (automatically) activate Discarding DLQ Broker PLugin

tem without web console interaction ? Moreno Yes - it should be in 5.3 - see http://issues.apache.org/activemq/browse/AMQ-1112 cheers, Rob Rob Davies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/ rajdavies wrote

Re: NMS PrefetchSize=0

.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. Rob Davies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/

Re: ActiveMQ.Advisory.Connection messages includes username and password

work around without extending an existing AuthenticationBroker (same package as AuthenticationPlugins) to copy the ConnectionInfo - remove the username/password from the copy and pass the copy through the BrokerFilter chain (super.addConnection()); cheers, Rob Rob Davies I work here: ht

Re: How to (automatically) activate Discarding DLQ Broker PLugin

Q-Broker-PLugin-tp24695829p24695829.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. As an aside - if you don't want expired messages in your DLQ - just set the property on the dead letter strategy - processExpired = false cheers, Rob Rob Davies I work here: http://fu

Re: ActiveMQ.Advisory.Connection messages includes username and password

sed. I'm going to assume that removing at least the password that early isn't going to affect brokers further down the stack. Mats Shouldn't do! cheers, Rob Rob Davies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/

Re: Standalone server restarting itself every 5 minutes - java.lang.IllegalStateException

be appreciated, as I'm totally stumped as to why the server keeps restarting itself. Our message content hasn't changed, so why would the EOF file errors or "channel inactive" errors be happening?? Thanks, Gary -- View this message in context: http://www.nabble.com/Stand

Re: 2 small questions on wildcards usage.

;queue.A,queueB" cheers, Rob Rob Davies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/

Re: Dynamically change the network connectors caracteristics in embedded brokers

ve at Nabble.com. Much sucking of teeth - I would think you can get away with stopping and then restarting the network connector for your embedded broker cheers, Rob Rob Davies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/

Re: Choose Stomp instead of OpenWire

e.g. do you have: inside your broker config (or something similar)? Rob Davies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/

Re: Standalone server restarting itself every 5 minutes - java.lang.IllegalStateException

quot; errors be happening?? Thanks, Gary -- View this message in context: http://www.nabble.com/Standalone-server-restarting-itself-every-5-minutes---java.lang.IllegalStateException-tp24727769p24727769.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. Rob Davies I

Re: 2 small questions on wildcards usage (MORE)

155p24752803.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. cheers, Rob Rob Davies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/

Re: Standalone server restarting itself every 5 minutes - java.lang.IllegalStateException

ed, so why would the EOF file errors or "channel inactive" errors be happening?? Thanks, Gary -- View this message in context: http://www.nabble.com/Standalone-server-restarting-itself-every-5-minutes---java.lang.IllegalStateException-tp24727769p24727769.html Sent from the ActiveMQ - Us

Re: New Broker plugin : Enforcing persistence mode

context: http://www.nabble.com/New-Broker-plugin-%3A-Enforcing-persistence-mode-tp24758167p24758167.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. Rob Davies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/

Re: Full Duplex Network of brokers and number of connections questions.

r 4 ? Eric-AWL -- View this message in context: http://www.nabble.com/Full-Duplex-Network-of-brokers-and-number-of-connections-questions.-tp24758942p24758942.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. Rob Davies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/

Re: automatically connecting to secondary when primary fails

ntext: http://www.nabble.com/automatically-connecting-to-secondary-when-primary-fails-tp24762123p24762123.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. if the primary fails - activemq will automatically failover for you - you shouldn't need to do anything cheers,

Re: New Broker plugin : Enforcing persistence mode

8167.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. Rob Davies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/ -- View this message in context: http://www.nabble.com/New-Broker-p

Re: right way to send and receive messages in a BrokerPlugin

s a right way to do things as per my last email in this thread. Regards, Mats Henrikson Hi Mats, the way you described setting up the internal consumers/producers using JMS constructs and vm:// transport is the correct way to implement what you are trying to do cheers, Rob Rob Davie

Re: Total Message Order of Queues (not topics) durring edge cases(crashes)

ordering may be violated for consumer crashes with the default prefetch sizes - see http://activemq.apache.org/what-is-the-prefetch-limit-for.html to reduce this possibility to a single message - set a prefetch size = 0. cheers, Rob Rob Davies I work here: http://fusesource.com My Blog: http

Re: Duplex Network Connector and Firewalls

User mailing list archive at Nabble.com. When duplex is enabled - the single connection is used by the local and remote broker. So to get through firewalls - only the brokers outside the firewall should create the network connection - and mark it as duplex cheers, Rob Rob Davies I work h

Re: Duplex Network Connector and Firewalls

de the firewall should create the network connection - and mark it as duplex cheers, Rob Rob Davies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/ -- View this message in context: http://www.nabble.com/Duplex-N

Re: failover in C++ CMS

e.com/failover-in-C%2B%2B-CMS-tp24780179p24845030.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. Rob Davies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/

Re: Total Message Order of Queues (not topics) durring edge cases(crashes)

e message - set a prefetch size = 0. cheers, Rob Rob Davies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/ -- View this message in context: http://www.nabble.com/Total-Message-Order-of-Queues-%28not-to

Re: How to tell if everything in a queue has been processed

list archive at Nabble.com. You can either use JMX - as the old post suggested - or enable message consumed advisory - to get informed out when a message has been consumed from the queue - see http://activemq.apache.org/advisory-message.html cheers, Rob Rob Davies I work here:

Re: conduit subscriptions

for the Queue network. cheers, Rob Rob Davies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/

Re: Could not locate data file data-queue-data-X

/Could-not-locate-data-file-data-queue-data-X-tp25239114p25239114.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. Rob Davies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/

Re: Producers hang under load with AMQ 5.2

archive at Nabble.com. -- View this message in context: http://www.nabble.com/Producers-hang-under-load-with-AMQ-5.2-tp25251841p25255812.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. Rob Davies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/

Re: Getting negative number of pending messages

mailing list archive at Nabble.com. It would be great to know if you still had the problem on the latest 5.3 snapshot too cheers, Rob Rob Davies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/

Re: Getting negative number of pending messages

sages-tp22106707p25295148.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. It would be great to know if you still had the problem on the latest 5.3 snapshot too cheers, Rob Rob Davies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing

Re: can't get simple Network of Brokers to work

ge in context: http://www.nabble.com/can%27t-get-simple-Network-of-Brokers-to-work-tp25303503p25303503.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. Can you post your the config for your brokers ? cheers, Rob Davies I work here: http://fusesource.com My Blog: http://rajdavi

Re: Message Integrity

Open Source Integration http://fusesource.com/ -- View this message in context: http://www.nabble.com/Message-Integrity-tp25363310p25364489.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. Rob Davies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com

Re: AMQ - MSMQ bridge ... possible?

ke the AMQ-MSMQ bridge work? -vezee -- View this message in context: http://www.nabble.com/AMQ---MSMQ-bridge-...-possible--tp25353204p25366925.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. Rob Davies I work here: http://fusesource.com My Blog: http://rajdavies.

Re: Getting negative number of pending messages

relatively quickly. -- View this message in context: http://www.nabble.com/Getting-negative-number-of-pending-messages-tp22106707p25295148.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. It would be great to know if you still had the problem on the latest 5.3 snapshot

Re: How can ActiveMQ help with our scenario?

reliably consume messages using JMS apis such that I'm not forced to do all the work in the delivery thread but I still can accurate keep track of what's been worked on and what's been processed such that I can recover the consumer from an outage without lose of messages? Rob Da

Re: Embedding activeMQ stops automatically

ssage in context: http://www.nabble.com/Embedding-activeMQ-stops-automatically-tp25373857p25373857.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. Rob Davies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/

Re: Transactional message consumption

ssage in context: http://www.nabble.com/Transactional-message-consumption-tp25374091p25374091.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. Rob Davies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/

Re: How to tell if everything in a queue has been processed

s message in context: http://www.nabble.com/How-to-tell-if-everything-in-a-queue-has-been-processed-tp24887648p25385340.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. Rob Davies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/

Re: error in subscribing topic

cribe to a Topic "STOCKS.SUNW". However, all destinations by default are dynamic - so you just have to change: javax.jms.Topic mytopic = (javax.jms.Topic) ctx.lookup("STOCKS.SUNW"); //error is from here for javax.jms.Topic mytopic = session.createTopic("STOCKS.SUNW&

Re: Retroactive Consumer on Virtual Topics

, Rob Rob Davies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/

Re: error in subscribing topic

On 13 Sep 2009, at 17:10, czy11421 wrote: Rob Davies wrote: On 12 Sep 2009, at 23:53, czy11421 wrote: I am running ActiveMQ 5, in the admin web page, I could see "STOCKS.SUNW" in Topics, and this topic is sending out message, then how could I subscribe this topic and get the

Re: error in subscribing topic

n the same subscriber after calling receive() - its best to create a new session for each new subscriber cheers, Rob Rob Davies twitter.com/rajdavies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/

Re: error in subscribing topic

On 13 Sep 2009, at 20:03, czy11421 wrote: Rob Davies wrote: On 13 Sep 2009, at 17:55, czy11421 wrote: Rob, Thanks for your reply. Here is another question. If I use MessageListener, how could I start to receive message ? Coding as below, the Listener will NOT output message. Did I

Re: error in subscribing topic

On 14 Sep 2009, at 00:00, czy11421 wrote: Rob Davies wrote: On 13 Sep 2009, at 20:03, czy11421 wrote: Rob Davies wrote: On 13 Sep 2009, at 17:55, czy11421 wrote: Rob, Thanks for your reply. Here is another question. If I use MessageListener, how could I start to receive message

Re: i have a problem about Topic

r configuration ? Does each user have a separate connection ? - how much memory are you allowing the JVM to have ? cheers, Rob Rob Davies http://twitter.com/rajdavies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/

Re: Use of jndi.properties with activemq?

ookup 2009/09/13 21:35:43 ERROR - jmeter.threads.JMeterThread: Test failed! java.lang.ClassCastException: org.apache.activemq.jndi.ReadOnlyContext cannot be cast to javax.jms.Queue Yes - if it can find it on its classpath - see http://activemq.apache.org/jndi-support.html cheers, Rob

Re: i have a problem about Topic [re-question : detail info]

oker-.html Certainly use nio:// transport - and I'd recommend looking at Kahadb - http://activemq.apache.org/kahadb.html with a 5.3-SNAPSHOT cheers, Rob Rob Davies http://twitter.com/rajdavies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: ht

Re: Use of jndi.properties with activemq?

On 15 Sep 2009, at 01:29, Robert Nicholson wrote: Ok I spotted one mistake and that was that I had receive queue and not request queue populated in my Point to Point setup. Now I see messages in my queue. Eureka !!! On Sep 14, 2009, at 8:36 AM, Rob Davies wrote: On 14 Sep 2009, at 14:27

Re: Duplicate Messages on Listener Restart

9&5R\"F)R=6-E+G-N>61EG;6%I;\"YC;VT*" );' ActiveMQ in Action: http://bit.ly/2je6cQ Blog: http://bruceblog.org/ Twitter: http://twitter.com/brucesnyder I think the main thing to note is to not use fanout:// transport for consumers - its for producers only cheer

Re: Messages left on the queue when using a transacted session.

provide a test case ? cheers, Rob Rob Davies http://twitter.com/rajdavies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/

Re: Messages left on the queue when using a transacted session.

On 15 Sep 2009, at 07:33, Robert Nicholson wrote: On each occasion when I notice messages are no longer being delivered. If I restart my app after restarting the broker the messages begin to deliver. On Sep 15, 2009, at 12:56 AM, Rob Davies wrote: On 15 Sep 2009, at 06:42, Robert

Re: Duplicate Messages on Listener Restart

context: http://www.nabble.com/Duplicate-Messages-on-Listener-Restart-tp25440673p25451637.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. just use a normal url for the consumers - not a fanout one. Rob Davies http://twitter.com/rajdavies I work here: http://fusesource.com My

Re: Duplicate Messages on Listener Restart

.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. Ah - missed that - assumed that TIPServer was producing for some reason. Can you create a jira and attach a test case ? Will make it quicker to work out what the issue is thanks Rob Davies http://twitter.com/rajdavies I

Re: Messages left on the queue when using a transacted session.

On Sep 15, 2009, at 2:40 AM, Rob Davies wrote: On 15 Sep 2009, at 07:33, Robert Nicholson wrote: On each occasion when I notice messages are no longer being delivered. If I restart my app after restarting the broker the messages begin to deliver. On Sep 15, 2009, at 12:56 AM, Rob Davies

Re: ActiveMQ creates lots of processes and then hangs

DataQueue'. Any help would be greatly appreciated. Minz -- View this message in context: http://www.nabble.com/ActiveMQ-creates-lots-of-processes-and-then-hangs-tp25540571p25540571.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. Rob Davies http://twitter.com/rajdavies

Re: Problems with cpu load and io

ing list archive at Nabble.com. Rob Davies http://twitter.com/rajdavies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/

Re: Getting negative number of pending messages

of-pending-messages-tp22106707p25575327.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. Rob Davies http://twitter.com/rajdavies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/

Re: ActiveMQ Failover exception

va: 208) at org .apache .activemq .broker.region.AbstractRegion.acknowledge(AbstractRegion.java:377) -- View this message in context: http://www.nabble.com/ActiveMQ-Failover-exception-tp25604966p25604966.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. Rob Davie

Re: Version 5.3.0 ?

t from the ActiveMQ - User mailing list archive at Nabble.com. Rob Davies http://twitter.com/rajdavies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/

Re: ActiveMQ Usage

archive at Nabble.com. cheers, Rob Rob Davies http://twitter.com/rajdavies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/

Re: undesirable activemq-data directory

Nabble.com. I'm not seeing any directories created with persistent=false on the latest 5.3 SNAPSHOT ? cheers, Rob Rob Davies http://twitter.com/rajdavies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/

Re: ActiveBlaze

probably be released early 2010 - if there's interest - maybe earlier ;) cheers, Rob Rob Davies http://twitter.com/rajdavies I work here: http://fusesource.com My Blog: http://rajdavies.blogspot.com/ I'm writing this: http://www.manning.com/snyder/

  1   2   3   4   5   6   7   8   9   >