All Classes Interface Summary Class Summary Enum Summary Exception Summary
Class |
Description |
AbstractInboundEndpointManager |
|
AbstractKafkaMessageListener |
|
AbstractKafkaMessageListener.CONSUMER_TYPE |
the consumer types are high level and simple,high level is used for kafka high level configuration
and simple is used for kafka low level configuration
|
AbstractSubprotocolHandler |
|
AcknowledgementMode |
The acknowledgement mode return by the message consumer
|
APIResource |
APIResource is the abstract implementation of a Resource in an Internal API.
|
Axis2HL7Constants |
Copyright (c) 2015, WSO2 Inc.
|
Axis2HL7Constants.MessageEncoding |
|
Axis2HL7Constants.MessageType |
|
BytesMessageDataSource |
Data source implementation wrapping a JMS BytesMessage .
|
BytesMessageInputStream |
Input stream that reads data from a JMS BytesMessage .
|
BytesMessageOutputStream |
|
CachedJMSConnectionFactory |
|
CallableTask |
Copyright (c) 2015, WSO2 Inc.
|
ConfigurationLoader |
ConfigurationLoader contains utilities to load configuration file content required for Internal APIs
implementation.
|
Constants |
Constants contains constants related to internal http api implementation.
|
CoreListener |
Core listener class which uses core NATS connection to receive messages.
|
EchoSubprotocolHandler |
|
EndpointListenerLoader |
This class is responsible for starting Listeners( like HTTP, HTTPS, HL7) on server startup for
Listening Inbound Endpoints.
|
GenericConstants |
|
GenericEventBasedConsumer |
|
GenericEventBasedListener |
|
GenericInboundListener |
|
GenericOneTimeTask |
|
GenericPollingConsumer |
|
GenericProcessor |
|
GenericTask |
|
HL7Codec |
|
HL7Configuration |
Copyright (c) 2015, WSO2 Inc.
|
HL7EndpointManager |
Copyright (c) 2015, WSO2 Inc.
|
HL7ExecutorServiceFactory |
Copyright (c) 2015, WSO2 Inc.
|
HL7MessagePreprocessor |
This interface represents an implementation of a preprocessor which is used to modify the incoming
HL7 message before parsing.
|
HL7MessageUtils |
|
HL7Processor |
Copyright (c) 2015, WSO2 Inc.
|
HTTPEndpointManager |
Manager which handles Http Listeners activities for Inbound Endpoints, coordinating
with Pass-through APIs and registry etc.
|
HttpWebsocketEndpointManager |
|
InboundCorrelationEnabledHttpServerWorker |
|
InboundEndpointManager |
|
InboundHL7IOReactor |
|
InboundHL7Listener |
|
InboundHttpConfiguration |
|
InboundHttpConfiguration.InboundHttpConfigurationBuilder |
|
InboundHttpConstants |
|
InboundHttpListener |
Listener class for HttpInboundEndpoint which is trigger by inbound core and
responsible for start ListeningEndpoint related to given port
|
InboundHttpResponseSender |
Get mediated message context from Source Response Worker and created InboundHttpSourceResponse
extract the pipe and set to the reader
|
InboundHttpServerWorker |
Create SynapseMessageContext from HTTP Request and inject it to the sequence in a synchronous manner
This is the worker for HTTP inbound related requests.
|
InboundHttpsListener |
|
InboundHttpSourceHandler |
Handler Class for process HTTP Requests
|
InboundHttpsSecureWebsocketListener |
|
InboundHttpWebSocketConstants |
|
InboundHttpWebsocketListener |
|
InboundNatsListener |
Listener class for NATS Inbound Endpoint which is triggered by inbound core
|
InboundOneTimeTriggerEventBasedProcessor |
|
InboundOneTimeTriggerRequestProcessor |
This class provides the common implementation for one time trigger protocol processors
Implemented the support if message injection happens in a separate thread.
|
InboundRequestProcessorFactoryImpl |
Class responsible for providing the implementation of the request processor according to the protocol.
|
InboundRequestProcessorFactoryImpl.Protocols |
|
InboundRequestProcessorImpl |
This class provides the common implementation for polling protocol processors
|
InboundRunner |
InboundRunner class is used to run the non coordinated processors in
background according to the scheduled interval
|
InboundSecureWebsocketListener |
|
InboundTask |
This class provides Generic Task implementation for inbound polling
|
InboundWebsocketChannelContext |
|
InboundWebsocketChannelInitializer |
|
InboundWebsocketConfiguration |
|
InboundWebsocketConfiguration.InboundWebsocketConfigurationBuilder |
|
InboundWebsocketConstants |
|
InboundWebsocketEventExecutor |
|
InboundWebsocketListener |
|
InboundWebsocketResponseSender |
|
InboundWebsocketSourceHandler |
|
InboundWebsocketSSLConfiguration |
|
InboundWebsocketSSLConfiguration.SSLConfigurationBuilder |
|
InjectHandler |
|
InternalAPI |
InternalAPI is the interface that need to be implemented in order to register an internal API into EI.
|
InternalAPIDispatcher |
InternalAPIDispatcher takes care of dispatching messages received over the internal inbound endpoint into
relevant InternalAPI .
|
InternalAPIHandler |
InternalAPIHandler is the interface that need to be implemented in order to set handlers to an internal API.
|
JMSConnectionFactory |
use of factory server down and up jms spec transport.jms.MessageSelector
isDurable
|
JMSConstants |
Common constants used by inbound JMS protocol
|
JMSConstants.JMSDestinationType |
|
JMSExceptionWrapper |
|
JMSInjectHandler |
JMSInjectHandler use to mediate the received JMS message
|
JMSPollingConsumer |
|
JMSProcessor |
|
JMSReplySender |
|
JMSTask |
JMSTask class is used to schedule the inbound execution when the coordination
is required
|
JMSUtils |
Maintain the common methods used by inbound JMS protocol
|
KAFKAConstants |
The constant parameters for kafka protocol
|
KAFKAInjectHandler |
KafkaInjectHandler uses to mediate the received Kafka message
|
KAFKAMessageListener |
|
KAFKAPollingConsumer |
|
KAFKAProcessor |
|
KAFKATask |
|
MLLPConstants |
|
MLLPConstants.TCPConstants |
|
MLLPContext |
|
MLLPContextFactory |
Copyright (c) 2015, WSO2 Inc.
|
MLLProtocolException |
Copyright (c) 2015, WSO2 Inc.
|
MLLPSourceHandler |
|
MqttAsyncCallback |
MQTT Asynchronous call back handler
|
MqttClientManager |
Reference Holder for MQTT clients in existence per ESB Server instance
|
MqttConnectionConsumer |
Connection consumer for MQTT listener which delegates connection attempts and subscription
from the MQTT inbound listener
|
MqttConnectionFactory |
MQTT factory, return instances of asynchronous clients
|
MqttConnectionListener |
MQTT connection Listener bounded per MQTT client, this the listener registered per client
when mqtt connection is being made.
|
MqttConstants |
MQTT Constants
|
MqttInjectHandler |
Inject mqtt message into the sequence
|
MqttListener |
This is the listener which directly interacts with the external MQTT server.
|
MqttTask |
MQTT task for support coordination.
|
MultiIOHandler |
|
NatsConstants |
Constant parameters and default values for NATS and NATS Streaming protocol.
|
NatsEndpointManager |
Manager which handles NATS Listeners activities for Inbound Endpoints.
|
NatsInjectHandler |
Inject handler to inject NATS message into the sequence.
|
NatsMessageConsumer |
Message consumer for NATS to initialize connection and listen for messages.
|
NatsMessageListener |
The interface which defines behaviour of a core NATS or NATS streaming connection.
|
NatsReplySender |
Send the Reply from the Respond Mediator using this class (only for core NATS).
|
NettyThreadPoolConfiguration |
|
OneTimeTriggerAbstractCallback |
Generic callback implementation for one time trigger inbound endpoints.
|
OneTimeTriggerInboundRunner |
OnetimeTriggerInboundRunner class is used to run the non coordinated processors in
background.
|
OneTimeTriggerInboundTask |
This class provides Generic Task implementation for one time trigger Inbound Endpoint Tasks
|
PinnedPollingTask |
|
PipelineHandlerBuilderUtil |
This class builds a ChannelHandler instance from the pipeline handler String
given in the configuration file
|
PollingConstants |
Define the common properties shared by all polling inbound endpoints
|
RabbitMQConnectionFactory |
Encapsulate a RabbitMQ AMQP Connection factory definition within an inbound configuration
|
RabbitMQConstants |
Holds constants for RabbitMQ Inbound Endpoint Implementation
|
RabbitMQConsumer |
The actual tasks that perform message consuming
|
RabbitMQException |
This class represents RabbitMQ specific exceptions
|
RabbitMQInjectHandler |
The received messages will be injected into the sequence for the mediation.
|
RabbitMQListener |
The listener implementation to initialize the RabbitMQ consumer once with inbound parameters.
|
RabbitMQRecoveryListener |
Logging notifications about completed automatic connection recovery
|
RabbitMQTask |
The task implementation to trigger the RabbitMQ consumer.
|
RabbitMQUtils |
Helper class to support AMQP inbound endpoint related functions
|
SamplePipelineHandler |
This class is an example of a Pipeline Handler
|
SimpleKafkaMessageListener |
|
SSLHandlerFactory |
|
StreamingListener |
Streaming listener class which uses NATS streaming connection to receive messages.
|
SubprotocolBuilderUtil |
|
WebsocketEndpointManager |
|
WebsocketEventExecutorManager |
|
WebsocketLogUtil |
This class will be used log the websocket communication related requests/frames between client and the gateway.
|
WebsocketSubscriberPathManager |
|
WorkerPoolConfiguration |
Wrapping class for Inbound Worker Pool Configs
|