org.pentaho.di.trans.ael.websocket

Class DaemonMessagesClientEndpoint

java.lang.Object

javax.websocket.Endpoint

org.pentaho.di.trans.ael.websocket.DaemonMessagesClientEndpoint

public class DaemonMessagesClientEndpoint
extends javax.websocket.Endpoint

Created by fcamara on 8/17/17.

Constructor Summary

Constructors

Constructor and Description
DaemonMessagesClientEndpoint(String host, String port, boolean ssl, MessageEventService messageEventService)

Method Summary

Modifier and Type	Method and Description
void	close(String message) Close the session informing the reason.
void	onClose(javax.websocket.Session userSession, javax.websocket.CloseReason reason) Callback hook for Connection close events.
void	onError(javax.websocket.Session userSession, Throwable thr) Callback hook for Connection close events.
void	onOpen(javax.websocket.Session userSession, javax.websocket.EndpointConfig endpointConfig) Callback hook for Connection open events.
void	sendMessage(org.pentaho.di.engine.api.remote.ExecutionRequest request) Send a execution request message.
void	sendMessage(org.pentaho.di.engine.api.remote.StopMessage stopMessage) Send a stop message to server as result of user request.
void	sessionValid() Validates if the session is open.

Methods inherited from class java.lang.Object

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

Constructor Detail

DaemonMessagesClientEndpoint

public DaemonMessagesClientEndpoint(String host,
                                    String port,
                                    boolean ssl,
                                    MessageEventService messageEventService)
                             throws KettleException

Throws:

KettleException

Method Detail

onOpen

public void onOpen(javax.websocket.Session userSession,
                   javax.websocket.EndpointConfig endpointConfig)

Callback hook for Connection open events.

Specified by:

onOpen in class javax.websocket.Endpoint

Parameters:

userSession - the userSession which is opened.

onClose

public void onClose(javax.websocket.Session userSession,
                    javax.websocket.CloseReason reason)

Callback hook for Connection close events.

Overrides:

onClose in class javax.websocket.Endpoint

Parameters:

userSession - the userSession which is getting closed.

reason - the reason for connection close

onError

public void onError(javax.websocket.Session userSession,
                    Throwable thr)

Callback hook for Connection close events.

Overrides:

onError in class javax.websocket.Endpoint

Parameters:

userSession - the userSession which is getting closed.

thr - throwable

sendMessage

public void sendMessage(org.pentaho.di.engine.api.remote.ExecutionRequest request)
                 throws KettleException

Send a execution request message.

Throws:

KettleException

sendMessage

public void sendMessage(org.pentaho.di.engine.api.remote.StopMessage stopMessage)
                 throws KettleException

Send a stop message to server as result of user request.

Throws:

KettleException

close

public void close(String message)
           throws KettleException

Close the session informing the reason.

Throws:

KettleException

sessionValid

public void sessionValid()
                  throws KettleException

Validates if the session is open.

Throws:

KettleException