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 |
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 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 Conduit getSelectedConduit(Message message)
message
- the current Messageprotected 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()
Copyright © 2018 JBoss by Red Hat. All rights reserved.