Package org.jboss.jbossts.star.client

Class SRAParticipant

java.lang.Object

org.jboss.jbossts.star.client.SRAParticipant

@RequestScoped
public abstract class SRAParticipant
extends Object

Constructor Summary

Constructors

Constructor	Description
SRAParticipant()

Method Summary

Modifier and Type	Method	Description
jakarta.ws.rs.core.Response	commitWork(String atId, String sraId)
protected String	getCompensatorData(String activityId)
protected String	getCurrentActivityId()	Get the SRA context of the currently running method.
jakarta.ws.rs.core.Response	getTerminator()
void	postConstruct()
jakarta.ws.rs.core.Response	prepareWork(String sraId)
jakarta.ws.rs.core.Response	rollbackWork(String sraId)
jakarta.ws.rs.core.Response	status(String sraId)
protected abstract SRAStatus	updateParticipantState(SRAStatus status, String activityId)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SRAParticipant

public SRAParticipant()

Method Details

updateParticipantState

protected abstract SRAStatus updateParticipantState(SRAStatus status,
 String activityId)

getCompensatorData

protected String getCompensatorData(String activityId)

getCurrentActivityId

protected String getCurrentActivityId()

Get the SRA context of the currently running method. Note that @HeaderParam(SRA_HTTP_HEADER) does not match the header (done't know why) so we the httpRequest

Returns:

the SRA context of the currently running method

getTerminator

@HEAD
@Path("/participant")
@Produces("application/json")
public jakarta.ws.rs.core.Response getTerminator()

commitWork

@PUT
@Path("/commit/{txid}")
@Produces("application/json")
public jakarta.ws.rs.core.Response commitWork(@HeaderParam("Short-Running-Action")
 String atId,
 @PathParam("txid")
 String sraId)
                                       throws jakarta.ws.rs.NotFoundException

Throws:

jakarta.ws.rs.NotFoundException

prepareWork

@PUT
@Path("/prepare/{txid}")
@Produces("application/json")
public jakarta.ws.rs.core.Response prepareWork(@PathParam("txid")
 String sraId)
                                        throws jakarta.ws.rs.NotFoundException

Throws:

jakarta.ws.rs.NotFoundException

rollbackWork

@PUT
@Path("/rollback/{txid}")
@Produces("application/json")
public jakarta.ws.rs.core.Response rollbackWork(@PathParam("txid")
 String sraId)
                                         throws jakarta.ws.rs.NotFoundException

Throws:

jakarta.ws.rs.NotFoundException

status

@GET
@Path("/status/{txid}")
@Produces("application/json")
public jakarta.ws.rs.core.Response status(@PathParam("txid")
 String sraId)
                                   throws jakarta.ws.rs.NotFoundException

Throws:

jakarta.ws.rs.NotFoundException

postConstruct

@PostConstruct
public void postConstruct()