org.apache.nifi.websocket

Interface WebSocketService

All Superinterfaces:

ConfigurableComponent, ControllerService

All Known Subinterfaces:

WebSocketClientService, WebSocketServerService

All Known Implementing Classes:

AbstractJettyWebSocketService, AbstractWebSocketService, JettyWebSocketClient, JettyWebSocketServer

public interface WebSocketService
extends ControllerService

Control an embedded WebSocket service instance.

Field Summary

Fields

Modifier and Type	Field and Description
static PropertyDescriptor	SSL_CONTEXT

Method Summary

Modifier and Type	Method and Description
void	deregisterProcessor(java.lang.String endpointId, Processor processor)
boolean	isProcessorRegistered(java.lang.String endpointId, Processor processor)
void	registerProcessor(java.lang.String endpointId, Processor processor)
void	sendMessage(java.lang.String endpointId, java.lang.String sessionId, SendMessage sendMessage)

Methods inherited from interface org.apache.nifi.controller.ControllerService

initialize

Methods inherited from interface org.apache.nifi.components.ConfigurableComponent

getIdentifier, getPropertyDescriptor, getPropertyDescriptors, onPropertyModified, validate

Field Detail

SSL_CONTEXT

static final PropertyDescriptor SSL_CONTEXT

Method Detail

registerProcessor

void registerProcessor(java.lang.String endpointId,
                       Processor processor)
                throws WebSocketConfigurationException

Throws:

WebSocketConfigurationException

isProcessorRegistered

boolean isProcessorRegistered(java.lang.String endpointId,
                              Processor processor)

deregisterProcessor

void deregisterProcessor(java.lang.String endpointId,
                         Processor processor)
                  throws WebSocketConfigurationException

Throws:

WebSocketConfigurationException

sendMessage

void sendMessage(java.lang.String endpointId,
                 java.lang.String sessionId,
                 SendMessage sendMessage)
          throws java.io.IOException,
                 WebSocketConfigurationException

Throws:

java.io.IOException

WebSocketConfigurationException