Package org.apache.camel.service.lra
Class LRASagaService
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.service.lra.LRASagaService
-
- All Implemented Interfaces:
AutoCloseable
,org.apache.camel.CamelContextAware
,org.apache.camel.saga.CamelSagaService
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.StatefulService
,org.apache.camel.StaticService
,org.apache.camel.SuspendableService
@JdkService("lra-saga-service") @Configurer @ManagedResource(description="Managed LRASagaService") public class LRASagaService extends org.apache.camel.support.service.ServiceSupport implements org.apache.camel.StaticService, org.apache.camel.saga.CamelSagaService
A Camel saga service based on Microprofile LRA (https://github.com/eclipse/microprofile-lra).
-
-
Constructor Summary
Constructors Constructor Description LRASagaService()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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)
String
toString()
-
Methods inherited from class org.apache.camel.support.service.BaseService
build, doBuild, doFail, doInit, doLifecycleChange, doResume, doShutdown, doSuspend, fail, getStatus, init, isBuild, isInit, isNew, isRunAllowed, isShutdown, isStarted, isStarting, isStartingOrStarted, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
-
-
-
Method Detail
-
newSaga
public CompletableFuture<org.apache.camel.saga.CamelSagaCoordinator> newSaga()
- Specified by:
newSaga
in interfaceorg.apache.camel.saga.CamelSagaService
-
getSaga
public CompletableFuture<org.apache.camel.saga.CamelSagaCoordinator> getSaga(String id)
- Specified by:
getSaga
in interfaceorg.apache.camel.saga.CamelSagaService
-
registerStep
public void registerStep(org.apache.camel.saga.CamelSagaStep step)
- Specified by:
registerStep
in interfaceorg.apache.camel.saga.CamelSagaService
-
doStart
protected void doStart() throws Exception
- Overrides:
doStart
in classorg.apache.camel.support.service.BaseService
- Throws:
Exception
-
doStop
protected void doStop() throws Exception
- Overrides:
doStop
in classorg.apache.camel.support.service.BaseService
- Throws:
Exception
-
setCamelContext
public void setCamelContext(org.apache.camel.CamelContext camelContext)
- Specified by:
setCamelContext
in interfaceorg.apache.camel.CamelContextAware
-
getCamelContext
public org.apache.camel.CamelContext getCamelContext()
- Specified by:
getCamelContext
in interfaceorg.apache.camel.CamelContextAware
-
getExecutorService
public ScheduledExecutorService getExecutorService()
-
getClient
public LRAClient getClient()
-
getCoordinatorUrl
@ManagedAttribute(description="Coordinator URL") public String getCoordinatorUrl()
-
setCoordinatorUrl
public void setCoordinatorUrl(String coordinatorUrl)
-
getCoordinatorContextPath
@ManagedAttribute(description="Coordinator context-path") public String getCoordinatorContextPath()
-
setCoordinatorContextPath
public void setCoordinatorContextPath(String coordinatorContextPath)
-
getLocalParticipantUrl
@ManagedAttribute(description="Local participant URL") public String getLocalParticipantUrl()
-
setLocalParticipantUrl
public void setLocalParticipantUrl(String localParticipantUrl)
-
getLocalParticipantContextPath
@ManagedAttribute(description="Local participant context-path") public String getLocalParticipantContextPath()
-
setLocalParticipantContextPath
public void setLocalParticipantContextPath(String localParticipantContextPath)
-
-