public class LRASagaService
extends org.apache.camel.support.ServiceSupport
implements org.apache.camel.saga.CamelSagaService
Constructor and Description |
---|
LRASagaService() |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
org.apache.camel.CamelContext |
getCamelContext() |
LRAClient |
getClient() |
String |
getCoordinatorContextPath() |
String |
getCoordinatorUrl() |
ScheduledExecutorService |
getExecutorService() |
String |
getLocalParticipantContextPath() |
String |
getLocalParticipantUrl() |
Set<String> |
getRegisteredURIs() |
CompletableFuture<org.apache.camel.saga.CamelSagaCoordinator> |
getSaga(String id) |
CompletableFuture<org.apache.camel.saga.CamelSagaCoordinator> |
newSaga() |
void |
registerStep(org.apache.camel.saga.CamelSagaStep step) |
void |
setCamelContext(org.apache.camel.CamelContext camelContext) |
void |
setCoordinatorContextPath(String coordinatorContextPath) |
void |
setCoordinatorUrl(String coordinatorUrl) |
void |
setLocalParticipantContextPath(String localParticipantContextPath) |
void |
setLocalParticipantUrl(String localParticipantUrl) |
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public CompletableFuture<org.apache.camel.saga.CamelSagaCoordinator> newSaga()
newSaga
in interface org.apache.camel.saga.CamelSagaService
public CompletableFuture<org.apache.camel.saga.CamelSagaCoordinator> getSaga(String id)
getSaga
in interface org.apache.camel.saga.CamelSagaService
public void registerStep(org.apache.camel.saga.CamelSagaStep step)
registerStep
in interface org.apache.camel.saga.CamelSagaService
protected void doStart() throws Exception
doStart
in class org.apache.camel.support.ServiceSupport
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.support.ServiceSupport
Exception
public void setCamelContext(org.apache.camel.CamelContext camelContext)
setCamelContext
in interface org.apache.camel.CamelContextAware
public org.apache.camel.CamelContext getCamelContext()
getCamelContext
in interface org.apache.camel.CamelContextAware
public ScheduledExecutorService getExecutorService()
public LRAClient getClient()
public String getCoordinatorUrl()
public void setCoordinatorUrl(String coordinatorUrl)
public String getCoordinatorContextPath()
public void setCoordinatorContextPath(String coordinatorContextPath)
public String getLocalParticipantUrl()
public void setLocalParticipantUrl(String localParticipantUrl)
public String getLocalParticipantContextPath()
public void setLocalParticipantContextPath(String localParticipantContextPath)
Apache Camel