public class AMQPTransportListener extends AbstractTransportListener
ConfigurationElement.State
logger, metrics, properties, serverName, transportName
Constructor and Description |
---|
AMQPTransportListener() |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getOriginatingTransportName() |
void |
maintenanceShutdown(long millis) |
void |
pause() |
void |
registerProxyService(org.adroitlogic.ultraesb.core.ProxyService ps,
java.lang.String uriPattern,
java.util.Map properties) |
void |
resume() |
void |
setAcknowledgeMode(AcknowledgeMode acknowledgeMode) |
void |
setChannelTransacted(boolean channelTransacted) |
void |
setConcurrentConsumers(int concurrentConsumers) |
void |
setConnectionFactory(ConnectionFactory connectionFactory) |
void |
setErrorHandler(org.springframework.util.ErrorHandler errorHandler) |
void |
setMessagePropertiesConverter(MessagePropertiesConverter messagePropertiesConverter) |
void |
setPhase(int phase) |
void |
setPrefetchCount(int prefetchCount) |
void |
setReceiveTimeout(long receiveTimeout) |
void |
setRecoveryInterval(long recoveryInterval) |
void |
setShutdownTimeout(long shutdownTimeout) |
void |
setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager) |
void |
setTransactionSize(int transactionSize) |
void |
start() |
void |
stop() |
void |
unregisterProxyService(org.adroitlogic.ultraesb.core.ProxyService ps) |
getAccessURLs, getDetails, init, resetStatistics, setProperties, toBasicView, toDetailedView, toDetailedViewExt
equals, getDeploymentUnit, getDerivedName, getId, getState, getStreamCount, getTimerStreamMax, getTimerStreamMean, getTimerStreamMin, getTimerStreamPer, hashCode, init, isDebugOn, isStarted, markAsOutdated, resetCounter, resetTimer, resolveMetricsStreams, setBeanName, setConfig, setDebugOn, setDerivedName, setId, setMetricsEngine, setState, throwIllegalStateException, undeploy
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
retire
public java.lang.String getOriginatingTransportName()
public void start()
start
in interface ConfigurationElement
start
in class org.adroitlogic.ultraesb.core.config.AbstractConfigurationElement
public void stop()
stop
in interface ConfigurationElement
stop
in class org.adroitlogic.ultraesb.core.config.AbstractConfigurationElement
public void pause()
pause
in interface ConfigurationElement
pause
in class org.adroitlogic.ultraesb.core.config.AbstractConfigurationElement
public void resume()
resume
in interface ConfigurationElement
resume
in class org.adroitlogic.ultraesb.core.config.AbstractConfigurationElement
public void maintenanceShutdown(long millis)
maintenanceShutdown
in interface ConfigurationElement
maintenanceShutdown
in class org.adroitlogic.ultraesb.core.config.AbstractConfigurationElement
public void registerProxyService(org.adroitlogic.ultraesb.core.ProxyService ps, java.lang.String uriPattern, java.util.Map properties)
public void unregisterProxyService(org.adroitlogic.ultraesb.core.ProxyService ps)
public void setConnectionFactory(ConnectionFactory connectionFactory)
public void setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
public void setErrorHandler(org.springframework.util.ErrorHandler errorHandler)
public void setMessagePropertiesConverter(MessagePropertiesConverter messagePropertiesConverter)
public void setConcurrentConsumers(int concurrentConsumers)
public void setRecoveryInterval(long recoveryInterval)
public void setReceiveTimeout(long receiveTimeout)
public void setPrefetchCount(int prefetchCount)
public void setChannelTransacted(boolean channelTransacted)
public void setAcknowledgeMode(AcknowledgeMode acknowledgeMode)
public void setShutdownTimeout(long shutdownTimeout)
public void setPhase(int phase)
public void setTransactionSize(int transactionSize)