public class TransportOptions extends Object
TransportOptions opts = new TransportOptions(); opts.setQoS(EXACTLY_ONCE); opts.setThrowOnError(true);The alternative is single-line usage:
new TransportOptions().setQoS(EXACTLY_ONCE).setThrowOnError()));
Modifier and Type | Class and Description |
---|---|
static class |
TransportOptions.ModeEnum |
static class |
TransportOptions.Option |
static class |
TransportOptions.QoSEnum |
Modifier and Type | Field and Description |
---|---|
static String |
_URI
Deprecated.
use Option.URI
|
static String |
BLOCKING_THROTTLING
Deprecated.
use Option.BLOCKING_THROTTLING
|
static String |
CONTENT_STREAMING
Deprecated.
use Option.CONTENT_STREAMING
|
static int |
DEFAULT_PRIORITY |
static String |
INBOUND_ENDPOINT
Deprecated.
use Option.INBOUND_ENDPOINT
|
static String |
MESSAGE_PRIORITY
Deprecated.
use Option.MESSAGE_PRIORITY
|
static String |
MODE
Deprecated.
use Option.MODE
|
static String |
OPAQUE_DATA
Deprecated.
use Option.OPAQUE_DATA
|
static String |
OPERATION_NAME
Deprecated.
use Option.OPERATION_NAME
|
static String |
QOS
Deprecated.
use Option.QOS
|
static String |
REPLY_SYNC
Deprecated.
use Option.REPLY_SYNC
|
static String |
REPLY_WITH_FAILURE
Deprecated.
use Option.REPLY_WITH_FAILURE
|
static String |
RETRY_COUNT
Deprecated.
use Option.RETRY_COUNT
|
static String |
RETRY_INTERVAL
Deprecated.
use Option.RETRY_INTERVAL
|
static String |
THROW_ON_ERROR
Deprecated.
use Option.THROW_ON_ERROR
|
Constructor and Description |
---|
TransportOptions() |
Modifier and Type | Method and Description |
---|---|
Object |
get(Object key) |
Object |
get(TransportOptions.Option option) |
int |
getMessagePriority() |
TransportOptions.ModeEnum |
getMode() |
Map<String,Object> |
getOpaqueData() |
String |
getOperationName() |
TransportOptions.QoSEnum |
getQoS() |
int |
getRetryCount() |
int |
getRetryInterval() |
URI |
getURI() |
boolean |
hasOption(Object key) |
boolean |
hasOption(TransportOptions.Option option) |
static boolean |
hasOption(TransportOptions options, Object option)
utility method
|
boolean |
isBlockingThrottling() |
boolean |
isContentStreamingEnabled() |
boolean |
isReplySync() |
boolean |
isReplyWithFailure() |
boolean |
isThrowOnError() |
TransportOptions |
put(Object option) |
TransportOptions |
put(Object option, int value)
set the value of the option with a given key to specified value
|
TransportOptions |
put(Object option, Object value)
set the value of the option with a given key to specified value
|
TransportOptions |
put(TransportOptions.Option option) |
void |
remove(Object key)
delete of the option with a given key
|
TransportOptions |
remove(TransportOptions.Option option)
delete of the option with a given key
|
static Object |
safeGet(TransportOptions options, Object option)
utility method
|
TransportOptions |
setBlockingThrottling() |
TransportOptions |
setMessagePriority(int priority) |
TransportOptions |
setMode(TransportOptions.ModeEnum val)
specifies the type of the message being processed by OSB - one-way or request/response.
|
TransportOptions |
setOpaqueData(Map<String,Object> data)
Stores opaque (i.e.
|
TransportOptions |
setOperationName(String val)
specifies the name of the Web Service operation, when applicable for outbound requests.
|
TransportOptions |
setQoS(TransportOptions.QoSEnum val)
specifies whether or not "exactly-once" qualify of service can be achieved.
|
TransportOptions |
setReplyWithFailure() |
TransportOptions |
setRetryCount(int val)
specifies the retry count is to used in case of delivery failure when sending outbound requests via a transport provider.
|
TransportOptions |
setRetryInterval(int val)
specifies the retry interval is to used in case of delivery failure when sending outbound requests via a transport provider.
|
TransportOptions |
setThrowOnError()
if set, an exception will be thrown to the callee of method TransportManager.receiveMessage() due to an error that occurs during the OSB pipeline processing.
|
TransportOptions |
setURI(URI val)
specifies which URI is to be used when sending outbound requests via a transport provider
|
String |
toString() |
public static final String QOS
public static final String THROW_ON_ERROR
public static final String MODE
public static final String _URI
public static final String RETRY_INTERVAL
public static final String RETRY_COUNT
public static final String OPERATION_NAME
public static final String INBOUND_ENDPOINT
public static final String OPAQUE_DATA
public static final String MESSAGE_PRIORITY
public static final String BLOCKING_THROTTLING
public static final String REPLY_WITH_FAILURE
public static final String REPLY_SYNC
public static final String CONTENT_STREAMING
public static final int DEFAULT_PRIORITY
public TransportOptions setQoS(TransportOptions.QoSEnum val)
val
- quality of service enumpublic TransportOptions.QoSEnum getQoS()
public TransportOptions setMode(TransportOptions.ModeEnum val)
val
- modepublic TransportOptions.ModeEnum getMode()
public TransportOptions setThrowOnError()
public boolean isThrowOnError()
public TransportOptions setBlockingThrottling()
public boolean isBlockingThrottling()
public boolean isReplyWithFailure()
public TransportOptions setReplyWithFailure()
public boolean isReplySync()
public boolean isContentStreamingEnabled()
public TransportOptions setURI(URI val)
val
- uripublic URI getURI()
public TransportOptions setRetryInterval(int val)
val
- retry intervalpublic int getRetryInterval()
public TransportOptions setRetryCount(int val)
val
- retry countpublic int getRetryCount()
public TransportOptions setOperationName(String val)
val
- operation namepublic String getOperationName()
public TransportOptions setMessagePriority(int priority)
public int getMessagePriority()
public TransportOptions setOpaqueData(Map<String,Object> data)
data
- opaque data, a map of object keyed by string.public Map<String,Object> getOpaqueData()
public boolean hasOption(TransportOptions.Option option)
option
- option keypublic boolean hasOption(Object key)
key
- option keypublic Object get(TransportOptions.Option option)
option
- option keypublic Object get(Object key)
key
- option keypublic TransportOptions put(TransportOptions.Option option)
option
- option keypublic TransportOptions put(Object option)
option
- option keypublic TransportOptions put(Object option, int value)
option
- object representing the option keyvalue
- int value for the given keypublic TransportOptions put(Object option, Object value)
option
- object representing the option keyvalue
- object value for the given keypublic TransportOptions remove(TransportOptions.Option option)
option
- keypublic void remove(Object key)
key
- keypublic static Object safeGet(TransportOptions options, Object option)
option
- keyoptions
- transport options to introspectpublic static boolean hasOption(TransportOptions options, Object option)
option
- keyoptions
- transport options to introspect