Class SSLStompListener
- java.lang.Object
-
- org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
-
- org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
-
- org.ovirt.vdsm.jsonrpc.client.reactors.SSLClient
-
- org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompClient
-
- org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompListener
-
- All Implemented Interfaces:
Sender
public class SSLStompListener extends SSLStompClient implements Sender
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
ReactorClient.MessageListener
-
-
Field Summary
-
Fields inherited from class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
connected, DEFAULT_REQUEST_QUEUE, DEFAULT_RESPONSE_QUEUE, headerBuffer, message, subscribed, subscriptionIds
-
Fields inherited from class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
BUFFER_SIZE, channel, CLIENT_CLOSED, eventListeners, half, ibuff, key, outbox, policy, reactor
-
-
Constructor Summary
Constructors Constructor Description SSLStompListener(Reactor reactor, java.nio.channels.Selector selector, java.lang.String hostname, int port, java.nio.channels.SocketChannel socketChannel, javax.net.ssl.SSLContext sslContext)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
postConnect(OneTimeCallback callback)
Transport specific post connection functionality.void
sendMessage(byte[] message)
Sends message using provided byte array.void
setClientPolicy(ClientPolicy policy)
-
Methods inherited from class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.SSLStompClient
getPostConnectCallback, isInInit
-
Methods inherited from class org.ovirt.vdsm.jsonrpc.client.reactors.SSLClient
createSSLEngine, getPeerCertificates, postDisconnect, process, read, updateInterestedOps, write
-
Methods inherited from class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient
buildNetworkResponse, clean, close, emitOnMessageReceived, getEventQueue, getRequestQueue, getResponseQueue, processIncoming, send, sendHeartbeat, sendNow, updatePolicyWithHeartbeat, validate
-
Methods inherited from class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient
addEventListener, closeChannel, connect, disconnect, emitOnMessageReceived, getClientId, getConnectionId, getHostname, getRetryPolicy, getSelectionKey, isOpen, now, performAction, processOutgoing, removeEventListener, scheduleTask, updateLastIncomingHeartbeat, updateLastOutgoingHeartbeat
-
-
-
-
Constructor Detail
-
SSLStompListener
public SSLStompListener(Reactor reactor, java.nio.channels.Selector selector, java.lang.String hostname, int port, java.nio.channels.SocketChannel socketChannel, javax.net.ssl.SSLContext sslContext) throws ClientConnectionException
- Throws:
ClientConnectionException
-
-
Method Detail
-
sendMessage
public void sendMessage(byte[] message)
Description copied from class:ReactorClient
Sends message using provided byte array.- Overrides:
sendMessage
in classSSLStompClient
- Parameters:
message
- - content of the message to sent.
-
setClientPolicy
public void setClientPolicy(ClientPolicy policy)
- Overrides:
setClientPolicy
in classReactorClient
-
postConnect
protected void postConnect(OneTimeCallback callback) throws ClientConnectionException
Description copied from class:ReactorClient
Transport specific post connection functionality.- Overrides:
postConnect
in classSSLStompClient
- Parameters:
callback
- - callback which is executed after connection is estabilished.- Throws:
ClientConnectionException
- when issues with connection.
-
-