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
javax.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.
javax.ws.rs.core.Response	getTerminator()
void	postConstruct()
javax.ws.rs.core.Response	prepareWork(String sraId)
javax.ws.rs.core.Response	rollbackWork(String sraId)
javax.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 Detail

SRAParticipant

public SRAParticipant()

Method Detail

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 javax.ws.rs.core.Response getTerminator()

commitWork

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

Throws:

javax.ws.rs.NotFoundException

prepareWork

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

Throws:

javax.ws.rs.NotFoundException

rollbackWork

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

Throws:

javax.ws.rs.NotFoundException

status

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

Throws:

javax.ws.rs.NotFoundException

postConstruct

@PostConstruct
public void postConstruct()