Package org.objectweb.joram.tools.rest.jms

Class JmsContextService

java.lang.Object

org.objectweb.joram.tools.rest.jms.JmsContextService

@Path("/context")
public final class JmsContextService
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static String	CONTEXT
static String	CONTEXT_ACK
static String	CONTEXT_ACK_MSG
static String	CONTEXT_COMMIT
static String	CONTEXT_CONSUME
static String	CONTEXT_CONSUME_NEXT
static String	CONTEXT_ROLLBACK
static String	CONTEXT_SEND
static String	CONTEXT_SEND_NEXT
private static boolean	DEBUG
private Helper	helper
static String	JMS_BODY
static String	JMS_HEADER
static String	JMS_PROPERTIES
static String	JMS_TYPE
private static Logger	logger
private static boolean	nologlink

Constructor Summary

Constructors

Constructor	Description
JmsContextService()

Method Summary

Modifier and Type	Method	Description
jakarta.ws.rs.core.Response	acknowledgeCons(jakarta.ws.rs.core.HttpHeaders headers, String ctxName, long id, jakarta.ws.rs.core.UriInfo uriInfo)
jakarta.ws.rs.core.Response	acknowledgeCons(jakarta.ws.rs.core.HttpHeaders headers, String ctxName, jakarta.ws.rs.core.UriInfo uriInfo)
jakarta.ws.rs.core.Response	commit(jakarta.ws.rs.core.HttpHeaders headers, String ctxName, jakarta.ws.rs.core.UriInfo uriInfo)
jakarta.ws.rs.core.Response	consumeMsg(jakarta.ws.rs.core.HttpHeaders headers, String consName, long timeout, boolean noLocal, boolean durable, boolean shared, String subName, jakarta.ws.rs.core.UriInfo uriInfo)
jakarta.ws.rs.core.Response	consumeMsg(jakarta.ws.rs.core.HttpHeaders headers, String consName, long id, long timeout, boolean noLocal, boolean durable, boolean shared, String subName, jakarta.ws.rs.core.UriInfo uriInfo)
private Map<String,Object>	getHeaderToJsonMap(jakarta.jms.Message message)
private Map<String,Object>	getMapMessageToJsonBodyMap(jakarta.jms.Message message)
private Map<String,Object>	getPropertiesToJsonMap(jakarta.jms.Message message)
String	info(jakarta.ws.rs.core.UriInfo uriInfo)
static void	logLinks(jakarta.ws.rs.core.Response.ResponseBuilder builder)
jakarta.ws.rs.core.Response	rollback(jakarta.ws.rs.core.HttpHeaders headers, String ctxName, jakarta.ws.rs.core.UriInfo uriInfo)
jakarta.ws.rs.core.Response	sendMsg(jakarta.ws.rs.core.HttpHeaders headers, String prodName, int deliveryMode, long deliveryTime, int priority, long timeToLive, String correlationID, jakarta.ws.rs.core.UriInfo uriInfo, String body)
jakarta.ws.rs.core.Response	sendMsg(jakarta.ws.rs.core.HttpHeaders headers, String prodName, long id, int deliveryMode, long deliveryTime, int priority, long timeToLive, String correlationID, jakarta.ws.rs.core.UriInfo uriInfo, String body)
jakarta.ws.rs.core.Response	sendMsgJson(jakarta.ws.rs.core.HttpHeaders headers, String prodName, int deliveryMode, long deliveryTime, int priority, long timeToLive, String correlationID, jakarta.ws.rs.core.UriInfo uriInfo, String json)
jakarta.ws.rs.core.Response	sendMsgJson(jakarta.ws.rs.core.HttpHeaders headers, String prodName, long id, int deliveryMode, long deliveryTime, int priority, long timeToLive, String correlationID, jakarta.ws.rs.core.UriInfo uriInfo, String json)

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static final Logger logger

DEBUG

private static final boolean DEBUG

helper

private final Helper helper

CONTEXT

public static final String CONTEXT

See Also:

Constant Field Values

CONTEXT_SEND

public static final String CONTEXT_SEND

See Also:

Constant Field Values

CONTEXT_SEND_NEXT

public static final String CONTEXT_SEND_NEXT

See Also:

Constant Field Values

CONTEXT_CONSUME

public static final String CONTEXT_CONSUME

See Also:

Constant Field Values

CONTEXT_CONSUME_NEXT

public static final String CONTEXT_CONSUME_NEXT

See Also:

Constant Field Values

CONTEXT_COMMIT

public static final String CONTEXT_COMMIT

See Also:

Constant Field Values

CONTEXT_ROLLBACK

public static final String CONTEXT_ROLLBACK

See Also:

Constant Field Values

CONTEXT_ACK

public static final String CONTEXT_ACK

See Also:

Constant Field Values

CONTEXT_ACK_MSG

public static final String CONTEXT_ACK_MSG

See Also:

Constant Field Values

JMS_HEADER

public static final String JMS_HEADER

See Also:

Constant Field Values

JMS_PROPERTIES

public static final String JMS_PROPERTIES

See Also:

Constant Field Values

JMS_BODY

public static final String JMS_BODY

See Also:

Constant Field Values

JMS_TYPE

public static final String JMS_TYPE

See Also:

Constant Field Values

nologlink

private static boolean nologlink

Constructor Detail

JmsContextService

public JmsContextService()

Method Detail

logLinks

public static void logLinks(jakarta.ws.rs.core.Response.ResponseBuilder builder)

info

@GET
@Produces("text/html")
public String info(@Context
                   jakarta.ws.rs.core.UriInfo uriInfo)

sendMsg

@POST
@Path("/{name}")
@Consumes("text/plain")
@Produces("text/plain")
public jakarta.ws.rs.core.Response sendMsg(@Context
                                           jakarta.ws.rs.core.HttpHeaders headers,
                                           @PathParam("name")
                                           String prodName,
                                           @DefaultValue("-1") @QueryParam("delivery-mode")
                                           int deliveryMode,
                                           @DefaultValue("-1") @QueryParam("delivery-time")
                                           long deliveryTime,
                                           @DefaultValue("-1") @QueryParam("priority")
                                           int priority,
                                           @DefaultValue("-1") @QueryParam("time-to-live")
                                           long timeToLive,
                                           @QueryParam("correlation-id")
                                           String correlationID,
                                           @Context
                                           jakarta.ws.rs.core.UriInfo uriInfo,
                                           String body)

sendMsgJson

@POST
@Path("/{name}")
@Consumes("application/json")
@Produces("text/plain")
public jakarta.ws.rs.core.Response sendMsgJson(@Context
                                               jakarta.ws.rs.core.HttpHeaders headers,
                                               @PathParam("name")
                                               String prodName,
                                               @DefaultValue("-1") @QueryParam("delivery-mode")
                                               int deliveryMode,
                                               @DefaultValue("-1") @QueryParam("delivery-time")
                                               long deliveryTime,
                                               @DefaultValue("-1") @QueryParam("priority")
                                               int priority,
                                               @DefaultValue("-1") @QueryParam("time-to-live")
                                               long timeToLive,
                                               @QueryParam("correlation-id")
                                               String correlationID,
                                               @Context
                                               jakarta.ws.rs.core.UriInfo uriInfo,
                                               String json)

sendMsg

@POST
@Path("/{name}/{id}")
@Consumes("text/plain")
@Produces("text/plain")
public jakarta.ws.rs.core.Response sendMsg(@Context
                                           jakarta.ws.rs.core.HttpHeaders headers,
                                           @PathParam("name")
                                           String prodName,
                                           @PathParam("id")
                                           long id,
                                           @DefaultValue("-1") @QueryParam("delivery-mode")
                                           int deliveryMode,
                                           @DefaultValue("-1") @QueryParam("delivery-time")
                                           long deliveryTime,
                                           @DefaultValue("-1") @QueryParam("priority")
                                           int priority,
                                           @DefaultValue("-1") @QueryParam("time-to-live")
                                           long timeToLive,
                                           @QueryParam("correlation-id")
                                           String correlationID,
                                           @Context
                                           jakarta.ws.rs.core.UriInfo uriInfo,
                                           String body)

sendMsgJson

@POST
@Path("/{name}/{id}")
@Consumes("application/json")
@Produces("text/plain")
public jakarta.ws.rs.core.Response sendMsgJson(@Context
                                               jakarta.ws.rs.core.HttpHeaders headers,
                                               @PathParam("name")
                                               String prodName,
                                               @PathParam("id")
                                               long id,
                                               @DefaultValue("-1") @QueryParam("delivery-mode")
                                               int deliveryMode,
                                               @DefaultValue("-1") @QueryParam("delivery-time")
                                               long deliveryTime,
                                               @DefaultValue("-1") @QueryParam("priority")
                                               int priority,
                                               @DefaultValue("-1") @QueryParam("time-to-live")
                                               long timeToLive,
                                               @QueryParam("correlation-id")
                                               String correlationID,
                                               @Context
                                               jakarta.ws.rs.core.UriInfo uriInfo,
                                               String json)

getMapMessageToJsonBodyMap

private Map<String,Object> getMapMessageToJsonBodyMap(jakarta.jms.Message message)
                                                     throws jakarta.jms.JMSException

Throws:

jakarta.jms.JMSException

consumeMsg

@GET
@Path("/{name}")
@Produces({"text/plain","application/json"})
@Consumes("text/plain")
public jakarta.ws.rs.core.Response consumeMsg(@Context
                                              jakarta.ws.rs.core.HttpHeaders headers,
                                              @PathParam("name")
                                              String consName,
                                              @DefaultValue("-1") @QueryParam("timeout")
                                              long timeout,
                                              @DefaultValue("false") @QueryParam("no-local")
                                              boolean noLocal,
                                              @DefaultValue("false") @QueryParam("durable")
                                              boolean durable,
                                              @DefaultValue("false") @QueryParam("shared")
                                              boolean shared,
                                              @QueryParam("sub-name")
                                              String subName,
                                              @Context
                                              jakarta.ws.rs.core.UriInfo uriInfo)

consumeMsg

@GET
@Path("/{name}/{id}")
@Produces({"text/plain","application/json"})
@Consumes("text/plain")
public jakarta.ws.rs.core.Response consumeMsg(@Context
                                              jakarta.ws.rs.core.HttpHeaders headers,
                                              @PathParam("name")
                                              String consName,
                                              @PathParam("id")
                                              long id,
                                              @DefaultValue("-1") @QueryParam("timeout")
                                              long timeout,
                                              @DefaultValue("false") @QueryParam("no-local")
                                              boolean noLocal,
                                              @DefaultValue("false") @QueryParam("durable")
                                              boolean durable,
                                              @DefaultValue("false") @QueryParam("shared")
                                              boolean shared,
                                              @QueryParam("sub-name")
                                              String subName,
                                              @Context
                                              jakarta.ws.rs.core.UriInfo uriInfo)

getPropertiesToJsonMap

private Map<String,Object> getPropertiesToJsonMap(jakarta.jms.Message message)
                                                 throws jakarta.jms.JMSException

Throws:

jakarta.jms.JMSException

getHeaderToJsonMap

private Map<String,Object> getHeaderToJsonMap(jakarta.jms.Message message)

commit

@HEAD
@Path("/{name}/commit")
@Produces("text/plain")
@Consumes("text/plain")
public jakarta.ws.rs.core.Response commit(@Context
                                          jakarta.ws.rs.core.HttpHeaders headers,
                                          @PathParam("name")
                                          String ctxName,
                                          @Context
                                          jakarta.ws.rs.core.UriInfo uriInfo)

rollback

@HEAD
@Path("/{name}/rollback")
@Produces("text/plain")
@Consumes("text/plain")
public jakarta.ws.rs.core.Response rollback(@Context
                                            jakarta.ws.rs.core.HttpHeaders headers,
                                            @PathParam("name")
                                            String ctxName,
                                            @Context
                                            jakarta.ws.rs.core.UriInfo uriInfo)

acknowledgeCons

@DELETE
@Path("/{name}")
@Produces("text/plain")
@Consumes("text/plain")
public jakarta.ws.rs.core.Response acknowledgeCons(@Context
                                                   jakarta.ws.rs.core.HttpHeaders headers,
                                                   @PathParam("name")
                                                   String ctxName,
                                                   @Context
                                                   jakarta.ws.rs.core.UriInfo uriInfo)

acknowledgeCons

@DELETE
@Path("/{name}/{id}")
@Produces("text/plain")
@Consumes("text/plain")
public jakarta.ws.rs.core.Response acknowledgeCons(@Context
                                                   jakarta.ws.rs.core.HttpHeaders headers,
                                                   @PathParam("name")
                                                   String ctxName,
                                                   @PathParam("id")
                                                   long id,
                                                   @Context
                                                   jakarta.ws.rs.core.UriInfo uriInfo)