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

Class StompCommonClient

java.lang.Object

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

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

Direct Known Subclasses:

PlainClient, SSLClient

public abstract class StompCommonClient
extends ReactorClient

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 and Description
protected CountDownLatch	connected
static String	DEFAULT_REQUEST_QUEUE
static String	DEFAULT_RESPONSE_QUEUE
protected ByteBuffer	headerBuffer
protected Message	message
protected CountDownLatch	subscribed
protected List<String>	subscriptionIds

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

BUFFER_SIZE, channel, CLIENT_CLOSED, eventListeners, ibuff, key, outbox, policy, reactor

Constructor Summary

Constructors

Constructor and Description
StompCommonClient(Reactor reactor, String hostname, int port)

Method Summary

Methods

Modifier and Type	Method and Description
protected byte[]	buildNetworkResponse(String reason) Builds network issue message for specific protocol.
Future<Void>	close()
protected void	emitOnMessageReceived(Message message)
String	getEventQueue()
String	getRequestQueue()
String	getResponseQueue()
protected void	processIncoming() Process incoming channel.
void	send(byte[] message)
protected void	sendHeartbeat() Client sends protocol specific heartbeat message
void	sendNow(byte[] message)
void	updatePolicyWithHeartbeat(String heartbeat, boolean client)
void	validate(ClientPolicy policy) Validates policy when it is set.

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

addEventListener, closeChannel, connect, disconnect, emitOnMessageReceived, getClientId, getConnectionId, getHostname, getPeerCertificates, getPostConnectCallback, getRetryPolicy, getSelectionKey, isInInit, isOpen, performAction, postConnect, postDisconnect, process, processOutgoing, read, removeEventListener, scheduleTask, sendMessage, setClientPolicy, updateInterestedOps, updateLastIncomingHeartbeat, updateLastOutgoingHeartbeat

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_REQUEST_QUEUE

public static final String DEFAULT_REQUEST_QUEUE

See Also:

Constant Field Values

DEFAULT_RESPONSE_QUEUE

public static final String DEFAULT_RESPONSE_QUEUE

See Also:

Constant Field Values

headerBuffer

protected ByteBuffer headerBuffer

message

protected Message message

connected

protected CountDownLatch connected

subscribed

protected CountDownLatch subscribed

subscriptionIds

protected List<String> subscriptionIds

Constructor Detail

StompCommonClient

public StompCommonClient(Reactor reactor,
                 String hostname,
                 int port)

Method Detail

send

public void send(byte[] message)

sendNow

public void sendNow(byte[] message)

close

public Future<Void> close()

Overrides:

close in class ReactorClient

processIncoming

protected void processIncoming()
                        throws IOException,
                               ClientConnectionException

Description copied from class: ReactorClient

Process incoming channel.

Specified by:

processIncoming in class ReactorClient

Throws:

IOException - Thrown when reading issue occurred.

ClientConnectionException - Thrown when issues with connection.

emitOnMessageReceived

protected void emitOnMessageReceived(Message message)

buildNetworkResponse

protected byte[] buildNetworkResponse(String reason)

Description copied from class: ReactorClient

Builds network issue message for specific protocol.

Specified by:

buildNetworkResponse in class ReactorClient

Parameters:

reason - why we want to build network response.

Returns:

byte array containing response.

updatePolicyWithHeartbeat

public void updatePolicyWithHeartbeat(String heartbeat,
                             boolean client)

sendHeartbeat

protected void sendHeartbeat()

Description copied from class: ReactorClient

Client sends protocol specific heartbeat message

Specified by:

sendHeartbeat in class ReactorClient

validate

public void validate(ClientPolicy policy)

Description copied from class: ReactorClient

Validates policy when it is set.

Specified by:

validate in class ReactorClient

getRequestQueue

public String getRequestQueue()

getResponseQueue

public String getResponseQueue()

getEventQueue

public String getEventQueue()