org.apache.cxf.transport.http
Class AbstractHTTPDestination
java.lang.Object
org.apache.cxf.transport.AbstractObservable
org.apache.cxf.transport.AbstractDestination
org.apache.cxf.transport.AbstractMultiplexDestination
org.apache.cxf.transport.http.AbstractHTTPDestination
- All Implemented Interfaces:
- Configurable, Assertor, Destination, DestinationWithEndpoint, MultiplexDestination, Observable
- Direct Known Subclasses:
- JettyHTTPDestination, NettyHttpDestination, ServletDestination
public abstract class AbstractHTTPDestination
- extends AbstractMultiplexDestination
- implements Configurable, Assertor
Common base for HTTP Destination implementations.
Method Summary |
protected void |
activate()
Activate messages flow. |
void |
assertMessage(Message message)
|
boolean |
canAssert(QName type)
|
protected boolean |
contextMatchOnExact()
|
protected void |
deactivate()
Deactivate messages flow. |
void |
finalizeConfig()
|
protected OutputStream |
flushHeaders(Message outMessage)
|
protected OutputStream |
flushHeaders(Message outMessage,
boolean getStream)
|
protected static EndpointInfo |
getAddressValue(EndpointInfo ei)
|
protected static EndpointInfo |
getAddressValue(EndpointInfo ei,
boolean dp)
|
EndpointReferenceType |
getAddressWithId(String id)
Builds an new endpoint reference using the current target reference as a template. |
protected String |
getBasePath(String contextPath)
|
String |
getBeanName()
Get the configurable object's Bean name |
Bus |
getBus()
|
String |
getContextMatchStrategy()
|
String |
getId(Map<String,Object> context)
Obtain id from reference parameters of the ws-a to address
Requires the existance of ws-a interceptors on dispatch path to provide access
to the ws-a headers |
protected Conduit |
getInbuiltBackChannel(Message inMessage)
|
String |
getPath()
|
HTTPServerPolicy |
getServer()
|
void |
invoke(javax.servlet.ServletConfig config,
javax.servlet.ServletContext context,
javax.servlet.http.HttpServletRequest req,
javax.servlet.http.HttpServletResponse resp)
|
protected void |
invokeComplete(javax.servlet.ServletContext context,
javax.servlet.http.HttpServletRequest req,
javax.servlet.http.HttpServletResponse resp,
Message m)
|
boolean |
isFixedParameterOrder()
|
boolean |
isMultiplexWithAddress()
|
protected boolean |
isOneWay(Message message)
|
void |
releaseRegistry()
|
protected Message |
retrieveFromContinuation(javax.servlet.http.HttpServletRequest req)
|
protected Message |
retrieveFromServlet3Async(javax.servlet.http.HttpServletRequest req)
|
void |
setContextMatchStrategy(String contextMatchStrategy)
|
void |
setFixedParameterOrder(boolean fixedParameterOrder)
|
void |
setMultiplexWithAddress(boolean multiplexWithAddress)
|
void |
setServer(HTTPServerPolicy server)
|
protected void |
setupContinuation(Message inMessage,
javax.servlet.http.HttpServletRequest req,
javax.servlet.http.HttpServletResponse resp)
|
protected void |
setupMessage(Message inMessage,
javax.servlet.ServletConfig config,
javax.servlet.ServletContext context,
javax.servlet.http.HttpServletRequest req,
javax.servlet.http.HttpServletResponse resp)
|
void |
shutdown()
Shutdown the Destination, i.e. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
HTTP_REQUEST
public static final String HTTP_REQUEST
- See Also:
- Constant Field Values
HTTP_RESPONSE
public static final String HTTP_RESPONSE
- See Also:
- Constant Field Values
HTTP_CONTEXT
public static final String HTTP_CONTEXT
- See Also:
- Constant Field Values
HTTP_CONFIG
public static final String HTTP_CONFIG
- See Also:
- Constant Field Values
HTTP_CONTEXT_MATCH_STRATEGY
public static final String HTTP_CONTEXT_MATCH_STRATEGY
- See Also:
- Constant Field Values
RESPONSE_HEADERS_COPIED
public static final String RESPONSE_HEADERS_COPIED
- See Also:
- Constant Field Values
RESPONSE_COMMITED
public static final String RESPONSE_COMMITED
- See Also:
- Constant Field Values
REQUEST_REDIRECTED
public static final String REQUEST_REDIRECTED
- See Also:
- Constant Field Values
CXF_CONTINUATION_MESSAGE
public static final String CXF_CONTINUATION_MESSAGE
- See Also:
- Constant Field Values
CXF_ASYNC_CONTEXT
public static final String CXF_ASYNC_CONTEXT
- See Also:
- Constant Field Values
SERVICE_REDIRECTION
public static final String SERVICE_REDIRECTION
- See Also:
- Constant Field Values
bus
protected final Bus bus
registry
protected DestinationRegistry registry
path
protected final String path
serverPolicy
protected HTTPServerPolicy serverPolicy
contextMatchStrategy
protected String contextMatchStrategy
fixedParameterOrder
protected boolean fixedParameterOrder
multiplexWithAddress
protected boolean multiplexWithAddress
certConstraints
protected CertConstraints certConstraints
isServlet3
protected boolean isServlet3
cproviderFactory
protected ContinuationProviderFactory cproviderFactory
enableWebSocket
protected boolean enableWebSocket
AbstractHTTPDestination
public AbstractHTTPDestination(Bus b,
DestinationRegistry registry,
EndpointInfo ei,
String path,
boolean dp)
throws IOException
- Constructor
- Parameters:
b
- the associated Busci
- the associated conduit initiatorei
- the endpoint info of the destinationdp
- true for adding the default port if it is missing
- Throws:
IOException
getBus
public Bus getBus()
isOneWay
protected final boolean isOneWay(Message message)
- Parameters:
message
- the message under consideration
- Returns:
- true iff the message has been marked as oneway
invoke
public void invoke(javax.servlet.ServletConfig config,
javax.servlet.ServletContext context,
javax.servlet.http.HttpServletRequest req,
javax.servlet.http.HttpServletResponse resp)
throws IOException
- Throws:
IOException
invokeComplete
protected void invokeComplete(javax.servlet.ServletContext context,
javax.servlet.http.HttpServletRequest req,
javax.servlet.http.HttpServletResponse resp,
Message m)
throws IOException
- Throws:
IOException
setupMessage
protected void setupMessage(Message inMessage,
javax.servlet.ServletConfig config,
javax.servlet.ServletContext context,
javax.servlet.http.HttpServletRequest req,
javax.servlet.http.HttpServletResponse resp)
throws IOException
- Throws:
IOException
retrieveFromContinuation
protected Message retrieveFromContinuation(javax.servlet.http.HttpServletRequest req)
retrieveFromServlet3Async
protected Message retrieveFromServlet3Async(javax.servlet.http.HttpServletRequest req)
setupContinuation
protected void setupContinuation(Message inMessage,
javax.servlet.http.HttpServletRequest req,
javax.servlet.http.HttpServletResponse resp)
getBasePath
protected String getBasePath(String contextPath)
throws IOException
- Throws:
IOException
getAddressValue
protected static EndpointInfo getAddressValue(EndpointInfo ei)
getAddressValue
protected static EndpointInfo getAddressValue(EndpointInfo ei,
boolean dp)
getInbuiltBackChannel
protected Conduit getInbuiltBackChannel(Message inMessage)
- Specified by:
getInbuiltBackChannel
in class AbstractDestination
- Parameters:
inMessage
- the incoming message
- Returns:
- the inbuilt backchannel
flushHeaders
protected OutputStream flushHeaders(Message outMessage)
throws IOException
- Throws:
IOException
flushHeaders
protected OutputStream flushHeaders(Message outMessage,
boolean getStream)
throws IOException
- Throws:
IOException
contextMatchOnExact
protected boolean contextMatchOnExact()
finalizeConfig
public void finalizeConfig()
getBeanName
public String getBeanName()
- Description copied from interface:
Configurable
- Get the configurable object's Bean name
- Specified by:
getBeanName
in interface Configurable
- Returns:
- the bean name
getAddressWithId
public EndpointReferenceType getAddressWithId(String id)
- Description copied from class:
AbstractMultiplexDestination
- Builds an new endpoint reference using the current target reference as a template.
The supplied id is endcoded using a reference parameter.
This requires the ws-a interceptors to propagate the reference parameters
on subsequent invokes using the returned reference.
- Specified by:
getAddressWithId
in interface MultiplexDestination
- Overrides:
getAddressWithId
in class AbstractMultiplexDestination
- Parameters:
id
- the id to encode in the new reference
- Returns:
- the new reference with the id encoded as a reference parameter
- See Also:
MultiplexDestination.getAddressWithId(java.lang.String)
getId
public String getId(Map<String,Object> context)
- Description copied from class:
AbstractMultiplexDestination
- Obtain id from reference parameters of the ws-a to address
Requires the existance of ws-a interceptors on dispatch path to provide access
to the ws-a headers
- Specified by:
getId
in interface MultiplexDestination
- Overrides:
getId
in class AbstractMultiplexDestination
- Parameters:
context
- the current invocation or message context
- Returns:
- the id from the reference parameters of the ws-a-to address or null if not found
- See Also:
MultiplexDestination.getId(java.util.Map)
getContextMatchStrategy
public String getContextMatchStrategy()
setContextMatchStrategy
public void setContextMatchStrategy(String contextMatchStrategy)
isFixedParameterOrder
public boolean isFixedParameterOrder()
setFixedParameterOrder
public void setFixedParameterOrder(boolean fixedParameterOrder)
isMultiplexWithAddress
public boolean isMultiplexWithAddress()
setMultiplexWithAddress
public void setMultiplexWithAddress(boolean multiplexWithAddress)
getServer
public HTTPServerPolicy getServer()
setServer
public void setServer(HTTPServerPolicy server)
assertMessage
public void assertMessage(Message message)
- Specified by:
assertMessage
in interface Assertor
canAssert
public boolean canAssert(QName type)
- Specified by:
canAssert
in interface Assertor
releaseRegistry
public void releaseRegistry()
getPath
public String getPath()
activate
protected void activate()
- Description copied from class:
AbstractObservable
- Activate messages flow.
- Overrides:
activate
in class AbstractObservable
deactivate
protected void deactivate()
- Description copied from class:
AbstractObservable
- Deactivate messages flow.
- Overrides:
deactivate
in class AbstractObservable
shutdown
public void shutdown()
- Description copied from class:
AbstractDestination
- Shutdown the Destination, i.e. stop accepting incoming messages.
- Specified by:
shutdown
in interface Destination
- Overrides:
shutdown
in class AbstractDestination
Apache CXF