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 |
---|---|
Response |
acknowledgeCons(HttpHeaders headers,
String ctxName,
long id,
UriInfo uriInfo) |
Response |
acknowledgeCons(HttpHeaders headers,
String ctxName,
UriInfo uriInfo) |
Response |
commit(HttpHeaders headers,
String ctxName,
UriInfo uriInfo) |
Response |
consumeMsg(HttpHeaders headers,
String consName,
long timeout,
boolean noLocal,
boolean durable,
boolean shared,
String subName,
UriInfo uriInfo) |
Response |
consumeMsg(HttpHeaders headers,
String consName,
long id,
long timeout,
boolean noLocal,
boolean durable,
boolean shared,
String subName,
UriInfo uriInfo) |
private Map |
getHeaderToJsonMap(Message message) |
private Map |
getPropertiesToJsonMap(Message message) |
String |
info(UriInfo uriInfo) |
static void |
logLinks(Response.ResponseBuilder builder) |
Response |
rollback(HttpHeaders headers,
String ctxName,
UriInfo uriInfo) |
Response |
sendMsg(HttpHeaders headers,
String prodName,
int deliveryMode,
long deliveryTime,
int priority,
long timeToLive,
String correlationID,
UriInfo uriInfo,
String body) |
Response |
sendMsg(HttpHeaders headers,
String prodName,
long id,
int deliveryMode,
long deliveryTime,
int priority,
long timeToLive,
String correlationID,
UriInfo uriInfo,
String body) |
Response |
sendMsgJson(HttpHeaders headers,
String prodName,
int deliveryMode,
long deliveryTime,
int priority,
long timeToLive,
String correlationID,
UriInfo uriInfo,
String json) |
Response |
sendMsgJson(HttpHeaders headers,
String prodName,
long id,
int deliveryMode,
long deliveryTime,
int priority,
long timeToLive,
String correlationID,
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(Response.ResponseBuilder builder)
@POST @Path(value="/{name}") @Consumes(value="text/plain") @Produces(value="text/plain") public Response sendMsg(@Context HttpHeaders headers, @PathParam(value="name") String prodName, @DefaultValue(value="-1")@QueryParam(value="persistent") 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 UriInfo uriInfo, String body)
@POST @Path(value="/{name}") @Consumes(value="application/json") @Produces(value="text/plain") public Response sendMsgJson(@Context HttpHeaders headers, @PathParam(value="name") String prodName, @DefaultValue(value="-1")@QueryParam(value="persistent") 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 UriInfo uriInfo, String json)
@POST @Path(value="/{name}/{id}") @Consumes(value="text/plain") @Produces(value="text/plain") public Response sendMsg(@Context HttpHeaders headers, @PathParam(value="name") String prodName, @PathParam(value="id") long id, @DefaultValue(value="-1")@QueryParam(value="persistent") 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 UriInfo uriInfo, String body)
@POST @Path(value="/{name}/{id}") @Consumes(value="application/json") @Produces(value="text/plain") public Response sendMsgJson(@Context HttpHeaders headers, @PathParam(value="name") String prodName, @PathParam(value="id") long id, @DefaultValue(value="-1")@QueryParam(value="persistent") 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 UriInfo uriInfo, String json)
@GET @Path(value="/{name}") @Produces(value={"text/plain","application/json"}) @Consumes(value="text/plain") public Response consumeMsg(@Context 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 UriInfo uriInfo)
@GET @Path(value="/{name}/{id}") @Produces(value={"text/plain","application/json"}) @Consumes(value="text/plain") public Response consumeMsg(@Context 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 UriInfo uriInfo)
private Map getPropertiesToJsonMap(Message message) throws JMSException
JMSException
@HEAD @Path(value="/{name}/commit") @Produces(value="text/plain") @Consumes(value="text/plain") public Response commit(@Context HttpHeaders headers, @PathParam(value="name") String ctxName, @Context UriInfo uriInfo)
@HEAD @Path(value="/{name}/rollback") @Produces(value="text/plain") @Consumes(value="text/plain") public Response rollback(@Context HttpHeaders headers, @PathParam(value="name") String ctxName, @Context UriInfo uriInfo)
@DELETE @Path(value="/{name}") @Produces(value="text/plain") @Consumes(value="text/plain") public Response acknowledgeCons(@Context HttpHeaders headers, @PathParam(value="name") String ctxName, @Context UriInfo uriInfo)
Copyright © 2016 ScalAgent D.T.. All Rights Reserved.