Package org.ovirt.vdsm.jsonrpc.client.reactors.stomp

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

Modifier and Type	Field	Description
private CommandFactory	commandFactory
private static org.slf4j.Logger	log

Fields inherited from class org.ovirt.vdsm.jsonrpc.client.reactors.SSLClient

nioEngine, selector

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, PEER_CERTIFICATE_EMPTY_LIST, policy, reactor

Constructor Summary

Constructors

Constructor	Description
SSLStompListener(Reactor reactor, Selector selector, String hostname, int port, SocketChannel socketChannel, SSLContext sslContext)

Method Summary

Modifier and Type	Method	Description
protected void	postConnect(OneTimeCallback callback)	Transport specific post connection functionality.
(package private) void	processMessage(Message message)
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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.ovirt.vdsm.jsonrpc.client.reactors.stomp.impl.Sender

send

Field Details

log

private static org.slf4j.Logger log

commandFactory

private CommandFactory commandFactory

Constructor Details

SSLStompListener

public SSLStompListener(Reactor reactor,
 Selector selector,
 String hostname,
 int port,
 SocketChannel socketChannel,
 SSLContext sslContext)
                 throws ClientConnectionException

Throws:

ClientConnectionException

Method Details

sendMessage

public void sendMessage(byte[] message)

Description copied from class: ReactorClient

Sends message using provided byte array.

Overrides:

sendMessage in class SSLStompClient

Parameters:

message - - content of the message to sent.

setClientPolicy

public void setClientPolicy(ClientPolicy policy)

Overrides:

setClientPolicy in class ReactorClient

processMessage

void processMessage(Message message)

postConnect

protected void postConnect(OneTimeCallback callback)
                    throws ClientConnectionException

Description copied from class: ReactorClient

Transport specific post connection functionality.

Overrides:

postConnect in class SSLStompClient

Parameters:

callback - - callback which is executed after connection is estabilished.

Throws:

ClientConnectionException - when issues with connection.