public class AMQPTransportListener extends org.apache.axis2.transport.base.AbstractTransportListenerEx<AMQPTransportEndpoint>
Constructor and Description |
---|
AMQPTransportListener() |
Modifier and Type | Method and Description |
---|---|
protected AMQPTransportEndpoint |
createEndpoint() |
protected void |
doInit() |
AMQPTransportConnectionFactory |
getConnectionFactory(String name)
Returns the connection factory with this name.
|
AMQPTransportReconnectHandler |
getHaHandler() |
protected void |
startEndpoint(AMQPTransportEndpoint endpoint) |
void |
stop() |
protected void |
stopEndpoint(AMQPTransportEndpoint endpoint) |
getEndpoints, getEPRsForService, init, start, startListeningForService, stopListeningForService
createMessageContext, destroy, disableTransportForService, getActiveThreadCount, getAvgSizeReceived, getAvgSizeSent, getBytesReceived, getBytesSent, getConfigurationContext, getEPRForService, getEPRsForService, getFaultsReceiving, getFaultsSending, getLastResetTime, getMaxSizeReceived, getMaxSizeSent, getMessagesReceived, getMessagesSent, getMetricsCollector, getMetricsWindow, getMinSizeReceived, getMinSizeSent, getQueueSize, getResponseCodeTable, getSessionContext, getTimeoutsReceiving, getTimeoutsSending, getTransportInDescription, getTransportName, handleException, handleIncomingMessage, logException, maintenenceShutdown, pause, resetStatistics, resume
protected void doInit() throws org.apache.axis2.AxisFault
doInit
in class org.apache.axis2.transport.base.AbstractTransportListenerEx<AMQPTransportEndpoint>
org.apache.axis2.AxisFault
protected AMQPTransportEndpoint createEndpoint()
createEndpoint
in class org.apache.axis2.transport.base.AbstractTransportListenerEx<AMQPTransportEndpoint>
protected void startEndpoint(AMQPTransportEndpoint endpoint) throws org.apache.axis2.AxisFault
startEndpoint
in class org.apache.axis2.transport.base.AbstractTransportListenerEx<AMQPTransportEndpoint>
org.apache.axis2.AxisFault
protected void stopEndpoint(AMQPTransportEndpoint endpoint)
stopEndpoint
in class org.apache.axis2.transport.base.AbstractTransportListenerEx<AMQPTransportEndpoint>
public void stop() throws org.apache.axis2.AxisFault
stop
in interface org.apache.axis2.transport.TransportListener
stop
in class org.apache.axis2.transport.base.AbstractTransportListenerEx<AMQPTransportEndpoint>
org.apache.axis2.AxisFault
public AMQPTransportConnectionFactory getConnectionFactory(String name) throws AMQPTransportException
name
- Name of the connection factory.AMQPTransportException
- throws in case of an error.public AMQPTransportReconnectHandler getHaHandler()
Copyright © 2005-2017 Apache Software Foundation. All Rights Reserved.