public abstract class AbstractHTTPDestination extends AbstractMultiplexDestination implements Configurable, Assertor
Modifier and Type | Class and Description |
---|---|
class |
AbstractHTTPDestination.BackChannelConduit
Backchannel conduit.
|
static class |
AbstractHTTPDestination.PrincipalAuthorizationPolicy |
AbstractDestination.AbstractBackChannelConduit
Modifier and Type | Field and Description |
---|---|
protected Bus |
bus |
protected CertConstraints |
certConstraints |
protected String |
contextMatchStrategy |
protected ContinuationProviderFactory |
cproviderFactory |
static String |
CXF_ASYNC_CONTEXT |
static String |
CXF_CONTINUATION_MESSAGE |
protected boolean |
enableWebSocket |
protected boolean |
fixedParameterOrder |
static String |
HTTP_CONFIG |
static String |
HTTP_CONTEXT |
static String |
HTTP_CONTEXT_MATCH_STRATEGY |
static String |
HTTP_REQUEST |
static String |
HTTP_RESPONSE |
protected boolean |
isServlet3 |
protected boolean |
multiplexWithAddress |
protected String |
path |
protected DestinationRegistry |
registry |
static String |
REQUEST_REDIRECTED |
static String |
RESPONSE_COMMITED |
static String |
RESPONSE_HEADERS_COPIED |
protected HTTPServerPolicy |
serverPolicy |
static String |
SERVICE_REDIRECTION |
endpointInfo, reference
incomingObserver
Constructor and Description |
---|
AbstractHTTPDestination(Bus b,
DestinationRegistry registry,
EndpointInfo ei,
String path,
boolean dp)
Constructor
|
Modifier and Type | Method and Description |
---|---|
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.
|
getAddress, getBackChannel, getEndpointInfo
getLogger, getMessageObserver, getTargetReference, getTargetReference, setMessageObserver
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getAddress, getBackChannel, getMessageObserver
setMessageObserver
public static final String HTTP_REQUEST
public static final String HTTP_RESPONSE
public static final String HTTP_CONTEXT
public static final String HTTP_CONFIG
public static final String HTTP_CONTEXT_MATCH_STRATEGY
public static final String RESPONSE_HEADERS_COPIED
public static final String RESPONSE_COMMITED
public static final String REQUEST_REDIRECTED
public static final String CXF_CONTINUATION_MESSAGE
public static final String CXF_ASYNC_CONTEXT
public static final String SERVICE_REDIRECTION
protected final Bus bus
protected DestinationRegistry registry
protected final String path
protected volatile HTTPServerPolicy serverPolicy
protected String contextMatchStrategy
protected boolean fixedParameterOrder
protected boolean multiplexWithAddress
protected CertConstraints certConstraints
protected boolean isServlet3
protected ContinuationProviderFactory cproviderFactory
protected boolean enableWebSocket
public AbstractHTTPDestination(Bus b, DestinationRegistry registry, EndpointInfo ei, String path, boolean dp) throws IOException
b
- the associated Busci
- the associated conduit initiatorei
- the endpoint info of the destinationdp
- true for adding the default port if it is missingIOException
public Bus getBus()
protected final boolean isOneWay(Message message)
message
- the message under considerationpublic void invoke(javax.servlet.ServletConfig config, javax.servlet.ServletContext context, javax.servlet.http.HttpServletRequest req, javax.servlet.http.HttpServletResponse resp) throws IOException
IOException
protected void invokeComplete(javax.servlet.ServletContext context, javax.servlet.http.HttpServletRequest req, javax.servlet.http.HttpServletResponse resp, Message m) throws IOException
IOException
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
IOException
protected Message retrieveFromContinuation(javax.servlet.http.HttpServletRequest req)
protected Message retrieveFromServlet3Async(javax.servlet.http.HttpServletRequest req)
protected void setupContinuation(Message inMessage, javax.servlet.http.HttpServletRequest req, javax.servlet.http.HttpServletResponse resp)
protected String getBasePath(String contextPath) throws IOException
IOException
protected static EndpointInfo getAddressValue(EndpointInfo ei)
protected static EndpointInfo getAddressValue(EndpointInfo ei, boolean dp)
protected Conduit getInbuiltBackChannel(Message inMessage)
getInbuiltBackChannel
in class AbstractDestination
inMessage
- the incoming messageprotected OutputStream flushHeaders(Message outMessage) throws IOException
IOException
protected OutputStream flushHeaders(Message outMessage, boolean getStream) throws IOException
IOException
protected boolean contextMatchOnExact()
public void finalizeConfig()
public String getBeanName()
Configurable
getBeanName
in interface Configurable
public EndpointReferenceType getAddressWithId(String id)
AbstractMultiplexDestination
getAddressWithId
in interface MultiplexDestination
getAddressWithId
in class AbstractMultiplexDestination
id
- the id to encode in the new referenceMultiplexDestination.getAddressWithId(java.lang.String)
public String getId(Map<String,Object> context)
AbstractMultiplexDestination
getId
in interface MultiplexDestination
getId
in class AbstractMultiplexDestination
context
- the current invocation or message contextMultiplexDestination.getId(java.util.Map)
public String getContextMatchStrategy()
public void setContextMatchStrategy(String contextMatchStrategy)
public boolean isFixedParameterOrder()
public void setFixedParameterOrder(boolean fixedParameterOrder)
public boolean isMultiplexWithAddress()
public void setMultiplexWithAddress(boolean multiplexWithAddress)
public HTTPServerPolicy getServer()
public void setServer(HTTPServerPolicy server)
public void assertMessage(Message message)
assertMessage
in interface Assertor
public void releaseRegistry()
public String getPath()
protected void activate()
AbstractObservable
activate
in class AbstractObservable
protected void deactivate()
AbstractObservable
deactivate
in class AbstractObservable
public void shutdown()
AbstractDestination
shutdown
in interface Destination
shutdown
in class AbstractDestination
Apache CXF