public class JmsInputChannel extends Object implements 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() |
Modifier and Type | Method and Description |
---|---|
void |
abort() |
void |
ackMessage(MessageContext aMessageContext) |
void |
createListener(String aDelegateKey,
Endpoint endpointToUpdate) |
void |
destroyListener(String anEndpointName,
String aDelegateKey) |
String |
getBrokerURL() |
int |
getConcurrentConsumerCount() |
org.apache.activemq.ActiveMQConnectionFactory |
getConnectionFactory() |
AnalysisEngineController |
getController() |
String |
getInputQueueName() |
String |
getName() |
String |
getServerUri() |
ServiceInfo |
getServiceInfo() |
int |
getSessionAckMode() |
boolean |
isFailed(String aDelegateKey) |
boolean |
isListenerActiveOnDestination(javax.jms.Destination destination) |
boolean |
isListenerForDestination(String anEndpointName) |
boolean |
isStopped() |
void |
onMessage(javax.jms.Message aMessage,
javax.jms.Session aJmsSession)
Receives Messages from the JMS Provider.
|
void |
removeDelegateFromFailedList(String aDelegateKey) |
void |
setController(AnalysisEngineController aController) |
void |
setEndpointName(String anEndpointName) |
void |
setListenerContainer(UimaDefaultMessageListenerContainer messageListener) |
void |
setMessageHandler(Handler aHandler) |
void |
setServerUri(String serverUri) |
void |
setTerminating() |
void |
stop() |
void |
stop(int channelsToClose) |
void |
terminate() |
boolean |
validMessage(javax.jms.Message aMessage)
Validates contents of the message.
|
public AnalysisEngineController getController()
public void setController(AnalysisEngineController aController) throws Exception
Exception
public void setMessageHandler(Handler aHandler)
public void setEndpointName(String anEndpointName)
public boolean validMessage(javax.jms.Message aMessage) throws Exception
aMessage
- - JMS Message to validateException
public void abort()
public void onMessage(javax.jms.Message aMessage, javax.jms.Session aJmsSession)
onMessage
in interface org.springframework.jms.listener.SessionAwareMessageListener
aMessage
- - JMS Message containing header and payloadaJmsSession
- - JMSSession objectpublic int getSessionAckMode()
getSessionAckMode
in interface InputChannel
public String getServerUri()
getServerUri
in interface InputChannel
public void setListenerContainer(UimaDefaultMessageListenerContainer messageListener)
public org.apache.activemq.ActiveMQConnectionFactory getConnectionFactory()
public void ackMessage(MessageContext aMessageContext)
ackMessage
in interface InputChannel
public String getBrokerURL()
getBrokerURL
in interface JmsInputChannelMBean
public String getInputQueueName()
getInputQueueName
in interface InputChannel
getInputQueueName
in interface JmsInputChannelMBean
public ServiceInfo getServiceInfo()
getServiceInfo
in interface InputChannel
public void setServerUri(String serverUri)
setServerUri
in interface InputChannel
public void setTerminating()
setTerminating
in interface InputChannel
public void terminate()
terminate
in interface InputChannel
public void stop(int channelsToClose) throws Exception
public boolean isStopped()
isStopped
in interface InputChannel
public int getConcurrentConsumerCount()
getConcurrentConsumerCount
in interface InputChannel
public void createListener(String aDelegateKey, Endpoint endpointToUpdate) throws Exception
createListener
in interface InputChannel
Exception
public boolean isListenerActiveOnDestination(javax.jms.Destination destination)
public void destroyListener(String anEndpointName, String aDelegateKey)
destroyListener
in interface InputChannel
public boolean isFailed(String aDelegateKey)
isFailed
in interface InputChannel
public void removeDelegateFromFailedList(String aDelegateKey)
removeDelegateFromFailedList
in interface InputChannel
public boolean isListenerForDestination(String anEndpointName)
isListenerForDestination
in interface InputChannel
Copyright © 2016. All rights reserved.