Class DefaultStreamInterceptor
- java.lang.Object
-
- org.apache.synapse.transport.passthru.DefaultStreamInterceptor
-
- All Implemented Interfaces:
StreamInterceptor
- Direct Known Subclasses:
LoggingStreamInterceptor
public abstract class DefaultStreamInterceptor extends Object implements StreamInterceptor
Default class implementing the methods ofStreamInterceptor
. A stream interceptor can be written by extending and overding the necessary methods of this class. For an example seeLoggingStreamInterceptor
-
-
Constructor Summary
Constructors Constructor Description DefaultStreamInterceptor()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addProperty(String name, Object value)
Add an interceptor propertyMap
getProperties()
Get all interceptor propertiesboolean
interceptSourceRequest(org.apache.axis2.context.MessageContext axisCtx)
Logic to determine whether to intercept the source requestboolean
interceptSourceResponse(org.apache.axis2.context.MessageContext axisCtx)
Logic to determine whether to intercept the source responseboolean
interceptTargetRequest(org.apache.axis2.context.MessageContext axisCtx)
Logic to determine whether to intercept the target requestboolean
interceptTargetResponse(org.apache.axis2.context.MessageContext axisCtx)
Logic to determine whether to intercept the target responseboolean
sourceRequest(ByteBuffer buffer, org.apache.axis2.context.MessageContext axisCtx)
Handles the request data coming in to the engine from the clientvoid
sourceResponse(ByteBuffer buffer, org.apache.axis2.context.MessageContext axisCtx)
Handles the response data leaving out of the enginevoid
targetRequest(ByteBuffer buffer, org.apache.axis2.context.MessageContext axisCtx)
Handles the request data leaving out of the engineboolean
targetResponse(ByteBuffer buffer, org.apache.axis2.context.MessageContext axisCtx)
Handles the response data coming in to the engine from the back end
-
-
-
Method Detail
-
interceptSourceRequest
public boolean interceptSourceRequest(org.apache.axis2.context.MessageContext axisCtx)
Description copied from interface:StreamInterceptor
Logic to determine whether to intercept the source request- Specified by:
interceptSourceRequest
in interfaceStreamInterceptor
- Parameters:
axisCtx
- associated axis2MsgCtx of the request- Returns:
- intercept source request or not
-
sourceRequest
public boolean sourceRequest(ByteBuffer buffer, org.apache.axis2.context.MessageContext axisCtx)
Description copied from interface:StreamInterceptor
Handles the request data coming in to the engine from the client- Specified by:
sourceRequest
in interfaceStreamInterceptor
- Parameters:
buffer
- copy of data entering inaxisCtx
- associated axis2MsgCtx- Returns:
- whether to continue reading the data or to close the connection
-
interceptTargetRequest
public boolean interceptTargetRequest(org.apache.axis2.context.MessageContext axisCtx)
Description copied from interface:StreamInterceptor
Logic to determine whether to intercept the target request- Specified by:
interceptTargetRequest
in interfaceStreamInterceptor
- Parameters:
axisCtx
- associated axis2MsgCtx of the request- Returns:
- intercept target request or not
-
targetRequest
public void targetRequest(ByteBuffer buffer, org.apache.axis2.context.MessageContext axisCtx)
Description copied from interface:StreamInterceptor
Handles the request data leaving out of the engine- Specified by:
targetRequest
in interfaceStreamInterceptor
- Parameters:
buffer
- copy of data being send outaxisCtx
- associated axis2MsgCtx
-
interceptTargetResponse
public boolean interceptTargetResponse(org.apache.axis2.context.MessageContext axisCtx)
Description copied from interface:StreamInterceptor
Logic to determine whether to intercept the target response- Specified by:
interceptTargetResponse
in interfaceStreamInterceptor
- Parameters:
axisCtx
- associated axis2MsgCtx of the response- Returns:
- intercept target response or not
-
targetResponse
public boolean targetResponse(ByteBuffer buffer, org.apache.axis2.context.MessageContext axisCtx)
Description copied from interface:StreamInterceptor
Handles the response data coming in to the engine from the back end- Specified by:
targetResponse
in interfaceStreamInterceptor
- Parameters:
buffer
- copy of data entering inaxisCtx
- associated axis2MsgCtx- Returns:
- whether to continue reading the data or to close the connection
-
interceptSourceResponse
public boolean interceptSourceResponse(org.apache.axis2.context.MessageContext axisCtx)
Description copied from interface:StreamInterceptor
Logic to determine whether to intercept the source response- Specified by:
interceptSourceResponse
in interfaceStreamInterceptor
- Parameters:
axisCtx
- associated axis2MsgCtx of the response- Returns:
- intercept source response or not
-
sourceResponse
public void sourceResponse(ByteBuffer buffer, org.apache.axis2.context.MessageContext axisCtx)
Description copied from interface:StreamInterceptor
Handles the response data leaving out of the engine- Specified by:
sourceResponse
in interfaceStreamInterceptor
- Parameters:
buffer
- copy of data leavingaxisCtx
- associated axis2MsgCtx
-
addProperty
public void addProperty(String name, Object value)
Description copied from interface:StreamInterceptor
Add an interceptor property- Specified by:
addProperty
in interfaceStreamInterceptor
- Parameters:
name
- property namevalue
- property value
-
getProperties
public Map getProperties()
Description copied from interface:StreamInterceptor
Get all interceptor properties- Specified by:
getProperties
in interfaceStreamInterceptor
- Returns:
- Map of handler properties
-
-