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 Logger |
logger |
private static boolean |
nologlink |
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 |
getMapMessageToJsonBodyMap(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 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
private static boolean nologlink
public static void logLinks(Response.ResponseBuilder builder)
public String info(UriInfo uriInfo)
public Response sendMsg(HttpHeaders headers, String prodName, int deliveryMode, long deliveryTime, int priority, long timeToLive, String correlationID, UriInfo uriInfo, String body)
public Response sendMsgJson(HttpHeaders headers, String prodName, int deliveryMode, long deliveryTime, int priority, long timeToLive, String correlationID, UriInfo uriInfo, String json)
public Response sendMsg(HttpHeaders headers, String prodName, long id, int deliveryMode, long deliveryTime, int priority, long timeToLive, String correlationID, UriInfo uriInfo, String body)
public Response sendMsgJson(HttpHeaders headers, String prodName, long id, int deliveryMode, long deliveryTime, int priority, long timeToLive, String correlationID, UriInfo uriInfo, String json)
private Map getMapMessageToJsonBodyMap(Message message) throws JMSException
JMSException
public Response consumeMsg(HttpHeaders headers, String consName, long timeout, boolean noLocal, boolean durable, boolean shared, String subName, UriInfo uriInfo)
public Response consumeMsg(HttpHeaders headers, String consName, long id, long timeout, boolean noLocal, boolean durable, boolean shared, String subName, UriInfo uriInfo)
private Map getPropertiesToJsonMap(Message message) throws JMSException
JMSException
public Response commit(HttpHeaders headers, String ctxName, UriInfo uriInfo)
public Response rollback(HttpHeaders headers, String ctxName, UriInfo uriInfo)
public Response acknowledgeCons(HttpHeaders headers, String ctxName, UriInfo uriInfo)
public Response acknowledgeCons(HttpHeaders headers, String ctxName, long id, UriInfo uriInfo)
Copyright © 2023 ScalAgent D.T.. All rights reserved.