Class ActionInvoker

java.lang.Object

services.moleculer.web.router.ActionInvoker

All Implemented Interfaces:

HttpConstants, RequestProcessor

public class ActionInvoker
extends Object
implements RequestProcessor, HttpConstants

Field Summary

Fields

Modifier and Type	Field	Description
protected final String	actionName
protected final CallProcessor	afterCall
protected final CallProcessor	beforeCall
protected final io.datatree.dom.Cache<String,Matcher>	cache
protected static final byte[]	EMPTY_RESPONSE
protected final services.moleculer.eventbus.Eventbus	eventbus
protected final ExecutorService	executor
protected final io.datatree.dom.TreeWriter	jsonSerializer
protected static final org.slf4j.Logger	logger
protected final ConcurrentHashMap<String, CachedMessages>	messageCache
protected final MessageLoader	messageLoader
protected final String	nodeID
protected final services.moleculer.context.CallOptions.Options	opts
protected final Pattern	pattern
protected final Route	route
protected final services.moleculer.service.ServiceInvoker	serviceInvoker
protected final AbstractTemplateEngine	templateEngine
protected final services.moleculer.uid.UidGenerator	uidGenerator
protected final IndexedVariable[]	variables

Fields inherited from interface HttpConstants

ACCEPT, ACCEPT_ENCODING, AUTHORIZATION, CACHE_CONTROL, CHUNKED, CLOSE, CONNECT, CONNECTION, CONTENT_ENCODING, CONTENT_LENGTH, CONTENT_TYPE, CONTENT_TYPE_HTML, CONTENT_TYPE_JSON, COOKIE, DEFLATE, DELETE, ETAG, GET, GZIP, HEAD, IF_NONE_MATCH, KEEP_ALIVE, LOCATION, META_CONTENT_TYPE, META_HEADERS, META_LOCALE, META_LOCATION, META_SESSION, META_STATUS, META_TEMPLATE, NO_CACHE, OPTIONS, PATCH, POST, PROPERTY_COOKIES, PROPERTY_SESSION_ID, PROPERTY_USER, PUT, SET_COOKIE, TRACE, TRANSFER_ENCODING, WWW_AUTHENTICATE, X_FORWARDED_FOR

Constructor Summary

Constructors

Constructor

Description

ActionInvoker(String actionName, Pattern pattern, io.datatree.dom.Cache<String,Matcher> cache, IndexedVariable[] variables, services.moleculer.context.CallOptions.Options opts, services.moleculer.service.ServiceInvoker serviceInvoker, AbstractTemplateEngine templateEngine, Route route, CallProcessor beforeCall, CallProcessor afterCall, ExecutorService executor, services.moleculer.eventbus.Eventbus eventbus)

Method Summary

Modifier and Type	Method	Description
RequestProcessor	getParent()	Returns the next RequestProcessor in the invocation chain.
protected io.datatree.Tree	insertMessages(io.datatree.Tree data, io.datatree.Tree meta)
protected boolean	invokeBeforeCall(WebRequest req, WebResponse rsp, io.datatree.Tree data)
protected io.datatree.Tree	parsePostBody(io.datatree.Tree params, byte[] bytes, String contentType)
protected void	parseQueryString(io.datatree.Tree params, String query)
protected void	parseTextPlain(io.datatree.Tree params, String query)
protected void	sendResponse(WebRequest req, WebResponse rsp, io.datatree.Tree data)
void	service(WebRequest req, WebResponse rsp)	Handles request of the HTTP client.

Methods inherited from class Object

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

Field Details

EMPTY_RESPONSE

protected static final byte[] EMPTY_RESPONSE

logger

protected static final org.slf4j.Logger logger

actionName

protected final String actionName

pattern

protected final Pattern pattern

cache

protected final io.datatree.dom.Cache<String,Matcher> cache

variables

protected final IndexedVariable[] variables

opts

protected final services.moleculer.context.CallOptions.Options opts

nodeID

protected final String nodeID

serviceInvoker

protected final services.moleculer.service.ServiceInvoker serviceInvoker

jsonSerializer

protected final io.datatree.dom.TreeWriter jsonSerializer

route

protected final Route route

beforeCall

protected final CallProcessor beforeCall

afterCall

protected final CallProcessor afterCall

executor

protected final ExecutorService executor

templateEngine

protected final AbstractTemplateEngine templateEngine

messageLoader

protected final MessageLoader messageLoader

eventbus

protected final services.moleculer.eventbus.Eventbus eventbus

uidGenerator

protected final services.moleculer.uid.UidGenerator uidGenerator

messageCache

protected final ConcurrentHashMap<String, CachedMessages> messageCache

Constructor Details

ActionInvoker

public ActionInvoker(String actionName,
 Pattern pattern,
 io.datatree.dom.Cache<String,Matcher> cache,
 IndexedVariable[] variables,
 services.moleculer.context.CallOptions.Options opts,
 services.moleculer.service.ServiceInvoker serviceInvoker,
 AbstractTemplateEngine templateEngine,
 Route route,
 CallProcessor beforeCall,
 CallProcessor afterCall,
 ExecutorService executor,
 services.moleculer.eventbus.Eventbus eventbus)

Method Details

service

public void service(WebRequest req,
 WebResponse rsp)
             throws Exception

Handles request of the HTTP client.

Specified by:

service in interface RequestProcessor

Parameters:

req - WebRequest object that contains the request the client made of the ApiGateway

rsp - WebResponse object that contains the response the ApiGateway returns to the client

Throws:

Exception - if an input or output error occurs while the ApiGateway is handling the HTTP request

invokeBeforeCall

protected boolean invokeBeforeCall(WebRequest req,
 WebResponse rsp,
 io.datatree.Tree data)

parsePostBody

protected io.datatree.Tree parsePostBody(io.datatree.Tree params,
 byte[] bytes,
 String contentType)
                                  throws Exception

Throws:

Exception

parseTextPlain

protected void parseTextPlain(io.datatree.Tree params,
 String query)
                       throws UnsupportedEncodingException

Throws:

UnsupportedEncodingException

parseQueryString

protected void parseQueryString(io.datatree.Tree params,
 String query)
                         throws UnsupportedEncodingException

Throws:

UnsupportedEncodingException

sendResponse

protected void sendResponse(WebRequest req,
 WebResponse rsp,
 io.datatree.Tree data)
                     throws Exception

Throws:

Exception

insertMessages

protected io.datatree.Tree insertMessages(io.datatree.Tree data,
 io.datatree.Tree meta)

getParent

public RequestProcessor getParent()

Description copied from interface: RequestProcessor

Returns the next RequestProcessor in the invocation chain.

Specified by:

getParent in interface RequestProcessor

Returns:

parent processor