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

Class StompClient

java.lang.Object

org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient

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

org.ovirt.vdsm.jsonrpc.client.reactors.PlainClient

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

Direct Known Subclasses:

StompListener

public class StompClient
extends PlainClient

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 OneTimeCallback	callback

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

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
StompClient(Reactor reactor, Selector selector, String hostname, int port)

Method Summary

Modifier and Type	Method	Description
protected OneTimeCallback	getPostConnectCallback()
boolean	isInInit()
protected void	postConnect(OneTimeCallback callback)	Transport specific post connection functionality.
void	sendMessage(byte[] message)	Sends message using provided byte array.

Methods inherited from class org.ovirt.vdsm.jsonrpc.client.reactors.PlainClient

postDisconnect, 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, getPeerCertificates, getRetryPolicy, getSelectionKey, isOpen, now, performAction, process, processOutgoing, removeEventListener, scheduleTask, setClientPolicy, updateLastIncomingHeartbeat, updateLastOutgoingHeartbeat

Methods inherited from class java.lang.Object

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

Field Details

callback

private OneTimeCallback callback

Constructor Details

StompClient

public StompClient(Reactor reactor,
 Selector selector,
 String hostname,
 int port)

Method Details

sendMessage

public void sendMessage(byte[] message)

Description copied from class: ReactorClient

Sends message using provided byte array.

Specified by:

sendMessage in class ReactorClient

Parameters:

message - - content of the message to sent.

postConnect

protected void postConnect(OneTimeCallback callback)
                    throws ClientConnectionException

Description copied from class: ReactorClient

Transport specific post connection functionality.

Overrides:

postConnect in class PlainClient

Parameters:

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

Throws:

ClientConnectionException - when issues with connection.

getPostConnectCallback

protected OneTimeCallback getPostConnectCallback()

Specified by:

getPostConnectCallback in class ReactorClient

Returns:

Client specific OneTimeCallback or null. The callback is executed after the connection is established.

isInInit

public boolean isInInit()

Specified by:

isInInit in class ReactorClient

Returns:

true when connection initialization is in progress like SSL hand shake. false when connection is initialized.