@Path(value="/context") public class JmsContextService extends Object
Modifier and Type | Field and 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 Helper |
helper |
static String |
JMS_BODY |
static String |
JMS_HEADER |
static String |
JMS_PROPERTIES |
static String |
JMS_TYPE |
static org.objectweb.util.monolog.api.Logger |
logger |
Constructor and Description |
---|
JmsContextService() |
Modifier and Type | Method and Description |
---|---|
javax.ws.rs.core.Response |
acknowledgeCons(javax.ws.rs.core.HttpHeaders headers,
String ctxName,
long id,
javax.ws.rs.core.UriInfo uriInfo) |
javax.ws.rs.core.Response |
acknowledgeCons(javax.ws.rs.core.HttpHeaders headers,
String ctxName,
javax.ws.rs.core.UriInfo uriInfo) |
javax.ws.rs.core.Response |
commit(javax.ws.rs.core.HttpHeaders headers,
String ctxName,
javax.ws.rs.core.UriInfo uriInfo) |
javax.ws.rs.core.Response |
consumeMsg(javax.ws.rs.core.HttpHeaders headers,
String consName,
long timeout,
boolean noLocal,
boolean durable,
boolean shared,
String subName,
javax.ws.rs.core.UriInfo uriInfo) |
javax.ws.rs.core.Response |
consumeMsg(javax.ws.rs.core.HttpHeaders headers,
String consName,
long id,
long timeout,
boolean noLocal,
boolean durable,
boolean shared,
String subName,
javax.ws.rs.core.UriInfo uriInfo) |
private Map |
getHeaderToJsonMap(javax.jms.Message message) |
private Map |
getMapMessageToJsonBodyMap(javax.jms.Message message) |
private Map |
getPropertiesToJsonMap(javax.jms.Message message) |
String |
info(javax.ws.rs.core.UriInfo uriInfo) |
static void |
logLinks(javax.ws.rs.core.Response.ResponseBuilder builder) |
javax.ws.rs.core.Response |
rollback(javax.ws.rs.core.HttpHeaders headers,
String ctxName,
javax.ws.rs.core.UriInfo uriInfo) |
javax.ws.rs.core.Response |
sendMsg(javax.ws.rs.core.HttpHeaders headers,
String prodName,
int deliveryMode,
long deliveryTime,
int priority,
long timeToLive,
String correlationID,
javax.ws.rs.core.UriInfo uriInfo,
String body) |
javax.ws.rs.core.Response |
sendMsg(javax.ws.rs.core.HttpHeaders headers,
String prodName,
long id,
int deliveryMode,
long deliveryTime,
int priority,
long timeToLive,
String correlationID,
javax.ws.rs.core.UriInfo uriInfo,
String body) |
javax.ws.rs.core.Response |
sendMsgJson(javax.ws.rs.core.HttpHeaders headers,
String prodName,
int deliveryMode,
long deliveryTime,
int priority,
long timeToLive,
String correlationID,
javax.ws.rs.core.UriInfo uriInfo,
String json) |
javax.ws.rs.core.Response |
sendMsgJson(javax.ws.rs.core.HttpHeaders headers,
String prodName,
long id,
int deliveryMode,
long deliveryTime,
int priority,
long timeToLive,
String correlationID,
javax.ws.rs.core.UriInfo uriInfo,
String json) |
public static org.objectweb.util.monolog.api.Logger logger
private final Helper helper
public static final String CONTEXT
public static final String CONTEXT_SEND
public static final String CONTEXT_SEND_NEXT
public static final String CONTEXT_CONSUME
public static final String CONTEXT_CONSUME_NEXT
public static final String CONTEXT_COMMIT
public static final String CONTEXT_ROLLBACK
public static final String CONTEXT_ACK
public static final String CONTEXT_ACK_MSG
public static final String JMS_HEADER
public static final String JMS_PROPERTIES
public static final String JMS_BODY
public static final String JMS_TYPE
public static void logLinks(javax.ws.rs.core.Response.ResponseBuilder builder)
@GET @Produces(value="text/html") public String info(@Context javax.ws.rs.core.UriInfo uriInfo)
@POST @Path(value="/{name}") @Consumes(value="text/plain") @Produces(value="text/plain") public javax.ws.rs.core.Response sendMsg(@Context javax.ws.rs.core.HttpHeaders headers, @PathParam(value="name") String prodName, @DefaultValue(value="-1") @QueryParam(value="delivery-mode") int deliveryMode, @DefaultValue(value="-1") @QueryParam(value="delivery-time") long deliveryTime, @DefaultValue(value="-1") @QueryParam(value="priority") int priority, @DefaultValue(value="-1") @QueryParam(value="time-to-live") long timeToLive, @QueryParam(value="correlation-id") String correlationID, @Context javax.ws.rs.core.UriInfo uriInfo, String body)
@POST @Path(value="/{name}") @Consumes(value="application/json") @Produces(value="text/plain") public javax.ws.rs.core.Response sendMsgJson(@Context javax.ws.rs.core.HttpHeaders headers, @PathParam(value="name") String prodName, @DefaultValue(value="-1") @QueryParam(value="delivery-mode") int deliveryMode, @DefaultValue(value="-1") @QueryParam(value="delivery-time") long deliveryTime, @DefaultValue(value="-1") @QueryParam(value="priority") int priority, @DefaultValue(value="-1") @QueryParam(value="time-to-live") long timeToLive, @QueryParam(value="correlation-id") String correlationID, @Context javax.ws.rs.core.UriInfo uriInfo, String json)
@POST @Path(value="/{name}/{id}") @Consumes(value="text/plain") @Produces(value="text/plain") public javax.ws.rs.core.Response sendMsg(@Context javax.ws.rs.core.HttpHeaders headers, @PathParam(value="name") String prodName, @PathParam(value="id") long id, @DefaultValue(value="-1") @QueryParam(value="delivery-mode") int deliveryMode, @DefaultValue(value="-1") @QueryParam(value="delivery-time") long deliveryTime, @DefaultValue(value="-1") @QueryParam(value="priority") int priority, @DefaultValue(value="-1") @QueryParam(value="time-to-live") long timeToLive, @QueryParam(value="correlation-id") String correlationID, @Context javax.ws.rs.core.UriInfo uriInfo, String body)
@POST @Path(value="/{name}/{id}") @Consumes(value="application/json") @Produces(value="text/plain") public javax.ws.rs.core.Response sendMsgJson(@Context javax.ws.rs.core.HttpHeaders headers, @PathParam(value="name") String prodName, @PathParam(value="id") long id, @DefaultValue(value="-1") @QueryParam(value="delivery-mode") int deliveryMode, @DefaultValue(value="-1") @QueryParam(value="delivery-time") long deliveryTime, @DefaultValue(value="-1") @QueryParam(value="priority") int priority, @DefaultValue(value="-1") @QueryParam(value="time-to-live") long timeToLive, @QueryParam(value="correlation-id") String correlationID, @Context javax.ws.rs.core.UriInfo uriInfo, String json)
private Map getMapMessageToJsonBodyMap(javax.jms.Message message) throws javax.jms.JMSException
javax.jms.JMSException
@GET @Path(value="/{name}") @Produces(value={"text/plain","application/json"}) @Consumes(value="text/plain") public javax.ws.rs.core.Response consumeMsg(@Context javax.ws.rs.core.HttpHeaders headers, @PathParam(value="name") String consName, @DefaultValue(value="-1") @QueryParam(value="timeout") long timeout, @DefaultValue(value="false") @QueryParam(value="no-local") boolean noLocal, @DefaultValue(value="false") @QueryParam(value="durable") boolean durable, @DefaultValue(value="false") @QueryParam(value="shared") boolean shared, @QueryParam(value="sub-name") String subName, @Context javax.ws.rs.core.UriInfo uriInfo)
@GET @Path(value="/{name}/{id}") @Produces(value={"text/plain","application/json"}) @Consumes(value="text/plain") public javax.ws.rs.core.Response consumeMsg(@Context javax.ws.rs.core.HttpHeaders headers, @PathParam(value="name") String consName, @PathParam(value="id") long id, @DefaultValue(value="-1") @QueryParam(value="timeout") long timeout, @DefaultValue(value="false") @QueryParam(value="no-local") boolean noLocal, @DefaultValue(value="false") @QueryParam(value="durable") boolean durable, @DefaultValue(value="false") @QueryParam(value="shared") boolean shared, @QueryParam(value="sub-name") String subName, @Context javax.ws.rs.core.UriInfo uriInfo)
private Map getPropertiesToJsonMap(javax.jms.Message message) throws javax.jms.JMSException
javax.jms.JMSException
private Map getHeaderToJsonMap(javax.jms.Message message)
@HEAD @Path(value="/{name}/commit") @Produces(value="text/plain") @Consumes(value="text/plain") public javax.ws.rs.core.Response commit(@Context javax.ws.rs.core.HttpHeaders headers, @PathParam(value="name") String ctxName, @Context javax.ws.rs.core.UriInfo uriInfo)
@HEAD @Path(value="/{name}/rollback") @Produces(value="text/plain") @Consumes(value="text/plain") public javax.ws.rs.core.Response rollback(@Context javax.ws.rs.core.HttpHeaders headers, @PathParam(value="name") String ctxName, @Context javax.ws.rs.core.UriInfo uriInfo)
@DELETE @Path(value="/{name}") @Produces(value="text/plain") @Consumes(value="text/plain") public javax.ws.rs.core.Response acknowledgeCons(@Context javax.ws.rs.core.HttpHeaders headers, @PathParam(value="name") String ctxName, @Context javax.ws.rs.core.UriInfo uriInfo)
@DELETE @Path(value="/{name}/{id}") @Produces(value="text/plain") @Consumes(value="text/plain") public javax.ws.rs.core.Response acknowledgeCons(@Context javax.ws.rs.core.HttpHeaders headers, @PathParam(value="name") String ctxName, @PathParam(value="id") long id, @Context javax.ws.rs.core.UriInfo uriInfo)
Copyright © 2018 ScalAgent D.T.. All Rights Reserved.