Package org.apache.uima.aae

Interface InputChannel

All Superinterfaces:

Channel

All Known Implementing Classes:

JmsInputChannel

public interface InputChannel
extends Channel

Field Summary

Fields inherited from interface org.apache.uima.aae.Channel

CloseAllChannels, InputChannels

Method Summary

Modifier and Type	Method	Description
void	ackMessage(MessageContext aMessageContext)
void	createListener(java.lang.String aDelegateKey, Endpoint endpointToUpdate)
void	destroyListener(java.lang.String anEndpointName, java.lang.String aDelegateKey)
int	getConcurrentConsumerCount()
java.lang.String	getInputQueueName()
java.lang.String	getServerUri()
ServiceInfo	getServiceInfo()
int	getSessionAckMode()
boolean	isFailed(java.lang.String aDelegateKey)
boolean	isListenerForDestination(java.lang.String anEndpointName)
boolean	isStopped()
void	removeDelegateFromFailedList(java.lang.String aDelegateKey)
void	setServerUri(java.lang.String aServerUri)
void	setTerminating()
void	terminate()

Methods inherited from interface org.apache.uima.aae.Channel

getName, stop, stop

Method Detail

getSessionAckMode

int getSessionAckMode()

ackMessage

void ackMessage(MessageContext aMessageContext)

getServerUri

java.lang.String getServerUri()

setServerUri

void setServerUri(java.lang.String aServerUri)

getInputQueueName

java.lang.String getInputQueueName()

getServiceInfo

ServiceInfo getServiceInfo()

isStopped

boolean isStopped()

getConcurrentConsumerCount

int getConcurrentConsumerCount()

destroyListener

void destroyListener(java.lang.String anEndpointName,
                     java.lang.String aDelegateKey)

createListener

void createListener(java.lang.String aDelegateKey,
                    Endpoint endpointToUpdate)
             throws java.lang.Exception

Throws:

java.lang.Exception

isFailed

boolean isFailed(java.lang.String aDelegateKey)

isListenerForDestination

boolean isListenerForDestination(java.lang.String anEndpointName)

removeDelegateFromFailedList

void removeDelegateFromFailedList(java.lang.String aDelegateKey)

setTerminating

void setTerminating()

terminate

void terminate()