I also use message selector for my queue and topic.
HOWEVER, I use string properties instead of JMS properties. Maybe you can
try it.
Zim-Zam O'Pootertoot wrote
> My program is using Java 8 (Oracle JDK) and the activemq-all 5.11.1 jar.
> I
> have a persistent queue of Job ob
My program is using Java 8 (Oracle JDK) and the activemq-all 5.11.1 jar. I
have a persistent queue of Job objects, and I'm trying to cherrypick
cancelled Job objects from the queue using a message selector. However, the
cherrypick is failing:
javax.jms.Session session; // no transactions,
Here is my use case..
I have two producers sending messages to a queue and there are two consumers
on this queue.
Producer one sets a message header on the message e.g. MyName=one and
priority 8.
Producer two sets message header MyName=two and priority 6.
The consumers use message selector
is added, that could lead to some terrible performance
> scenarios.
>
> To the original use-case, can separate queues be used instead?
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Message-priority-and-message-selector-Active-MQ-version-5-4-tp4690692p4690727.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
View this message in context:
http://activemq.2283324.n4.nabble.com/Message-priority-and-message-selector-Active-MQ-version-5-4-tp4690692p4690727.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
oducer two sets message header MyName=two and priority 6.
>
> The consumers use message selector MyName="one" and MyName="two".
>
> The producers are continuously sending messages and consumers are also
> active.
>
> Lets say at certain stage, the queue has
Here is my use case..
I have two producers sending messages to a queue and there are two consumers
on this queue.
Producer one sets a message header on the message e.g. MyName=one and
priority 8.
Producer two sets message header MyName=two and priority 6.
The consumers use message selector
of applying
the selection criteria outside of AMQ)
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Message-Selector-or-Composite-Destinations-tp4687564p4687827.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
this
And each consumer is using each queue C1 -> Q1 and C2 -> Q2, and this is
working fine.
Thanks!
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Message-Selector-or-Composite-Destinations-tp4687
Not trying to ignore any possible issue here...
Is it feasible to use two different queues? One for each version.
That may be the best way to go for many reasons.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Message-Selector-or-Composite-Destinations
test, this the consumer stop to process and not start again.
If I start the consumer 2, all the messages are processed.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Message-Selector-or-Composite-Destinations-tp4687564p4687748.html
Sent from the ActiveMQ - User mailing
l consumers are back online.
On Tue, Nov 18, 2014 at 1:58 PM, juanmanuel.romeraferrio <
juanmanuel.romerafer...@gmail.com> wrote:
> I'm using version 5.10.0
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Message-Selector-or-Composite
I'm using version 5.10.0
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Message-Selector-or-Composite-Destinations-tp4687564p4687673.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
on 1 are consumed, because this consumer is ON.
>
>
>
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Message-Selector-or-Composite-Destinations-tp4687564p4687633.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
consumed and other no and stay in the
queue. This is a problem with selector, because I expected that all the
messages of Version 1 are consumed, because this consumer is ON.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Message-Selector-or-Composite-Destinations
message in context:
> http://activemq.2283324.n4.nabble.com/Message-Selector-or-Composite-Destinations-tp4687564p4687627.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
onsumer is on, consume all the messages.
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Message-Selector-or-Composite-Destinations-tp4687564p4687627.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
.
And I want that if the consumer is on, consume all the messages.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Message-Selector-or-Composite-Destinations-tp4687564p4687627.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
m> wrote:
> Hi,
>
> I'm in a trouble in my system. I have a lot of clients that send message
> with differente VERSION and I have one consumer per version that recibe
> this
> message, I'm using message selector on a only queue to do that, but I found
> a problem wh
Hi,
I'm in a trouble in my system. I have a lot of clients that send message
with differente VERSION and I have one consumer per version that recibe this
message, I'm using message selector on a only queue to do that, but I found
a problem when I sent for exmple message of 2 versions
e selector for network connector would be great. However, seems
>no such config is found on the web.
>
>
>>
>> 寄件人︰ Christian Posta
>>收件人︰ "users@activemq.apache.org" ; Raccoonwao
>>
>>傳送日期︰ 2013年03月5日 (週二) 11:13 PM
&g
Anyone else encountered the same problem?
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Static-network-connector-with-message-selector-tp4664389p4664657.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
n Posta
>收件人︰ "users@activemq.apache.org" ; Raccoonwao
>
>傳送日期︰ 2013年03月5日 (週二) 11:13 PM
>主題︰ Re: Static network connector with message selector
>
>
>Where did you add it in the NC via JMX?
>The network bridge is just a pipe. The consumers determine what will
, Mar 5, 2013 at 3:49 AM, Raccoonwao wrote:
> Hi all,
>
> I am looking for a solution to have limited message between 2
> network-connected brokers (A and B) by message selector.
>
> Only message matching selector, say, "type='car'" should goes from broker
ction
to their JMS Provider"
From: 3.8.1 "Message Selector": A JMS message selector allows a client to
specify, by message header, the messages it's interested in. *Only messages
whose headers and properties match the selector are delivered*."
We are then sent to look at
How about using Camel to create a content-based router?
http://camel.apache.org/content-based-router.html
Joe
ActiveMQ Ref Guide - http://bit.ly/AMQRefGuide
ingorfano wrote:
>
> Hi
>
> unfortunately Siebel sysytem doesn't support Message Selector, so i
> connect t
Hi
unfortunately Siebel sysytem doesn't support Message Selector, so i connect
to a Topic using JNDI properties file, but cannot filter messages out.
Question : Using permanent subscription with Selector, can i get this
around? Pratically i would like ActiveMQ to filter messages for S
t; following link:
>
> http://activemq.apache.org/selectors.html
>
>
>
> I have doubt regarding the message Selector expression:
>
>I want to know which expressions are supported by the ActiveMQ
> Message Selectors . I have tried the following Expression like
Hi,
I went through the Message Selectors concept available in the
following link:
http://activemq.apache.org/selectors.html
I have doubt regarding the message Selector expression:
I want to know which expressions are supported by the ActiveMQ
Message Selectors . I have
I'm setting the message selector for a non-persistent topic subscription at
runtime via the
ActiveMQActivationSpec.setMessageSelector and then restarting the
org.jencks.JCAConnector as follows:
...
logger.info("Setting selector to: " + selector);
activemqActivationSpec.set
I'm setting the message selector for a non-persistent topic subscription at
runtime via the
ActiveMQActivationSpec.setMessageSelector and then restarting the
org.jencks.JCAConnector as follows:
...
logger.info("Setting selector to: " + selector);
activemqActivationSpec.set
I'm setting the message selector for a non-persistent topic subscription at
runtime via the
ActiveMQActivationSpec.setMessageSelector and then restarting the
org.jencks.JCAConnector as follows:
...
logger.info("Setting selector to: " + selector);
activemqActivationSpec.set
Hi James,
Could you describe what this problem is & how to reproduce? What
version are you using? Are you hitting RAM exhaustion?
http://activemq.apache.org/my-producer-blocks.html
The issue is pretty much identical to that described here:
https://issues.apache.org/activemq/browse/AMQ-1375 AMQ-13
well. Instead of a temp quueue for each client, we are
> considering using just one permanent topic onto which we would send all
> client response data, with each client using a unique message selector to
> only get his data. What do ye think of this approach, does it make any
> sense?
clients,
which are working well. Instead of a temp quueue for each client, we are
considering using just one permanent topic onto which we would send all
client response data, with each client using a unique message selector to
only get his data. What do ye think of this approach, does it make any
sense
ource code for
NMS (see my post) and rebuilt it and selectors now seem to work for me.
Chris
--
View this message in context:
http://www.nabble.com/Message-Selector-Not-Filtering-Messages-tf3870553s2354.html#a11035767
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
g to see why the selector isn't filtering out these
> messages?
>
> As an aside, am I right in thinking you can't create non-temporary topics
> using NMS?
>
> Thanks,
>
> Jim
>
>
--
View this message in context:
http://www.nabble.com/Message-Selector-Not-Filtering-Messages-tf3870553s2354.html#a10991784
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
see why the selector isn't filtering out these
> messages?
>
> As an aside, am I right in thinking you can't create non-temporary topics
> using NMS?
>
> Thanks,
>
> Jim
>
>
--
View this message in context:
http://www.nabble.com/Message-Selector-Not-Filtering-Messages-tf3870553s2354.html#a10991517
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
essages?
>
> As an aside, am I right in thinking you can't create non-temporary topics
> using NMS?
>
> Thanks,
>
> Jim
>
>
--
View this message in context:
http://www.nabble.com/Message-Selector-Not-Filtering-Messages-tf3870553s2354.html#a10977566
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
g to see why the selector isn't filtering out these messages?
As an aside, am I right in thinking you can't create non-temporary topics
using NMS?
Thanks,
Jim
--
View this message in context:
http://www.nabble.com/Message-Selector-Not-Filtering-Messages-tf3870553s2354.html#a10965883
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
40 matches
Mail list logo
