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, wait
prepare, selectConduit
public 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 Closeable
close
in interface AutoCloseable
protected void removeConduit(Conduit conduit)
protected Conduit getSelectedConduit(Message message)
message
- the current Messageprotected Conduit createConduit(Message message, Exchange exchange, ConduitInitiator conduitInitiator) throws IOException
IOException
protected boolean replaceEndpointAddressPropertyIfNeeded(Message message, String endpointAddress, Conduit cond)
public Endpoint getEndpoint()
getEndpoint
in interface ConduitSelector
public void setEndpoint(Endpoint ep)
setEndpoint
in interface ConduitSelector
ep
- the endpoint to encapsulatepublic void complete(Exchange exchange)
complete
in interface ConduitSelector
exchange
- represents the completed MEPprotected abstract Logger getLogger()
Apache CXF