services.moleculer.web.router

Class ActionInvoker

java.lang.Object

services.moleculer.web.router.ActionInvoker

All Implemented Interfaces:

HttpConstants, RequestProcessor

public class ActionInvoker
extends java.lang.Object
implements RequestProcessor, HttpConstants

Field Summary

Fields

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

Fields inherited from interface services.moleculer.web.common.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 and Description

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

Method Summary

Modifier and Type	Method and 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, java.lang.String contentType)
protected void	parseQueryString(io.datatree.Tree params, java.lang.String query)
protected void	parseTextPlain(io.datatree.Tree params, java.lang.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 java.lang.Object

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

Field Detail

EMPTY_RESPONSE

protected static final byte[] EMPTY_RESPONSE

logger

protected static final org.slf4j.Logger logger

actionName

protected final java.lang.String actionName

pattern

protected final java.util.regex.Pattern pattern

cache

protected final io.datatree.dom.Cache<java.lang.String,java.util.regex.Matcher> cache

variables

protected final IndexedVariable[] variables

opts

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

nodeID

protected final java.lang.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 java.util.concurrent.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 java.util.concurrent.ConcurrentHashMap<java.lang.String,CachedMessages> messageCache

Constructor Detail

ActionInvoker

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

Method Detail

service

public void service(WebRequest req,
                    WebResponse rsp)
             throws java.lang.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:

java.lang.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,
                                         java.lang.String contentType)
                                  throws java.lang.Exception

Throws:

java.lang.Exception

parseTextPlain

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

Throws:

java.io.UnsupportedEncodingException

parseQueryString

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

Throws:

java.io.UnsupportedEncodingException

sendResponse

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

Throws:

java.lang.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