org.apache.uima.adapter.jms.activemq
Class TempDestinationResolver

java.lang.Object
  extended by org.apache.uima.adapter.jms.activemq.TempDestinationResolver
All Implemented Interfaces:
org.springframework.jms.support.destination.DestinationResolver

public class TempDestinationResolver
extends java.lang.Object
implements org.springframework.jms.support.destination.DestinationResolver


Constructor Summary
TempDestinationResolver()
           
 
Method Summary
 javax.jms.Destination resolveDestinationName(javax.jms.Session session, java.lang.String destinationName, boolean pubSubDomain)
          This method is called by the Spring listener code.
 void setConnectionFactory(org.apache.activemq.ActiveMQConnectionFactory aFactory)
          called from Spring during initialization
 void setListener(UimaDefaultMessageListenerContainer aListener)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TempDestinationResolver

public TempDestinationResolver()
Method Detail

resolveDestinationName

public javax.jms.Destination resolveDestinationName(javax.jms.Session session,
                                                    java.lang.String destinationName,
                                                    boolean pubSubDomain)
                                             throws javax.jms.JMSException
This method is called by the Spring listener code. It creates a single temp queue for all listener instances. If the Spring listener is configured with more than one concurrentConsumer, this method will be called more than once. The temp queue is created only once and cached on the first call. Subsequent requests receive the same queue.

Specified by:
resolveDestinationName in interface org.springframework.jms.support.destination.DestinationResolver
Throws:
javax.jms.JMSException

setListener

public void setListener(UimaDefaultMessageListenerContainer aListener)

setConnectionFactory

public void setConnectionFactory(org.apache.activemq.ActiveMQConnectionFactory aFactory)
called from Spring during initialization

Parameters:
aFactory -


Copyright © 2011. All Rights Reserved.