All Classes and Interfaces
Class
Description
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
The acknowledgement mode return by the message consumer
APIResource is the abstract implementation of a Resource in an Internal API.Copyright (c) 2015, WSO2 Inc.
Data source implementation wrapping a JMS
BytesMessage.Input stream that reads data from a JMS
BytesMessage.Copyright (c) 2015, WSO2 Inc.
ConfigurationLoader contains utilities to load configuration file content required for Internal APIs
implementation.Constants contains constants related to internal http api implementation.Core listener class which uses core NATS connection to receive messages.
This class is responsible for starting Listeners( like HTTP, HTTPS, HL7) on server startup for
Listening Inbound Endpoints.
Copyright (c) 2015, WSO2 Inc.
Copyright (c) 2015, WSO2 Inc.
Copyright (c) 2015, WSO2 Inc.
This interface represents an implementation of a preprocessor which is used to modify the incoming
HL7 message before parsing.
Copyright (c) 2015, WSO2 Inc.
Manager which handles Http Listeners activities for Inbound Endpoints, coordinating
with Pass-through APIs and registry etc.
Extends
InboundHttpServerWorker with correlation logs enabled.Listener class for HttpInboundEndpoint which is trigger by inbound core and
responsible for start ListeningEndpoint related to given port
Get mediated message context from Source Response Worker and created InboundHttpSourceResponse
extract the pipe and set to the reader
Create SynapseMessageContext from HTTP Request and inject it to the sequence in a synchronous manner
This is the worker for HTTP inbound related requests.
Handler Class for process HTTP Requests
Listener class for NATS Inbound Endpoint which is triggered by inbound core
This class provides the common implementation for one time trigger protocol processors
Implemented the support if message injection happens in a separate thread.
Class responsible for providing the implementation of the request processor according to the protocol.
This class provides the common implementation for polling protocol processors
InboundRunner class is used to run the non coordinated processors in
background according to the scheduled interval
This class provides Generic Task implementation for inbound polling
InternalAPI is the interface that need to be implemented in order to register an internal API into EI.InternalAPIDispatcher takes care of dispatching messages received over the internal inbound endpoint into
relevant InternalAPI.InternalAPIHandler is the interface that need to be implemented in order to set handlers to an internal API.use of factory server down and up jms spec transport.jms.MessageSelector
isDurable
Common constants used by inbound JMS protocol
JMSInjectHandler use to mediate the received JMS message
JMSTask class is used to schedule the inbound execution when the coordination
is required
Maintain the common methods used by inbound JMS protocol
The constant parameters for kafka protocol
KafkaInjectHandler uses to mediate the received Kafka message
Copyright (c) 2015, WSO2 Inc.
Copyright (c) 2015, WSO2 Inc.
MQTT Asynchronous call back handler
Reference Holder for MQTT clients in existence per ESB Server instance
Connection consumer for MQTT listener which delegates connection attempts and subscription
from the MQTT inbound listener
MQTT factory, return instances of asynchronous clients
MQTT connection Listener bounded per MQTT client, this the listener registered per client
when mqtt connection is being made.
MQTT Constants
Inject mqtt message into the sequence
This is the listener which directly interacts with the external MQTT server.
MQTT task for support coordination.
Constant parameters and default values for NATS and NATS Streaming protocol.
Manager which handles NATS Listeners activities for Inbound Endpoints.
Inject handler to inject NATS message into the sequence.
Message consumer for NATS to initialize connection and listen for messages.
The interface which defines behaviour of a core NATS or NATS streaming connection.
Send the Reply from the Respond Mediator using this class (only for core NATS).
Generic callback implementation for one time trigger inbound endpoints.
OnetimeTriggerInboundRunner class is used to run the non coordinated processors in
background.
This class provides Generic Task implementation for one time trigger Inbound Endpoint Tasks
This class builds a ChannelHandler instance from the pipeline handler String
given in the configuration file
Define the common properties shared by all polling inbound endpoints
Encapsulate a RabbitMQ AMQP Connection factory definition within an inbound configuration
Holds constants for RabbitMQ Inbound Endpoint Implementation
The actual tasks that perform message consuming
This class represents RabbitMQ specific exceptions
The received messages will be injected into the sequence for the mediation.
The listener implementation to initialize the RabbitMQ consumer once with inbound parameters.
Logging notifications about completed automatic connection recovery
The task implementation to trigger the RabbitMQ consumer.
Helper class to support AMQP inbound endpoint related functions
This class is an example of a Pipeline Handler
Streaming listener class which uses NATS streaming connection to receive messages.
This class is used to log the websocket access logs
This class is used for managing logging the access logs of the WebSocket APIs.
This class will be used log the websocket communication related requests/frames between client and the gateway.
Wrapping class for Inbound Worker Pool Configs