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
protected ByteBuffer	headerBuffer
protected Message	message
static String	REQUEST_QUEUE
static String	RESPONSE_QUEUE
protected CountDownLatch	subscribed
protected String	subscribtionId

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)
protected void	processIncoming() Process incoming channel.
void	send(byte[] message)

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

addEventListener, connect, disconnect, emitOnMessageReceived, getClientId, getHostname, getPostConnectCallback, getRetryPolicy, getSelectionKey, isInInit, isOpen, postDisconnect, process, processOutgoing, read, removeEventListener, scheduleTask, sendMessage, setRetryPolicy, updateInterestedOps, updateLastHeartbeat

Methods inherited from class java.lang.Object

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

Field Detail

REQUEST_QUEUE

public static final String REQUEST_QUEUE

See Also:

Constant Field Values

RESPONSE_QUEUE

public static final String RESPONSE_QUEUE

See Also:

Constant Field Values

headerBuffer

protected ByteBuffer headerBuffer

message

protected Message message

connected

protected CountDownLatch connected

subscribed

protected CountDownLatch subscribed

subscribtionId

protected String subscribtionId

Constructor Detail

StompCommonClient

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

Method Detail

send

public void send(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