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

Class StompListener

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

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

All Implemented Interfaces:

Sender

public class StompListener
extends StompClient
implements Sender

Nested Class Summary

Nested classes/interfaces inherited from class org.ovirt.vdsm.jsonrpc.client.reactors.ReactorClient

ReactorClient.MessageListener

Field Summary

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, headerBuffer, message, REQUEST_QUEUE, RESPONSE_QUEUE, subscribed, 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
StompListener(Reactor reactor, Selector selector, String hostname, int port, SocketChannel socketChannel)

Method Summary

Methods

Modifier and Type	Method and Description
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.stomp.StompClient

getPostConnectCallback, isInInit

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

postDisconnect, read, updateInterestedOps

Methods inherited from class org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompCommonClient

buildNetworkResponse, close, emitOnMessageReceived, processIncoming, send

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

addEventListener, connect, disconnect, emitOnMessageReceived, getClientId, getHostname, getRetryPolicy, getSelectionKey, isOpen, process, processOutgoing, removeEventListener, scheduleTask, setRetryPolicy, updateLastHeartbeat

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

Constructor Detail

StompListener

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

Throws:

ClientConnectionException

Method Detail

sendMessage

public void sendMessage(byte[] message)

Description copied from class: ReactorClient

Sends message using provided byte array.

Overrides:

sendMessage in class StompClient

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 StompClient

Throws:

ClientConnectionException - when issues with connection.