public class TransportOptions
extends java.lang.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 java.lang.String |
_URI
Deprecated.
use Option.URI
|
static java.lang.String |
BLOCKING_THROTTLING
Deprecated.
use Option.BLOCKING_THROTTLING
|
static java.lang.String |
CONTENT_STREAMING
Deprecated.
use Option.CONTENT_STREAMING
|
static int |
DEFAULT_PRIORITY |
static java.lang.String |
INBOUND_ENDPOINT
Deprecated.
use Option.INBOUND_ENDPOINT
|
static java.lang.String |
MESSAGE_PRIORITY
Deprecated.
use Option.MESSAGE_PRIORITY
|
static java.lang.String |
MODE
Deprecated.
use Option.MODE
|
static java.lang.String |
OPAQUE_DATA
Deprecated.
use Option.OPAQUE_DATA
|
static java.lang.String |
OPERATION_NAME
Deprecated.
use Option.OPERATION_NAME
|
static java.lang.String |
QOS
Deprecated.
use Option.QOS
|
static java.lang.String |
REPLY_SYNC
Deprecated.
use Option.REPLY_SYNC
|
static java.lang.String |
REPLY_WITH_FAILURE
Deprecated.
use Option.REPLY_WITH_FAILURE
|
static java.lang.String |
RETRY_COUNT
Deprecated.
use Option.RETRY_COUNT
|
static java.lang.String |
RETRY_INTERVAL
Deprecated.
use Option.RETRY_INTERVAL
|
static java.lang.String |
THROW_ON_ERROR
Deprecated.
use Option.THROW_ON_ERROR
|
Constructor and Description |
---|
TransportOptions() |
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
get(java.lang.Object key) |
java.lang.Object |
get(TransportOptions.Option option) |
int |
getMessagePriority() |
TransportOptions.ModeEnum |
getMode() |
java.util.Map<java.lang.String,java.lang.Object> |
getOpaqueData() |
java.lang.String |
getOperationName() |
TransportOptions.QoSEnum |
getQoS() |
int |
getRetryCount() |
int |
getRetryInterval() |
java.net.URI |
getURI() |
boolean |
hasOption(java.lang.Object key) |
boolean |
hasOption(TransportOptions.Option option) |
static boolean |
hasOption(TransportOptions options, java.lang.Object option)
utility method
|
boolean |
isBlockingThrottling() |
boolean |
isContentStreamingEnabled() |
boolean |
isReplySync() |
boolean |
isReplyWithFailure() |
boolean |
isThrowOnError() |
TransportOptions |
put(java.lang.Object option) |
TransportOptions |
put(java.lang.Object option, int value)
set the value of the option with a given key to specified value
|
TransportOptions |
put(java.lang.Object option, java.lang.Object value)
set the value of the option with a given key to specified value
|
TransportOptions |
put(TransportOptions.Option option) |
void |
remove(java.lang.Object key)
delete of the option with a given key
|
TransportOptions |
remove(TransportOptions.Option option)
delete of the option with a given key
|
static java.lang.Object |
safeGet(TransportOptions options, java.lang.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(java.util.Map<java.lang.String,java.lang.Object> data)
Stores opaque (i.e.
|
TransportOptions |
setOperationName(java.lang.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(java.net.URI val)
specifies which URI is to be used when sending outbound requests via a transport provider
|
java.lang.String |
toString() |
public static final java.lang.String QOS
public static final java.lang.String THROW_ON_ERROR
public static final java.lang.String MODE
public static final java.lang.String _URI
public static final java.lang.String RETRY_INTERVAL
public static final java.lang.String RETRY_COUNT
public static final java.lang.String OPERATION_NAME
public static final java.lang.String INBOUND_ENDPOINT
public static final java.lang.String OPAQUE_DATA
public static final java.lang.String MESSAGE_PRIORITY
public static final java.lang.String BLOCKING_THROTTLING
public static final java.lang.String REPLY_WITH_FAILURE
public static final java.lang.String REPLY_SYNC
public static final java.lang.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(java.net.URI val)
val
- uripublic java.net.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(java.lang.String val)
val
- operation namepublic java.lang.String getOperationName()
public TransportOptions setMessagePriority(int priority)
public int getMessagePriority()
public TransportOptions setOpaqueData(java.util.Map<java.lang.String,java.lang.Object> data)
data
- opaque data, a map of object keyed by string.public java.util.Map<java.lang.String,java.lang.Object> getOpaqueData()
public boolean hasOption(TransportOptions.Option option)
option
- option keypublic boolean hasOption(java.lang.Object key)
key
- option keypublic java.lang.Object get(TransportOptions.Option option)
option
- option keypublic java.lang.Object get(java.lang.Object key)
key
- option keypublic TransportOptions put(TransportOptions.Option option)
option
- option keypublic TransportOptions put(java.lang.Object option)
option
- option keypublic TransportOptions put(java.lang.Object option, int value)
option
- object representing the option keyvalue
- int value for the given keypublic TransportOptions put(java.lang.Object option, java.lang.Object value)
option
- object representing the option keyvalue
- object value for the given keypublic TransportOptions remove(TransportOptions.Option option)
option
- keypublic void remove(java.lang.Object key)
key
- keypublic static java.lang.Object safeGet(TransportOptions options, java.lang.Object option)
option
- keyoptions
- transport options to introspectpublic static boolean hasOption(TransportOptions options, java.lang.Object option)
option
- keyoptions
- transport options to introspectpublic java.lang.String toString()
toString
in class java.lang.Object