com.atomikos.remoting.twopc

Class AtomikosRestPort

java.lang.Object

com.atomikos.remoting.twopc.AtomikosRestPort

@Path(value="/atomikos")
 @Consumes(value="application/vnd.atomikos+json")
public class AtomikosRestPort
extends Object

A REST port for making the local JVM's invocations part of the transaction scope of the calling client (if any). An instance needs to be running if you want to accept incoming transactional REST calls.

Field Summary

Fields

Modifier and Type	Field and Description
static String	REST_URL_PROPERTY_NAME

Constructor Summary

Constructors

Constructor and Description
AtomikosRestPort()

Method Summary

Modifier and Type	Method and Description
static String	buildParticipantUrl(com.atomikos.icatch.CompositeTransaction ct)
static String	buildRecoveryCoordinatorUrl(com.atomikos.icatch.CompositeTransaction ct)
javax.ws.rs.core.Response	commit(String rootId, String coordinatorId, boolean onePhase)
String	getOutcome(String coordinatorId)
static String	getUrl()
static void	init(String url)
String	ping()
javax.ws.rs.core.Response	prepare(String rootId, String coordinatorId, Map<String,Integer> cascadeList)
javax.ws.rs.core.Response	rollback(String rootId, String coordinatorId)
static void	setUrl(String url) Sets the URL for this port - either from jta.properties or as detected on first invocation of our interceptor.

Methods inherited from class java.lang.Object

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

Field Detail

REST_URL_PROPERTY_NAME

public static final String REST_URL_PROPERTY_NAME

See Also:

Constant Field Values

Constructor Detail

AtomikosRestPort

public AtomikosRestPort()

Method Detail

setUrl

public static void setUrl(String url)

Sets the URL for this port - either from jta.properties or as detected on first invocation of our interceptor. Needed because JAX-RS does not have an easy why of finding out on which URL we are bound.

Parameters:

url - Can be null in which case this method does nothing. If the URL was already set then a second invocation will not have any effect.

getUrl

public static String getUrl()

buildParticipantUrl

public static String buildParticipantUrl(com.atomikos.icatch.CompositeTransaction ct)
                                  throws com.atomikos.icatch.SysException

Throws:

com.atomikos.icatch.SysException

buildRecoveryCoordinatorUrl

public static String buildRecoveryCoordinatorUrl(com.atomikos.icatch.CompositeTransaction ct)

init

public static void init(String url)

ping

@GET
public String ping()

getOutcome

@GET
 @Path(value="{coordinatorId}")
public String getOutcome(@PathParam(value="coordinatorId")
                                                              String coordinatorId)

prepare

@POST
 @Path(value="{rootId}/{coordinatorId}")
public javax.ws.rs.core.Response prepare(@PathParam(value="rootId")
                                                                                        String rootId,
                                                                                        @PathParam(value="coordinatorId")
                                                                                        String coordinatorId,
                                                                                        Map<String,Integer> cascadeList)

commit

@PUT
 @Path(value="{rootId}/{coordinatorId}/{onePhase}")
public javax.ws.rs.core.Response commit(@PathParam(value="rootId")
                                                                                                 String rootId,
                                                                                                 @PathParam(value="coordinatorId")
                                                                                                 String coordinatorId,
                                                                                                 @PathParam(value="onePhase")
                                                                                                 boolean onePhase)

rollback

@DELETE
 @Path(value="{rootId}/{coordinatorId}")
public javax.ws.rs.core.Response rollback(@PathParam(value="rootId")
                                                                                           String rootId,
                                                                                           @PathParam(value="coordinatorId")
                                                                                           String coordinatorId)