public abstract class AbstractConduitSelector extends Object implements ConduitSelector, Closeable
| Modifier and Type | Field and Description |
|---|---|
static String |
CONDUIT_COMPARE_FULL_URL |
protected List<Conduit> |
conduits |
protected Endpoint |
endpoint |
protected static String |
KEEP_CONDUIT_ALIVE |
| Constructor and Description |
|---|
AbstractConduitSelector() |
AbstractConduitSelector(Conduit c)
Constructor, allowing a specific conduit to override normal selection.
|
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
void |
complete(Exchange exchange)
Called on completion of the MEP for which the Conduit was required.
|
protected Conduit |
createConduit(Message message,
Exchange exchange,
ConduitInitiator conduitInitiator) |
protected Conduit |
findCompatibleConduit(Message message)
If address protocol was changed, conduit should be re-initialised
|
Endpoint |
getEndpoint() |
protected abstract Logger |
getLogger() |
protected Conduit |
getSelectedConduit(Message message)
Mechanics to actually get the Conduit from the ConduitInitiator
if necessary.
|
protected void |
removeConduit(Conduit conduit) |
protected boolean |
replaceEndpointAddressPropertyIfNeeded(Message message,
String endpointAddress,
Conduit cond) |
void |
setEndpoint(Endpoint ep) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitprepare, selectConduitpublic static final String CONDUIT_COMPARE_FULL_URL
protected static final String KEEP_CONDUIT_ALIVE
protected Endpoint endpoint
public AbstractConduitSelector()
public AbstractConduitSelector(Conduit c)
c - specific conduitpublic void close()
close in interface Closeableclose in interface AutoCloseableprotected void removeConduit(Conduit conduit)
protected Conduit getSelectedConduit(Message message)
message - the current Messageprotected Conduit createConduit(Message message, Exchange exchange, ConduitInitiator conduitInitiator) throws IOException
IOExceptionprotected boolean replaceEndpointAddressPropertyIfNeeded(Message message, String endpointAddress, Conduit cond)
public Endpoint getEndpoint()
getEndpoint in interface ConduitSelectorpublic void setEndpoint(Endpoint ep)
setEndpoint in interface ConduitSelectorep - the endpoint to encapsulatepublic void complete(Exchange exchange)
complete in interface ConduitSelectorexchange - represents the completed MEPprotected abstract Logger getLogger()
Apache CXF