You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@camel.apache.org by "Willem Jiang (JIRA)" <ji...@apache.org> on 2010/03/08 11:19:45 UTC
[jira] Created: (CAMEL-2529) ConsumerTemplate don't support the jms
uri with selector
ConsumerTemplate don't support the jms uri with selector
--------------------------------------------------------
Key: CAMEL-2529
URL: https://issues.apache.org/activemq/browse/CAMEL-2529
Project: Apache Camel
Issue Type: Bug
Components: camel-jms
Affects Versions: 2.2.0, 2.1.0, 2.0.0
Reporter: Willem Jiang
Assignee: Willem Jiang
Fix For: 2.3.0
This unit test can shows the issue that selector option don't work for ConsumerTemplate
{code}
@Test
public void testConsumerTemplate() throws Exception {
template.sendBodyAndHeader("activemq:queue:consumer", "Message1", "SIZE_NUMBER", 1505);
template.sendBodyAndHeader("activemq:queue:consumer", "Message3", "SIZE_NUMBER", 1300);
template.sendBodyAndHeader("activemq:queue:consumer", "Message2", "SIZE_NUMBER", 1600);
// process every exchange which is ready. If no exchange is left break
// the loop
while (true) {
Exchange ex = consumer.receiveNoWait("activemq:queue:consumer?selector=SIZE_NUMBER<1500");
if (ex != null) {
Message message = ex.getIn();
int size = message.getHeader("SIZE_NUMBER", int.class);
assertTrue("The message header SIZE_NUMBER should be less than 1500", size < 1500);
assertEquals("The message body is wrong", "Message3", message.getBody());
} else {
break;
}
}
}
{code}
And here is [mail thread|http://old.nabble.com/activemq-component-and-selector-ts27813752.html] which discusses about it.
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
[jira] Resolved: (CAMEL-2529) ConsumerTemplate don't support the
jms uri with selector
Posted by "Willem Jiang (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/activemq/browse/CAMEL-2529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Willem Jiang resolved CAMEL-2529.
---------------------------------
Resolution: Fixed
committed patch for it.
> ConsumerTemplate don't support the jms uri with selector
> --------------------------------------------------------
>
> Key: CAMEL-2529
> URL: https://issues.apache.org/activemq/browse/CAMEL-2529
> Project: Apache Camel
> Issue Type: Bug
> Components: camel-jms
> Affects Versions: 2.0.0, 2.1.0, 2.2.0
> Reporter: Willem Jiang
> Assignee: Willem Jiang
> Fix For: 2.3.0
>
>
> This unit test can shows the issue that selector option don't work for ConsumerTemplate
> {code}
> @Test
> public void testConsumerTemplate() throws Exception {
> template.sendBodyAndHeader("activemq:queue:consumer", "Message1", "SIZE_NUMBER", 1505);
> template.sendBodyAndHeader("activemq:queue:consumer", "Message3", "SIZE_NUMBER", 1300);
> template.sendBodyAndHeader("activemq:queue:consumer", "Message2", "SIZE_NUMBER", 1600);
> // process every exchange which is ready. If no exchange is left break
> // the loop
> while (true) {
> Exchange ex = consumer.receiveNoWait("activemq:queue:consumer?selector=SIZE_NUMBER<1500");
> if (ex != null) {
> Message message = ex.getIn();
> int size = message.getHeader("SIZE_NUMBER", int.class);
> assertTrue("The message header SIZE_NUMBER should be less than 1500", size < 1500);
> assertEquals("The message body is wrong", "Message3", message.getBody());
> } else {
> break;
> }
> }
> }
> {code}
> And here is [mail thread|http://old.nabble.com/activemq-component-and-selector-ts27813752.html] which discusses about it.
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.