[
https://issues.apache.org/jira/browse/AXIS2-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andreas Veithen resolved AXIS2-5825.
------------------------------------
Resolution: Fixed
Assignee: Andreas Veithen
Fix Version/s: 1.7.5
> [Axis2][Tibco] Correct usage of JMS API to create MessageConsumer
> -----------------------------------------------------------------
>
> Key: AXIS2-5825
> URL: https://issues.apache.org/jira/browse/AXIS2-5825
> Project: Axis2
> Issue Type: Bug
> Components: JMS transport
> Affects Versions: 1.7.4
> Reporter: Ziborov Egor
> Assignee: Andreas Veithen
> Priority: Minor
> Fix For: 1.7.5
>
>
> When we tried to work with Tibco ESB we handle ClassCastException:
> {noformat}
> java.lang.ClassCastException: com.tibco.tibjms.TibjmsxSessionImp cannot be
> cast to javax.jms.QueueSession
> at org.apache.axis2.transport.jms.JMSUtils.createConsumer(JMSUtils.java:434)
> {noformat}
> Currently Axis2 logic based on correlation Queue (as destination) <->
> QueueSession (as a session) and the same for the topics. But it's not
> correct. Offer rewrite method createConsumer(Session, Destination, String) to:
> {code:java}
> public static MessageConsumer createConsumer(Session session, Destination
> dest, String messageSelector) throws JMSException {
> return (dest instanceof Queue ?
> createQueueConsumer(session, (Queue)dest, messageSelector) :
> createTopicConsumer(session, (Topic) dest, messageSelector));
> }
> public static MessageConsumer createQueueConsumer(Session session, Queue
> queue, String messageSelector) throws JMSException {
> return (session instanceof QueueSession) ?
> ((QueueSession)session).createReceiver(queue,
> messageSelector) :
> session.createConsumer(queue, messageSelector);
> }
> public static MessageConsumer createTopicConsumer(Session session, Topic
> topic, String messageSelector) throws JMSException {
> return (session instanceof TopicSession) ?
> ((TopicSession)session).createSubscriber(topic,
> messageSelector, false) :
> session.createConsumer(topic, messageSelector);
> }
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
