Interface AmqpTransport
-
- All Known Implementing Classes:
AmqpTransportFilter
public interface AmqpTransportBasic interface that mediates between protocol converter and transport
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description AmqpInactivityMonitorgetInactivityMonitor()X509Certificate[]getPeerCertificates()AmqpProtocolConvertergetProtocolConverter()StringgetRemoteAddress()StringgetTransformer()AmqpWireFormatgetWireFormat()booleanisTrace()booleanisUseInactivityMonitor()longkeepAlive()voidonException(IOException error)voidsendToActiveMQ(IOException command)voidsendToActiveMQ(Command command)voidsendToAmqp(Object command)voidsetInactivityMonitor(AmqpInactivityMonitor monitor)voidsetProtocolConverter(AmqpProtocolConverter protocolConverter)voidstop()
-
-
-
Method Detail
-
sendToActiveMQ
void sendToActiveMQ(Command command)
-
sendToActiveMQ
void sendToActiveMQ(IOException command)
-
sendToAmqp
void sendToAmqp(Object command) throws IOException
- Throws:
IOException
-
getPeerCertificates
X509Certificate[] getPeerCertificates()
-
onException
void onException(IOException error)
-
getWireFormat
AmqpWireFormat getWireFormat()
-
getTransformer
String getTransformer()
-
getRemoteAddress
String getRemoteAddress()
-
isTrace
boolean isTrace()
-
getProtocolConverter
AmqpProtocolConverter getProtocolConverter()
-
setProtocolConverter
void setProtocolConverter(AmqpProtocolConverter protocolConverter)
-
setInactivityMonitor
void setInactivityMonitor(AmqpInactivityMonitor monitor)
-
getInactivityMonitor
AmqpInactivityMonitor getInactivityMonitor()
-
isUseInactivityMonitor
boolean isUseInactivityMonitor()
-
keepAlive
long keepAlive()
-
-