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
Exceptionboolean isFailed(String aDelegateKey)
boolean isListenerForDestination(String anEndpointName)
void removeDelegateFromFailedList(String aDelegateKey)
void setTerminating()
void terminate()
Copyright © 2016. All rights reserved.