Package com.predic8.membrane.core.exchange

Class Exchange

java.lang.Object

com.predic8.membrane.core.exchange.AbstractExchange

com.predic8.membrane.core.exchange.Exchange

public class Exchange
extends AbstractExchange

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ALLOW_SPDY
static final String	ALLOW_TCP
static final String	ALLOW_WEBSOCKET
static final String	API_KEY
static final String	HTTP_SERVLET_REQUEST
static final String	OAUTH2
static final String	SECURITY_SCHEMES
static final String	SNI_SERVER_NAME
static final String	SSL_CONTEXT
static final String	TRACK_NODE_STATUS
static final String	WS_ORIGINAL_EXCHANGE

Fields inherited from class com.predic8.membrane.core.exchange.AbstractExchange

properties, request, rule

Constructor Summary

Constructors

Constructor	Description
Exchange(Exchange original, AbstractHttpHandler handler)	For HttpResendRunnable
Exchange(AbstractHttpHandler handler)

Method Summary

Modifier and Type	Method	Description
void	block(Message msg)
void	blockRequestIfNeeded()
void	blockResponseIfNeeded()
boolean	canKeepConnectionAlive()
void	collectStatistics()
AbstractExchange	createSnapshot(Runnable bodyUpdatedCallback, BodyCollectingMessageObserver.Strategy strategy, long limit)
void	detach()	Prepares for long-term storage (for example, in-memory ExchangeStores).
Outcome	echo()
AbstractHttpHandler	getHandler()
long	getId()
String	getInboundProtocol()
Exception[]	getNodeExceptions()
int[]	getNodeStatusCodes()
String	getOriginalHostHeader()
String	getOriginalHostHeaderHost()
String	getOriginalHostHeaderPort()
String	getRequestURI()	Returns the relative original URI.
Map<String,String>	getStringProperties()
Connection	getTargetConnection()
void	setId(long id)
void	setNodeException(int tryCounter, Exception e)
void	setNodeExceptions(Exception[] nodeExceptions)
void	setNodeStatusCode(int tryCounter, int code)
void	setNodeStatusCodes(int[] nodeStatusCodes)
void	setOriginalHostHeader(String hostHeader)
void	setRequest(Request req)
void	setTargetConnection(Connection con)

Methods inherited from class com.predic8.membrane.core.exchange.AbstractExchange

addExchangeStoreListener, addExchangeViewerListener, estimateHeapSize, finishExchange, finishExchange, getDestinations, getErrorMessage, getHeapSizeEstimation, getInterceptorStack, getOriginalRequestUri, getProperties, getProperty, getProperty, getPublicUrl, getRemoteAddr, getRemoteAddrIp, getRequest, getRequestContentLength, getRequestContentType, getResponse, getResponseContentLength, getResponseContentType, getRule, getServer, getStatus, getStringProperty, getTime, getTimeReqReceived, getTimeReqSent, getTimeResReceived, getTimeResSent, informExchangeViewerOnRemoval, isForcedToStop, popInterceptorFromStack, pushInterceptorToStack, received, removeExchangeStoreListener, removeExchangeViewerListener, resetHeapSizeEstimation, setCompleted, setDestinations, setErrorMessage, setForceToStop, setInterceptorStack, setOriginalRequestUri, setProperties, setProperty, setReceived, setRemoteAddr, setRemoteAddrIp, setResponse, setRule, setStatus, setStopped, setTime, setTimeReqReceived, setTimeReqSent, setTimeResReceived, setTimeResSent, toString, updateCopy

Methods inherited from class java.lang.Object

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

Field Details

HTTP_SERVLET_REQUEST

public static final String HTTP_SERVLET_REQUEST

See Also:

• Constant Field Values

ALLOW_WEBSOCKET

public static final String ALLOW_WEBSOCKET

See Also:

• Constant Field Values

ALLOW_TCP

public static final String ALLOW_TCP

See Also:

• Constant Field Values

ALLOW_SPDY

public static final String ALLOW_SPDY

See Also:

• Constant Field Values

TRACK_NODE_STATUS

public static final String TRACK_NODE_STATUS

See Also:

• Constant Field Values

SSL_CONTEXT

public static final String SSL_CONTEXT

See Also:

• Constant Field Values

API_KEY

public static final String API_KEY

See Also:

• Constant Field Values

OAUTH2

public static final String OAUTH2

See Also:

• Constant Field Values

SNI_SERVER_NAME

public static final String SNI_SERVER_NAME

See Also:

• Constant Field Values

WS_ORIGINAL_EXCHANGE

public static final String WS_ORIGINAL_EXCHANGE

See Also:

• Constant Field Values

SECURITY_SCHEMES

public static final String SECURITY_SCHEMES

See Also:

• Constant Field Values

Constructor Details

Exchange

public Exchange(AbstractHttpHandler handler)

Exchange

public Exchange(Exchange original,
 AbstractHttpHandler handler)

For HttpResendRunnable

Parameters:

original - Exchange

Method Details

getHandler

public AbstractHttpHandler getHandler()

getOriginalHostHeaderHost

public String getOriginalHostHeaderHost()

blockRequestIfNeeded

public void blockRequestIfNeeded()
                          throws TerminateException

Throws:

TerminateException

blockResponseIfNeeded

public void blockResponseIfNeeded()
                           throws TerminateException

Throws:

TerminateException

block

public void block(Message msg)
           throws TerminateException

Throws:

TerminateException

getOriginalHostHeaderPort

public String getOriginalHostHeaderPort()

getOriginalHostHeader

public String getOriginalHostHeader()

setOriginalHostHeader

public void setOriginalHostHeader(String hostHeader)

setRequest

public void setRequest(Request req)

Overrides:

setRequest in class AbstractExchange

getTargetConnection

public Connection getTargetConnection()

setTargetConnection

public void setTargetConnection(Connection con)

collectStatistics

public void collectStatistics()

getRequestURI

public String getRequestURI()

Returns the relative original URI.

"original" meaning "as received by Membrane's transport".

To be used, for example, when generating self-referring web pages.

echo

public Outcome echo()
             throws IOException

Throws:

IOException

getStringProperties

public Map<String,String> getStringProperties()

setNodeStatusCode

public void setNodeStatusCode(int tryCounter,
 int code)

setNodeException

public void setNodeException(int tryCounter,
 Exception e)

detach

public void detach()

Description copied from class: AbstractExchange

Prepares for long-term storage (for example, in-memory ExchangeStores).

Overrides:

detach in class AbstractExchange

canKeepConnectionAlive

public boolean canKeepConnectionAlive()

getId

public long getId()

Specified by:

getId in class AbstractExchange

createSnapshot

public AbstractExchange createSnapshot(Runnable bodyUpdatedCallback,
 BodyCollectingMessageObserver.Strategy strategy,
 long limit)

Specified by:

createSnapshot in class AbstractExchange

setId

public void setId(long id)

getNodeStatusCodes

public int[] getNodeStatusCodes()

setNodeStatusCodes

public void setNodeStatusCodes(int[] nodeStatusCodes)

getNodeExceptions

public Exception[] getNodeExceptions()

setNodeExceptions

public void setNodeExceptions(Exception[] nodeExceptions)

getInboundProtocol

public String getInboundProtocol()