Interface AmqpTransport
-
- All Known Implementing Classes:
AmqpTransportFilter
public interface AmqpTransport
Basic interface that mediates between protocol converter and transport
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description AmqpInactivityMonitor
getInactivityMonitor()
X509Certificate[]
getPeerCertificates()
AmqpProtocolConverter
getProtocolConverter()
String
getRemoteAddress()
String
getTransformer()
AmqpWireFormat
getWireFormat()
boolean
isTrace()
boolean
isUseInactivityMonitor()
long
keepAlive()
void
onException(IOException error)
void
sendToActiveMQ(IOException command)
void
sendToActiveMQ(Command command)
void
sendToAmqp(Object command)
void
setInactivityMonitor(AmqpInactivityMonitor monitor)
void
setProtocolConverter(AmqpProtocolConverter protocolConverter)
void
stop()
-
-
-
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()
-
-