public class HttpUtils
extends java.lang.Object
Constructor and Description |
---|
HttpUtils() |
Modifier and Type | Method and Description |
---|---|
static void |
addTransportHeadersToTransportMessage(io.netty.handler.codec.http.HttpHeaders headers,
org.apache.axis2.context.MessageContext msgCtx) |
static void |
closeMessageOutputStreamQuietly(java.io.OutputStream messageOutputStream) |
static void |
copyContentFromInboundHttpCarbonMessage(org.wso2.transport.http.netty.message.HttpCarbonMessage inboundMsg,
org.wso2.transport.http.netty.message.HttpCarbonMessage outboundResponseMsg) |
static org.wso2.transport.http.netty.contractimpl.sender.channel.pool.ConnectionManager |
getConnectionManager() |
static org.wso2.transport.http.netty.message.HttpMessageDataStreamer |
getHttpMessageDataStreamer(org.wso2.transport.http.netty.message.HttpCarbonMessage outboundResponse)
Get the response data streamer that should be used for serializing data.
|
static boolean |
isCONNECTRequest(org.apache.axis2.context.MessageContext msgCtx) |
static boolean |
isFaultMessage(org.apache.axis2.context.MessageContext msgContext) |
static boolean |
isGETRequest(org.apache.axis2.context.MessageContext msgCtx) |
static boolean |
isHEADRequest(org.apache.axis2.context.MessageContext msgCtx) |
static boolean |
isNoEntityBodyRequest(org.apache.axis2.context.MessageContext msgCtx) |
static void |
populatePoolingConfig(org.wso2.transport.http.netty.contractimpl.sender.channel.pool.PoolConfiguration poolConfiguration) |
static void |
removeUnwantedHeadersFromInternalTransportHeadersMap(org.apache.axis2.context.MessageContext msgContext,
BaseConfiguration baseConfiguration)
RRemove unwanted headers from the http response of outgoing request.
|
static boolean |
requestHasEntityBody(org.wso2.transport.http.netty.message.HttpCarbonMessage httpCarbonMessage)
Checks if the given HttpCarbonMessage has an entity body.
|
static boolean |
sendFaultAsHTTP200(org.apache.axis2.context.MessageContext msgContext) |
static org.wso2.transport.http.netty.contract.HttpResponseFuture |
sendOutboundResponse(org.wso2.transport.http.netty.message.HttpCarbonMessage requestMsg,
org.wso2.transport.http.netty.message.HttpCarbonMessage responseMsg)
Invokes
HttpResponseFuture respond method to send the response back to the client. |
static void |
serializeBytes(java.io.OutputStream outputStream,
byte[] bytes) |
static void |
serializeDataUsingMessageFormatter(org.apache.axis2.context.MessageContext msgContext,
org.apache.axis2.transport.MessageFormatter messageFormatter,
java.io.OutputStream outputStream) |
static void |
setHostHeader(java.lang.String host,
int port,
io.netty.handler.codec.http.HttpHeaders headers,
org.apache.axis2.context.MessageContext msgCtx,
boolean isPreservedHeader) |
static void |
writeEmptyBody(java.io.OutputStream outputStream) |
public static org.wso2.transport.http.netty.contractimpl.sender.channel.pool.ConnectionManager getConnectionManager()
public static void populatePoolingConfig(org.wso2.transport.http.netty.contractimpl.sender.channel.pool.PoolConfiguration poolConfiguration)
public static void removeUnwantedHeadersFromInternalTransportHeadersMap(org.apache.axis2.context.MessageContext msgContext, BaseConfiguration baseConfiguration)
msgContext
- axis2 message contextbaseConfiguration
- configuration that has all the preserved header detailspublic static boolean isFaultMessage(org.apache.axis2.context.MessageContext msgContext)
public static boolean sendFaultAsHTTP200(org.apache.axis2.context.MessageContext msgContext)
public static boolean requestHasEntityBody(org.wso2.transport.http.netty.message.HttpCarbonMessage httpCarbonMessage)
httpCarbonMessage
- HttpCarbonMessage in which we need to check if an entity body is presentpublic static org.wso2.transport.http.netty.contract.HttpResponseFuture sendOutboundResponse(org.wso2.transport.http.netty.message.HttpCarbonMessage requestMsg, org.wso2.transport.http.netty.message.HttpCarbonMessage responseMsg) throws org.apache.axis2.AxisFault
HttpResponseFuture
respond method to send the response back to the client.requestMsg
- Represent the request messageresponseMsg
- Represent the corresponding responseorg.apache.axis2.AxisFault
public static org.wso2.transport.http.netty.message.HttpMessageDataStreamer getHttpMessageDataStreamer(org.wso2.transport.http.netty.message.HttpCarbonMessage outboundResponse)
outboundResponse
- Represents native responsepublic static void serializeDataUsingMessageFormatter(org.apache.axis2.context.MessageContext msgContext, org.apache.axis2.transport.MessageFormatter messageFormatter, java.io.OutputStream outputStream) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public static void serializeBytes(java.io.OutputStream outputStream, byte[] bytes) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public static void writeEmptyBody(java.io.OutputStream outputStream) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public static void copyContentFromInboundHttpCarbonMessage(org.wso2.transport.http.netty.message.HttpCarbonMessage inboundMsg, org.wso2.transport.http.netty.message.HttpCarbonMessage outboundResponseMsg)
public static void closeMessageOutputStreamQuietly(java.io.OutputStream messageOutputStream)
public static boolean isGETRequest(org.apache.axis2.context.MessageContext msgCtx)
public static boolean isHEADRequest(org.apache.axis2.context.MessageContext msgCtx)
public static boolean isCONNECTRequest(org.apache.axis2.context.MessageContext msgCtx)
public static boolean isNoEntityBodyRequest(org.apache.axis2.context.MessageContext msgCtx)
public static void addTransportHeadersToTransportMessage(io.netty.handler.codec.http.HttpHeaders headers, org.apache.axis2.context.MessageContext msgCtx)
public static void setHostHeader(java.lang.String host, int port, io.netty.handler.codec.http.HttpHeaders headers, org.apache.axis2.context.MessageContext msgCtx, boolean isPreservedHeader)
Copyright © 2005-2022 Apache Software Foundation. All Rights Reserved.