public class JmsInputChannel extends Object implements org.apache.uima.aae.InputChannel, JmsInputChannelMBean, org.springframework.jms.listener.SessionAwareMessageListener
Handler. Each JMS Message is wrapped in transport neutral MessageContext
wrapper.| Modifier and Type | Field and Description |
|---|---|
static boolean |
attachToBrokerMBeanServer |
CloseAllChannels, InputChannels| Constructor and Description |
|---|
JmsInputChannel() |
public org.apache.uima.aae.controller.AnalysisEngineController getController()
public String getName()
getName in interface org.apache.uima.aae.Channelpublic void setController(org.apache.uima.aae.controller.AnalysisEngineController aController) throws Exception
Exceptionpublic void setMessageHandler(org.apache.uima.aae.handler.Handler aHandler)
public void setEndpointName(String anEndpointName)
public boolean validMessage(javax.jms.Message aMessage)
throws Exception
aMessage - - JMS Message to validateExceptionpublic void abort()
public void onMessage(org.apache.uima.aae.message.MessageWrapper wrapper)
onMessage in interface org.apache.uima.aae.InputChannelpublic void onMessage(javax.jms.Message aMessage,
javax.jms.Session aJmsSession)
onMessage in interface org.springframework.jms.listener.SessionAwareMessageListeneraMessage - - JMS Message containing header and payloadaJmsSession - - JMSSession objectpublic int getSessionAckMode()
getSessionAckMode in interface org.apache.uima.aae.InputChannelpublic String getServerUri()
getServerUri in interface org.apache.uima.aae.InputChannelpublic List<UimaDefaultMessageListenerContainer> registerListener(UimaDefaultMessageListenerContainer messageListener)
public List<UimaDefaultMessageListenerContainer> getListeners()
public void setListenerContainer(UimaDefaultMessageListenerContainer jmsL)
public org.apache.activemq.ActiveMQConnectionFactory getConnectionFactory()
public void ackMessage(org.apache.uima.aae.message.MessageContext aMessageContext)
ackMessage in interface org.apache.uima.aae.InputChannelpublic String getBrokerURL()
getBrokerURL in interface JmsInputChannelMBeanpublic String getInputQueueName()
getInputQueueName in interface org.apache.uima.aae.InputChannelgetInputQueueName in interface JmsInputChannelMBeanpublic org.apache.uima.aae.jmx.ServiceInfo getServiceInfo()
getServiceInfo in interface org.apache.uima.aae.InputChannelpublic void setServerUri(String serverUri)
setServerUri in interface org.apache.uima.aae.InputChannelpublic void stop(boolean shutdownNow)
throws Exception
stop in interface org.apache.uima.aae.ChannelExceptionpublic void disconnectListenersFromQueue()
throws Exception
disconnectListenersFromQueue in interface org.apache.uima.aae.InputChannelExceptionpublic void setTerminating()
setTerminating in interface org.apache.uima.aae.InputChannelpublic void terminate()
terminate in interface org.apache.uima.aae.InputChannelpublic void stop(int channelsToClose,
boolean shutdownNow)
throws Exception
stop in interface org.apache.uima.aae.ChannelExceptionpublic boolean isStopped()
isStopped in interface org.apache.uima.aae.InputChannelpublic int getConcurrentConsumerCount()
getConcurrentConsumerCount in interface org.apache.uima.aae.InputChannelpublic void createListenerOnTempQueue(javax.jms.ConnectionFactory cf,
boolean isFreeCasDestination)
throws Exception
Exceptionpublic void createListenerForTargetedMessages()
throws Exception
createListenerForTargetedMessages in interface org.apache.uima.aae.InputChannelExceptionpublic void createListener(String aDelegateKey, org.apache.uima.aae.controller.Endpoint endpointToUpdate) throws Exception
createListener in interface org.apache.uima.aae.InputChannelExceptionpublic boolean isListenerActiveOnDestination(javax.jms.Destination destination)
public void destroyListener(String anEndpointName, String aDelegateKey)
destroyListener in interface org.apache.uima.aae.InputChannelpublic boolean isFailed(String aDelegateKey)
isFailed in interface org.apache.uima.aae.InputChannelpublic void removeDelegateFromFailedList(String aDelegateKey)
removeDelegateFromFailedList in interface org.apache.uima.aae.InputChannelpublic boolean isListenerForDestination(String anEndpointName)
isListenerForDestination in interface org.apache.uima.aae.InputChannelCopyright © 2006–2018 The Apache Software Foundation. All rights reserved.