Package 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	Description
protected CountDownLatch	connected
static final String	DEFAULT_REQUEST_QUEUE
static final String	DEFAULT_RESPONSE_QUEUE
protected ByteBuffer	headerBuffer
private static final org.slf4j.Logger	LOG
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, half, ibuff, key, outbox, PEER_CERTIFICATE_EMPTY_LIST, policy, reactor

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected byte[]	buildNetworkResponse(String reason)	Builds network issue message for specific protocol.
protected void	clean()	Cleans internal state.
Future<Void>	close()
protected void	emitOnMessageReceived(Message message)
String	getEventQueue()
private Message	getMessage(ByteBuffer buffer, int read)
String	getRequestQueue()
String	getResponseQueue()
private void	logMessageInTrace(byte[] message)
protected void	processIncoming()	Process incoming channel.
(package private) void	processMessage(Message message)
void	send(byte[] message)
protected void	sendHeartbeat()	Client sends protocol specific heartbeat message
void	sendNow(byte[] message)
private void	updateOps()
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, now, performAction, postConnect, postDisconnect, process, processOutgoing, read, removeEventListener, scheduleTask, sendMessage, setClientPolicy, updateInterestedOps, updateLastIncomingHeartbeat, updateLastOutgoingHeartbeat, write

Methods inherited from class java.lang.Object

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

Field Details

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

LOG

private static final org.slf4j.Logger LOG

Constructor Details

StompCommonClient

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

Method Details

send

public void send(byte[] message)

logMessageInTrace

private void logMessageInTrace(byte[] message)

updateOps

private void updateOps()

sendNow

public void sendNow(byte[] message)

processMessage

void processMessage(Message 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.

getMessage

private Message getMessage(ByteBuffer buffer,
 int read)
                    throws ClientConnectionException

Throws:

ClientConnectionException

clean

protected void clean()

Description copied from class: ReactorClient

Cleans internal state.

Specified by:

clean in class ReactorClient

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

Parameters:

policy - - validated policy

getRequestQueue

public String getRequestQueue()

getResponseQueue

public String getResponseQueue()

getEventQueue

public String getEventQueue()