Class RequestResponseUtils
- java.lang.Object
-
- com.microsoft.azure.servicebus.primitives.RequestResponseUtils
-
public class RequestResponseUtils extends Object
-
-
Constructor Summary
Constructors Constructor Description RequestResponseUtils()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static org.apache.qpid.proton.message.Message
createRequestMessageFromPropertyBag(String operation, Map propertyBag, Duration timeout)
static org.apache.qpid.proton.message.Message
createRequestMessageFromPropertyBag(String operation, Map propertyBag, Duration timeout, String associatedLinkName)
static org.apache.qpid.proton.message.Message
createRequestMessageFromValueBody(String operation, Object valueBody, Duration timeout)
static Map<String,Object>
encodeRuleDescriptionToMap(RuleDescription ruleDescription)
static Exception
generateExceptionFromError(org.apache.qpid.proton.amqp.Symbol errorCondition, String exceptionMessage)
static Exception
genereateExceptionFromResponse(org.apache.qpid.proton.message.Message responseMessage)
static Map
getResponseBody(org.apache.qpid.proton.message.Message responseMessage)
static org.apache.qpid.proton.amqp.Symbol
getResponseErrorCondition(org.apache.qpid.proton.message.Message responseMessage)
static int
getResponseStatusCode(org.apache.qpid.proton.message.Message responseMessage)
static String
getResponseStatusDescription(org.apache.qpid.proton.message.Message responseMessage)
-
-
-
Method Detail
-
createRequestMessageFromPropertyBag
public static org.apache.qpid.proton.message.Message createRequestMessageFromPropertyBag(String operation, Map propertyBag, Duration timeout)
-
createRequestMessageFromPropertyBag
public static org.apache.qpid.proton.message.Message createRequestMessageFromPropertyBag(String operation, Map propertyBag, Duration timeout, String associatedLinkName)
-
createRequestMessageFromValueBody
public static org.apache.qpid.proton.message.Message createRequestMessageFromValueBody(String operation, Object valueBody, Duration timeout)
-
getResponseStatusCode
public static int getResponseStatusCode(org.apache.qpid.proton.message.Message responseMessage)
-
getResponseErrorCondition
public static org.apache.qpid.proton.amqp.Symbol getResponseErrorCondition(org.apache.qpid.proton.message.Message responseMessage)
-
getResponseStatusDescription
public static String getResponseStatusDescription(org.apache.qpid.proton.message.Message responseMessage)
-
getResponseBody
public static Map getResponseBody(org.apache.qpid.proton.message.Message responseMessage)
-
genereateExceptionFromResponse
public static Exception genereateExceptionFromResponse(org.apache.qpid.proton.message.Message responseMessage)
-
generateExceptionFromError
public static Exception generateExceptionFromError(org.apache.qpid.proton.amqp.Symbol errorCondition, String exceptionMessage)
-
encodeRuleDescriptionToMap
public static Map<String,Object> encodeRuleDescriptionToMap(RuleDescription ruleDescription)
-
-