public interface InputChannel extends Channel
CloseAllChannels, InputChannels
Modifier and Type | Method and Description |
---|---|
void |
ackMessage(MessageContext aMessageContext) |
void |
createListener(String aDelegateKey,
Endpoint endpointToUpdate) |
void |
destroyListener(String anEndpointName,
String aDelegateKey) |
int |
getConcurrentConsumerCount() |
String |
getInputQueueName() |
String |
getServerUri() |
ServiceInfo |
getServiceInfo() |
int |
getSessionAckMode() |
boolean |
isFailed(String aDelegateKey) |
boolean |
isListenerForDestination(String anEndpointName) |
boolean |
isStopped() |
void |
removeDelegateFromFailedList(String aDelegateKey) |
void |
setServerUri(String aServerUri) |
void |
setTerminating() |
void |
terminate() |
int getSessionAckMode()
void ackMessage(MessageContext aMessageContext)
String getServerUri()
void setServerUri(String aServerUri)
String getInputQueueName()
ServiceInfo getServiceInfo()
boolean isStopped()
int getConcurrentConsumerCount()
void createListener(String aDelegateKey, Endpoint endpointToUpdate) throws Exception
Exception
boolean isFailed(String aDelegateKey)
boolean isListenerForDestination(String anEndpointName)
void removeDelegateFromFailedList(String aDelegateKey)
void setTerminating()
void terminate()
Copyright © 2016. All rights reserved.