Package | Description |
---|---|
com.solacesystems.jcsmp |
The Solace Messaging API for Java (also referred to as JCSMP) is a 100% pure Java implementation that provides an object-oriented API for delivering high message throughput.
|
com.solacesystems.jcsmp.transaction |
Modifier and Type | Method and Description |
---|---|
ConsumerFlowProperties |
ConsumerFlowProperties.setAckMode(String ackMode)
Indicates whether the acknowledgement of receiving a message is done by
JCSMP automatically or by the application explicitly calling
XMLMessage.ackMessage() or XMLMessage.settle(Outcome) . |
ConsumerFlowProperties |
ConsumerFlowProperties.setAckThreshold(int ackThreshold)
Sets threshold for sending an acknowledgement, as a percentage of
window size . |
ConsumerFlowProperties |
ConsumerFlowProperties.setAckTimerInMsecs(int ackTimerInMsecs)
Sets the acknowledgement timer for the flow (in milliseconds).
|
ConsumerFlowProperties |
ConsumerFlowProperties.setActiveFlowIndication(boolean activeFlowIndication)
Applications that require a separate message for active or inactive flow indication
must set this property to
true when creating the flow. |
ConsumerFlowProperties |
ConsumerFlowProperties.setEndpoint(Endpoint endpoint)
The appliance Endpoint to bind to.
|
ConsumerFlowProperties |
ConsumerFlowProperties.setNewSubscription(Subscription newSubscription)
If binding to a
TopicEndpoint , the Topic to
set/replace as a topic subscription on the endpoint. |
ConsumerFlowProperties |
ConsumerFlowProperties.setNoLocal(boolean noLocal)
When the flow has the
noLocal flag 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. |
ConsumerFlowProperties |
ConsumerFlowProperties.setReconnectRetryIntervalInMsecs(int val)
This property specifies how much time (in ms) to wait between each attempt to reconnect to an endpoint.
|
ConsumerFlowProperties |
ConsumerFlowProperties.setReconnectTries(int count)
This property specifies the number of times to attempt to reconnect to an endpoint after the initial bound flow goes down.
|
ConsumerFlowProperties |
ConsumerFlowProperties.setReplayStartLocation(ReplayStartLocation startLocation)
This property specifies a message replay start location.
|
ConsumerFlowProperties |
ConsumerFlowProperties.setSelector(String selector)
A SQL-92 selector to use for selection of messages for delivery.
|
ConsumerFlowProperties |
ConsumerFlowProperties.setStartState(boolean startState)
Controls whether a newly created flow should be in the started state upon
creation.
|
ConsumerFlowProperties |
ConsumerFlowProperties.setTransportWindowSize(int winSz)
Sets the Guaranteed message transport window size for the flow.
|
Modifier and Type | Method and Description |
---|---|
FlowReceiver |
JCSMPSession.createFlow(XMLMessageListener listener,
ConsumerFlowProperties flowProps)
|
FlowReceiver |
JCSMPSession.createFlow(XMLMessageListener listener,
ConsumerFlowProperties flowProps,
EndpointProperties endpointProps)
|
FlowReceiver |
JCSMPSession.createFlow(XMLMessageListener listener,
ConsumerFlowProperties flowProps,
EndpointProperties endpointProps,
FlowEventHandler flowEventHandler)
|
Modifier and Type | Method and Description |
---|---|
FlowReceiver |
TransactedSession.createFlow(XMLMessageListener listener,
ConsumerFlowProperties flowProps,
EndpointProperties endpointProps)
Creates a consumer flow within this
TransactedSession and
associates it to this session. |
FlowReceiver |
TransactedSession.createFlow(XMLMessageListener listener,
ConsumerFlowProperties flowProps,
EndpointProperties endpointProps,
FlowEventHandler flowEventHandler)
Creates a consumer flow within this
TransactedSession and
associates it to this session. |
Copyright 2004-2024 Solace Corporation. All rights reserved.