public interface AmqpTransport
Modifier and Type | Method and 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(Command command) |
void |
sendToActiveMQ(IOException command) |
void |
sendToAmqp(Object command) |
void |
setInactivityMonitor(AmqpInactivityMonitor monitor) |
void |
setProtocolConverter(AmqpProtocolConverter protocolConverter) |
void |
stop() |
void sendToActiveMQ(Command command)
void sendToActiveMQ(IOException command)
void sendToAmqp(Object command) throws IOException
IOException
X509Certificate[] getPeerCertificates()
void onException(IOException error)
AmqpWireFormat getWireFormat()
String getTransformer()
String getRemoteAddress()
boolean isTrace()
AmqpProtocolConverter getProtocolConverter()
void setProtocolConverter(AmqpProtocolConverter protocolConverter)
void setInactivityMonitor(AmqpInactivityMonitor monitor)
AmqpInactivityMonitor getInactivityMonitor()
boolean isUseInactivityMonitor()
long keepAlive()
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.