public static final class FlowHandle.PROPERTIES
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
ACK_THRESHOLD
The threshold for sending an acknowledgement, configured as a percentage.
|
static java.lang.String |
ACK_TIMER_MS
The duration of the Flow acknowledgement timer (in milliseconds).
|
static java.lang.String |
ACKMODE
Controls how acknowledgements are generated for received Guaranteed messages.
Possible values in SolEnum.AckMode Default: SolEnum.AckMode.AUTO |
static java.lang.String |
ACTIVE_FLOW_IND
When a Flow has the Active Flow Indication property enabled, the application will receive flow events when the flow becomes
active, or inactive.
|
static java.lang.String |
BIND_BLOCKING
This property controls whether or not to block in
SessionHandle#createFlowForHandle .Possible values in SolEnum.BooleanValue Default: SolEnum.BooleanValue#ENABLE |
static java.lang.String |
BIND_TIMEOUT_MS
The timeout (in milliseconds) used when creating a Flow in blocking mode.
|
static java.lang.String |
BROWSER
Set browser mode on flow and signal it is a browser flow to appliance on bind.
|
static java.lang.String |
MAX_BIND_TRIES
When creating a non-blocking Flow, or a Flow that is bound due to Session-connect,
the maximum number of bind attempts to make.
|
static java.lang.String |
MAX_RECONNECT_TRIES
When a connected flow receives an unsolicited unbind event with subcode
REPLAY_STARTED or GM_UNAVAILABLE, the SDK can reconnect the flow automatically.
|
static java.lang.String |
MAX_UNACKED_MESSAGES
This property may only be set when the Flow property
FlowHandle.PROPERTIES.ACKMODE is set to
SolEnum.AckMode.CLIENT . |
static java.lang.String |
NO_LOCAL
When a Flow has the No Local property enabled, messages published on the Session cannot appear in
a Flow created in the same Session, even if the endpoint contains a subscription that matches the
published message.
|
static java.lang.String |
RECONNECT_RETRY_INTERVAL_MS
Time to wait between flow auto reconnect attempts, in milliseconds.
|
static java.lang.String |
REPLAY_START_LOCATION
When a Flow is created, the application may request replay of messages from the replay log, even messages
that have been previously delivered and removed from the topic endpoint or queue.
|
static java.lang.String |
REQUIRED_OUTCOME_FAILED
This property allows the flow to use
FlowHandle.settle(long, int) or
FlowHandle.settle(MessageHandle, int)
with SolEnum.MessageOutcome.FAILED outcome. |
static java.lang.String |
REQUIRED_OUTCOME_REJECTED
This property allows the flow to use
FlowHandle.settle(long, int) or
FlowHandle.settle(MessageHandle, int)
with SolEnum.MessageOutcome.REJECTED outcome. |
static java.lang.String |
SELECTOR
A Java Message System (JMS) defined selector.
|
static java.lang.String |
START_STATE
This property controls whether the Flow should be created in a start or stop state with respect to
receiving messages.
|
static java.lang.String |
WINDOWSIZE
The Guaranteed message window size for the Flow.
|
Constructor and Description |
---|
PROPERTIES() |
public static final java.lang.String BIND_BLOCKING
SessionHandle#createFlowForHandle
.SolEnum.BooleanValue
SolEnum.BooleanValue#ENABLE
public static final java.lang.String BIND_TIMEOUT_MS
public static final java.lang.String WINDOWSIZE
public static final java.lang.String ACKMODE
SolEnum.AckMode
SolEnum.AckMode.AUTO
public static final java.lang.String MAX_BIND_TRIES
public static final java.lang.String ACK_TIMER_MS
public static final java.lang.String ACK_THRESHOLD
public static final java.lang.String START_STATE
FlowHandle.start()
or FlowHandle.stop()
.SolEnum.BooleanValue
SolEnum.BooleanValue.ENABLE
public static final java.lang.String SELECTOR
public static final java.lang.String NO_LOCAL
SessionHandle#createFlowForHandle
returns SolEnum.ReturnCode.FAIL
and SolEnum.SubCode#NO_LOCAL_NOT_SUPPORTED
set.SolEnum.BooleanValue
SolEnum.BooleanValue.DISABLE
public static final java.lang.String MAX_UNACKED_MESSAGES
FlowHandle.PROPERTIES.ACKMODE
is set to
SolEnum.AckMode.CLIENT
.
When set to a positive value, this property controls the maximum number of messages that may be unacknowledged on the Flow
(FlowHandle.ack(long)
is called to acknowledge messages and remove those messages from the message spool).
This property cannot be used to increase the appliance configured maximum number of acknowledged messages on the endpoint.
When set to -1, the appliance configured maximum controls how many unacknowledged messages may be received
by the application. Valid values are -1 and >0. public static final java.lang.String BROWSER
FlowHandle.start()
to get more messages.
After being browsed, messages are still available for consumption over normal flows. However, it is possible to selectively
remove messages (by calling FlowHandle.ack(long)
)
from the persistent store of an Endpoint, in this case, these removed messages will no longer be available for consumption.SolEnum.BooleanValue
SolEnum.BooleanValue.DISABLE
public static final java.lang.String ACTIVE_FLOW_IND
SessionHandle#createFlowForHandle
returns
SolEnum.ReturnCode.FAIL
and sets the
SubCode SolEnum.SubCode#FLOW_ACTIVE_FLOW_INDICATION_UNSUPPORTED
.SolEnum.BooleanValue
SolEnum.BooleanValue.DISABLE
public static final java.lang.String REPLAY_START_LOCATION
SolEnum.ReplayStartLocation.BEGINNING
to indicate that all messages available should be replayed. Or the replay start location may be a string
that begins with "DATE:" followed by a date in one of two formats. The date may be a string representing
a long integer, which is the number of seconds since the epoch - 0:00:00 Jan 1, 1970. The data may
be a string as specified in RFC3339 -
'YYYY-MM-DDTHH:MM:SS[.1*DIGIT]Z' or 'YYYY-MM-DDTHH:MM:SS[.1*DIGIT]("+"/"-")HH:MM'.
Additionally, the replay start location may be a replication-group-message-id string as returned by
ReplicationGroupMessageIdHandleImpl.toString()
.
Such a string starts with "rmid1:" and is a ReplicationGroupMessageIdHandle
.public static final java.lang.String MAX_RECONNECT_TRIES
public static final java.lang.String RECONNECT_RETRY_INTERVAL_MS
FlowHandle.PROPERTIES.REPLAY_START_LOCATION
Default: 3000public static final java.lang.String REQUIRED_OUTCOME_FAILED
FlowHandle.settle(long, int)
or
FlowHandle.settle(MessageHandle, int)
with SolEnum.MessageOutcome.FAILED
outcome.
Requires broker capability SolEnum.CapabilityName.CAPABILITY_AD_APP_ACK_FAILED
SolEnum.BooleanValue.DISABLE
public static final java.lang.String REQUIRED_OUTCOME_REJECTED
FlowHandle.settle(long, int)
or
FlowHandle.settle(MessageHandle, int)
with SolEnum.MessageOutcome.REJECTED
outcome.
Requires broker capability SolEnum.CapabilityName.CAPABILITY_AD_APP_ACK_FAILED
SolEnum.BooleanValue.DISABLE
Copyright 2004-2024 Solace Corporation. All rights reserved.