public abstract class AbstractStompSocket extends TransportSupport implements StompTransport
Modifier and Type | Field and Description |
---|---|
protected X509Certificate[] |
certificates |
protected ProtocolConverter |
protocolConverter |
protected ReentrantLock |
protocolLock |
protected int |
receiveCounter |
protected String |
remoteAddress |
protected CountDownLatch |
socketTransportStarted |
protected StompInactivityMonitor |
stompInactivityMonitor |
protected StompWireFormat |
wireFormat |
Constructor and Description |
---|
AbstractStompSocket(String remoteAddress) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop(ServiceStopper stopper) |
StompInactivityMonitor |
getInactivityMonitor() |
X509Certificate[] |
getPeerCertificates() |
int |
getReceiveCounter()
Returns a counter which gets incremented as data is read from the transport.
|
String |
getRemoteAddress() |
StompWireFormat |
getWireFormat()
Retrieves the WireFormat instance associated with this Transport instance.
|
abstract void |
handleStopped()
Called when the transport is stopping to allow the dervied classes
a chance to close WebSocket resources.
|
void |
oneway(Object command)
A one way asynchronous send
|
protected void |
processStompFrame(String data) |
void |
sendToActiveMQ(Command command) |
abstract void |
sendToStomp(StompFrame command) |
void |
setPeerCertificates(X509Certificate[] certificates)
Sets the certificates provided by the connected peer.
|
asyncRequest, checkStarted, doConsume, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, onException, reconnect, request, request, setTransportListener, updateURIs
addServiceListener, dispose, isStarted, isStopped, isStopping, postStop, preStart, removeServiceListener, start, stop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onException
protected ReentrantLock protocolLock
protected ProtocolConverter protocolConverter
protected StompWireFormat wireFormat
protected final CountDownLatch socketTransportStarted
protected final StompInactivityMonitor stompInactivityMonitor
protected volatile int receiveCounter
protected final String remoteAddress
protected X509Certificate[] certificates
public AbstractStompSocket(String remoteAddress)
public void oneway(Object command) throws IOException
Transport
oneway
in interface Transport
IOException
public void sendToActiveMQ(Command command)
sendToActiveMQ
in interface StompTransport
protected void doStop(ServiceStopper stopper) throws Exception
doStop
in class ServiceSupport
Exception
protected void doStart() throws Exception
doStart
in class ServiceSupport
Exception
public abstract void sendToStomp(StompFrame command) throws IOException
sendToStomp
in interface StompTransport
IOException
public abstract void handleStopped() throws IOException
IOException
- if an error occurs during the stop.public StompInactivityMonitor getInactivityMonitor()
getInactivityMonitor
in interface StompTransport
public StompWireFormat getWireFormat()
Transport
getWireFormat
in interface StompTransport
getWireFormat
in interface Transport
public String getRemoteAddress()
getRemoteAddress
in interface Transport
public int getReceiveCounter()
Transport
getReceiveCounter
in interface Transport
protected void processStompFrame(String data)
public X509Certificate[] getPeerCertificates()
getPeerCertificates
in interface Transport
public void setPeerCertificates(X509Certificate[] certificates)
Transport
setPeerCertificates
in interface Transport
certificates
- the Certificates provided by the peer.Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.