Re: Failed to update lease Oracle connection Reset

The dbcp connection pool may return a invalid connection when you require a new connection to update the lease. Enabling the idle check for the connection pool should help. -- View this message in context: http://activemq.2283324.n4.nabble.com/Failed-to-update-lease-Oracle-connection-Reset-tp46

Re: How to filter message in virtual destinations?

You might be able to implement with a broker plugin. Have the plugin add a custom filter to the consumer based on extra data you stuff into the consumer options. Sent from my iPhone On Jun 19, 2013, at 4:34 PM, hengyunabc wrote: > For example, my message type JSON string, I just need a JSONM

Re: prefetch size variations with nms connections

Hi Ethan, Thanks for following up with your solution. Hopefully, it will help the next person, too. Best, Jim On Jun 19, 2013 5:08 AM, "Ethan Winograd" wrote: > ok I realized what we were doing wrong... > > Instead of creating a consumer from an IQueue I was creating it from an > IDestination,

Re: How to filter message in virtual destinations?

For example, my message type JSON string, I just need a JSONMessageFilter class. The filter can add or disable or change in runtime. The ActiveMQ don't need to restart. I hope that it can work like camel route. We can add/remove/configure camel route in runtime. -- View this message in context:

Re: How to filter message in virtual destinations?

So every time a new consumer comes on board, they have to create a new filter, new jar, and restart activemq? On Wed, Jun 19, 2013 at 3:54 PM, hengyunabc wrote: > What I want is different filters for each subscriber. > The consumer can define their filter class, make a jar file, place in the >

Re: How to filter message in virtual destinations?

What I want is different filters for each subscriber. The consumer can define their filter class, make a jar file, place in the ActiveMQ lib path. Producer send message to the topic "VirtualTopic.Orders". ConsumerA, queue: Consumer.B.VirtualTopic.Orders ConsumerB, queue: Consumer.B.VirtualTopic.Or

Re: Failed to update lease Oracle connection Reset

Mandar, I am facing the same issue. Did you have a solution for this? Please post the solution if you had. Thanks Pramod -- View this message in context: http://activemq.2283324.n4.nabble.com/Failed-to-update-lease-Oracle-connection-Reset-tp4662859p4668380.html Sent from the ActiveMQ - User m

Re: Scripts that generate the ActiveMQ website?

2013/6/19 Dejan Bosanac > Hi, > > can you try this link > > > https://cwiki.apache.org/confluence/createrssfeed.action?types=blogpost&spaces=ACTIVEMQ&spaces=AMQCPP&spaces=NMS&title=Apache+Software+Foundation+RSS+Feed&labelString%3D&excludedSpaceKeys%3D&sort=modified&maxResults=10&timeSpan=365&sho

Re: DemandForwardingBridge - Ignoring sub ConsumerInf

Hi Dejan, could you please also explain how the inactivity monitor and KeepAlive work? I could not make out much from the material available on Active MQ site. Thanks, mmg -- View this message in context: http://activemq.2283324.n4.nabble.com/DemandForwardingBridge-Ignoring-sub-ConsumerInf-tp

Re: DemandForwardingBridge - Ignoring sub ConsumerInf

Hi Dejan, Will setting "keepAlive=true" in the NetworkConnector on both the brokers help? Also what does the following error message means? I can see this message on one broker only. 2013-06-13 03:52:31,998 [77.225.90:37027] WARN ManagedTransportConnection - Failed to unregister mbean: org.

Re: Latest .NET libraries on Nuget

On 06/19/2013 10:52 AM, Chris Robison wrote: I noticed 1.6.0 was released. What is the timeline for getting that posted on Nuget? Chris Robison You probably need to talk to the people that own that package, don't think anyone here is involved. -- Tim Bish Sr Software Engineer | RedHat Inc. t

Latest .NET libraries on Nuget

I noticed 1.6.0 was released. What is the timeline for getting that posted on Nuget? Chris Robison

Re: Scripts that generate the ActiveMQ website?

Hi, can you try this link https://cwiki.apache.org/confluence/createrssfeed.action?types=blogpost&spaces=ACTIVEMQ&spaces=AMQCPP&spaces=NMS&title=Apache+Software+Foundation+RSS+Feed&labelString%3D&excludedSpaceKeys%3D&sort=modified&maxResults=10&timeSpan=365&showContent=true&showDiff=true&confirm=

Re: DemandForwardingBridge - Ignoring sub ConsumerInf

Hi, it looks like it's indeed a case of unstable physical connection between brokers. The message Channel was inactive for too long. org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long. means that socket is basically dead. I'd suggest you do some investigation

Re: How to filter message in virtual destinations?

Tell more about your use case. You will have the same filter for every subscriber to the virtual topic? Or different filters for each subscriber? How should the filter be specified? In advance on the broker? Or let the consumer specify? On Tue, Jun 18, 2013 at 10:27 PM, hengyunabc wrote: > Tha

activeMQ clustering (integrated with JBoss)

All, I have JBoss+activeMQ running in an integrated mode. Originally the plan was to have a single instance of JBoss running. now we plan to run this in a clustered environment. As per http://docs.jboss.org/jbossclustering/cluster_guide/5.1/html-single/#deployment.chapt I am going ahead with the

Using BlobMessage with ActiveMQ inside ServiceMix

Hello, I'm trying to send a file to another computer using ActiveMQ BlobMessages. The broker starts inside ServiceMix and the transport is: tcp://localhost:61616?jms.blobTransferPolicy.defaultUploadUrl=http://localhost:8080/temp. We always get exceptions related to the connection. Does the defaul

Re: DemandForwardingBridge - Ignoring sub ConsumerInf

Hi Dejan, Now we are not receiving any messages between these two brokers. We can see following exceptions and messages in Active MQ logs (there is one hr time difference between these two hosts). Could you please let us know the reason for these exceptions and what needs to be done to get over th

Scripts that generate the ActiveMQ website?

Hi folks, Anyone know where the scripts/CMS that generate https://svn.apache.org/repos/infra/websites/production/activemq/content/ are kept? Because I'm guessing the above is the content we see on the ActiveMQ website? I'm interested in contributing the generation of a news.xml (RSS/Atom), in a

Retained Flag in MQTT

Hi, I'm having trouble with the retained flag on mqtt. Setting retained puts a default post into a topic, so any new subscribers get that message first. Doesn't seem to work though. I'm using latest paho client and activemq version 5.9 SNAPSHOT with basic matt transport config. Anyone come across t

Re: ActiveMQ-CPP - Why can't I delete a consumer before a session commit?

On 06/19/2013 06:19 AM, cineva wrote: I'm using ActiveMQ-CPP 3.7.0. -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-CPP-Why-can-t-I-delete-a-consumer-before-a-session-commit-tp4668344p4668347.html Sent from the ActiveMQ - User mailing list archive at Nabble.com

Re: ActiveMQ-CPP - Why can't I delete a consumer before a session commit?

I'm using ActiveMQ-CPP 3.7.0. -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-CPP-Why-can-t-I-delete-a-consumer-before-a-session-commit-tp4668344p4668347.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: ActiveMQ-CPP - Why can't I delete a consumer before a session commit?

On 06/19/2013 05:50 AM, cineva wrote: If I delete a consumer before I commit a session I get an access violation error in ActiveMQConsumerKernel.cpp in ActiveMQConsumerKernel::doClose() at this line: info->setObjectId(this->consumerInfo->getConsumerId()); If this is correct behavior then what it

ActiveMQ-CPP - Why can't I delete a consumer before a session commit?

If I delete a consumer before I commit a session I get an access violation error in ActiveMQConsumerKernel.cpp in ActiveMQConsumerKernel::doClose() at this line: info->setObjectId(this->consumerInfo->getConsumerId()); If this is correct behavior then what it's a recommended way to get a lot of mes