public class AmqpTransportFilter extends TransportFilter implements AmqpTransport
Modifier and Type | Field and Description |
---|---|
static org.slf4j.Logger |
TRACE_FRAMES |
next, transportListener
Constructor and Description |
---|
AmqpTransportFilter(Transport next,
org.apache.activemq.wireformat.WireFormat wireFormat,
BrokerService brokerService) |
Modifier and Type | Method and Description |
---|---|
int |
getConnectAttemptTimeout() |
AmqpInactivityMonitor |
getInactivityMonitor() |
long |
getMaxFrameSize() |
X509Certificate[] |
getPeerCertificates() |
int |
getProducerCredit() |
AmqpProtocolConverter |
getProtocolConverter() |
String |
getTransformer() |
AmqpWireFormat |
getWireFormat() |
void |
handleException(IOException e) |
boolean |
isTrace() |
boolean |
isUseInactivityMonitor() |
long |
keepAlive() |
void |
onCommand(Object command) |
void |
oneway(Object o) |
void |
onException(IOException error) |
void |
sendToActiveMQ(org.apache.activemq.command.Command command) |
void |
sendToActiveMQ(IOException error) |
void |
sendToAmqp(Object command) |
void |
setConnectAttemptTimeout(int connectAttemptTimeout) |
void |
setInactivityMonitor(AmqpInactivityMonitor monitor) |
void |
setMaxFrameSize(long maxFrameSize) |
void |
setProducerCredit(int producerCredit) |
void |
setProtocolConverter(AmqpProtocolConverter protocolConverter) |
void |
setTrace(boolean trace) |
void |
setTransformer(String transformer) |
void |
start() |
asyncRequest, getNext, getReceiveCounter, getRemoteAddress, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, reconnect, request, request, setTransportListener, stop, toString, transportInterupted, transportResumed, updateURIs
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getRemoteAddress, stop
public static final org.slf4j.Logger TRACE_FRAMES
public AmqpTransportFilter(Transport next, org.apache.activemq.wireformat.WireFormat wireFormat, BrokerService brokerService)
public void start() throws Exception
start
in interface org.apache.activemq.Service
start
in class TransportFilter
Exception
public void oneway(Object o) throws IOException
oneway
in interface Transport
oneway
in class TransportFilter
IOException
public void onException(IOException error)
onException
in interface AmqpTransport
onException
in interface TransportListener
onException
in class TransportFilter
public void sendToActiveMQ(IOException error)
sendToActiveMQ
in interface AmqpTransport
public void onCommand(Object command)
onCommand
in interface TransportListener
onCommand
in class TransportFilter
public void sendToActiveMQ(org.apache.activemq.command.Command command)
sendToActiveMQ
in interface AmqpTransport
public void sendToAmqp(Object command) throws IOException
sendToAmqp
in interface AmqpTransport
IOException
public long keepAlive()
keepAlive
in interface AmqpTransport
public X509Certificate[] getPeerCertificates()
getPeerCertificates
in interface AmqpTransport
public boolean isTrace()
isTrace
in interface AmqpTransport
public void setTrace(boolean trace)
public AmqpWireFormat getWireFormat()
getWireFormat
in interface AmqpTransport
public void handleException(IOException e)
public String getTransformer()
getTransformer
in interface AmqpTransport
public void setTransformer(String transformer)
public AmqpProtocolConverter getProtocolConverter()
getProtocolConverter
in interface AmqpTransport
public void setProtocolConverter(AmqpProtocolConverter protocolConverter)
setProtocolConverter
in interface AmqpTransport
public void setProducerCredit(int producerCredit)
public int getProducerCredit()
public void setInactivityMonitor(AmqpInactivityMonitor monitor)
setInactivityMonitor
in interface AmqpTransport
public AmqpInactivityMonitor getInactivityMonitor()
getInactivityMonitor
in interface AmqpTransport
public boolean isUseInactivityMonitor()
isUseInactivityMonitor
in interface AmqpTransport
public int getConnectAttemptTimeout()
public void setConnectAttemptTimeout(int connectAttemptTimeout)
public long getMaxFrameSize()
public void setMaxFrameSize(long maxFrameSize)
Copyright © 2005–2020 FuseSource, Corp.. All rights reserved.