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 | Class and Description |
---|---|
class |
ClosedFacilityException
ClosedFacilityException indicates that the requested operation
cannot be fulfilled because the facility providing the operation was closed. |
class |
InvalidMessageReceivedException
InvalidMessageReceivedException is raised when the message received from the Solace appliance
is not valid. |
class |
InvalidOperationException
InvalidOperationException indicates that the requested operation
cannot be fulfilled because the object on which it was performed is not
in a state to support such an operation. |
class |
InvalidPropertiesException
InvalidPropertiesException indicates invalid properties are specified
in JCSMPProperties . |
class |
JCSMPErrorResponseException
JCSMPErrorResponseException is used to capture Solace Message
Format (SMF) response codes. |
class |
JCSMPFatalErrorException
JCSMPFatalErrorException indicates an unrecoverable error condition. |
class |
JCSMPFlowTransportException
Indicates a transport error condition for a specific flow, while the parent
session is not necessarily closed.
|
class |
JCSMPFlowTransportUnsolicitedUnbindException
This exception is used to indicate that a Guaranteed Delivery Flow (
FlowReceiver )
encountered a terminal condition making the flow unusable and must be closed/destroyed due to an unsolicited unbind
for the resource it requires. |
class |
JCSMPInterruptedException |
class |
JCSMPLoginFailureException
Indicates a producer or consumer was unable to login to the 3200 Series
appliance.
|
class |
JCSMPNotComparableException
NotComparableException indicates that the comparison operation
failed because the two objects being compared are semantically not comparable. |
class |
JCSMPOperationException
JCSMPOperationException indicates an error condition related to Content Subscription Management Protocol (CSMP)
operation. |
class |
JCSMPRequestTimeoutException
Indicates that a blocking request operation timed out.
|
class |
JCSMPResponseTimeoutException
JCSMPResponseTimeoutException is used for client request timeout. |
class |
JCSMPSecurityException
Thrown when a security restriction prevents an operation from being performed.
|
class |
JCSMPStateException
JCSMPStateException indicates that the program logic cannot proceed
based on the current JCSMPSession state. |
class |
JCSMPTransportException
JCSMPTransportException indicates an error condition regarding
communication with the Solace appliance. |
class |
OperationNotSupportedException
OperationNotSupportedException indicates the requested operation
is not supported based on the current Session configuration. |
class |
PropertyMismatchException
A general exception for property mismatch problems.
|
class |
SDTEOFException
SDTEOFException indicates a read operation was
performed on an SDTStream which has no more data to read. |
class |
SDTException
The base class of SDT exceptions.
|
class |
SDTFormatException
SDTFormatException indicates a type conversion
error occurred retrieving data from an SDTMap or SDTStream. |
class |
StaleSessionException
StaleSessionException indicates that the requested operation
cannot be fulfilled because the underlying session was stale. |
class |
SubscriptionsOutOfSynchException
Deprecated.
This class is no longer supported and will be removed in a future
release.
|
class |
VersionNotSupportException
Exception thrown when the appliance version is not compatible with the JCSMP version.
|
Modifier and Type | Method and Description |
---|---|
JCSMPException |
CacheEventMessage.getCacheRequestException()
Returns the exception that occurred when a cache request failed.
|
JCSMPException |
StaleSessionException.getCause() |
Modifier and Type | Method and Description |
---|---|
default void |
JCSMPStreamingPublishCorrelatingEventHandler.handleError(String messageID,
JCSMPException cause,
long timestamp) |
void |
JCSMPStreamingPublishEventHandler.handleError(String messageID,
JCSMPException cause,
long timestamp)
Deprecated.
Use
JCSMPStreamingPublishCorrelatingEventHandler instead.
This method is invoked during streaming publishing if there is an error
in reading the response, or if a non-OK response is read.
Note: Handler processing should be kept to a minimum because it blocks the thread from which the error originated. Error responses from the applianceIf an error response is available, it is represented as aJCSMPErrorResponseException . The subcodes discussed in
JCSMPStreamingPublishCorrelatingEventHandler might be present to provide
further information about why the message was rejected. |
void |
JCSMPStreamingPublishCorrelatingEventHandler.handleErrorEx(Object key,
JCSMPException cause,
long timestamp)
This method is invoked during streaming publishing if there is an error
in reading the response, or if a non-OK response is read.
|
void |
XMLMessageListener.onException(JCSMPException exception)
On error, this method is invoked.
|
void |
CacheRequestListener.onException(Long requestId,
Topic topic,
JCSMPException exception)
Called when an asynchronous cache request ends with an error.
|
Modifier and Type | Method and Description |
---|---|
void |
Session.addSubscriber()
Deprecated.
It is no longer necessary to call this function. This
function might be removed in a future version of JCSMP.
|
void |
JCSMPSession.addSubscription(Endpoint endpoint,
Subscription subscription,
int subscribeFlags)
Adds a subscription to an Endpoint on the appliance.
|
void |
JCSMPSession.addSubscription(Endpoint endpoint,
Subscription subscription,
JCSMPResponseListener handler,
Object key)
Adds a subscription asynchronously to an Endpoint on the appliance.
|
void |
JCSMPSession.addSubscription(Subscription subscription)
Adds a subscription to the appliance.
|
void |
JCSMPSession.addSubscription(Subscription subscription,
boolean waitForConfirm)
Adds a subscription to an appliance.
|
void |
JCSMPSession.addSubscription(Subscription subscription,
JCSMPResponseListener handler,
Object key)
Adds a subscription asynchronously to the appliance.
|
void |
JCSMPSession.applySubscriptions(Set<Subscription> subscriptions)
Uses the subscription refresh feature to override the subscriptions and
subscription filters associated with a subscriber on the appliance with a
given list of subscriptions.
|
void |
Session.clearSubscriber()
Deprecated.
This method is no longer supported. The recommended way to
delete subscriptions from the appliance is to perform an
applySubscriptions() on the session with an
empty subscription list. |
void |
JCSMPSession.connect()
Connect to the appliance.
|
Browser |
JCSMPSession.createBrowser(BrowserProperties properties)
Creates a
Browser , which can be used for browsing the contents of a Queue. |
Browser |
JCSMPSession.createBrowser(BrowserProperties properties,
FlowEventHandler flowEventHandler)
Creates a
Browser , which can be used for browsing the contents of a Queue. |
BytesMessage |
Producer.createBytesMessage()
Applications use this method to create a
BytesMessage . |
BytesXMLMessage |
Producer.createBytesXMLMessage()
Applications use this method to create a
BytesXMLMessage . |
BytesXMLMessage |
Producer.createBytesXMLMessage(byte[] value)
Applications use this method to create a
BytesXMLMessage . |
CacheSession |
JCSMPSession.createCacheSession(CacheSessionProperties properties)
Creates a CacheSession using the provided CacheSession properties.
|
FlowReceiver |
JCSMPSession.createFlow(Endpoint endpoint,
Subscription newSubscription,
XMLMessageListener listener)
|
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)
|
MapMessage |
Producer.createMapMessage()
Applications use this method to create a
MapMessage . |
TopicEndpoint |
JCSMPSession.createNonDurableTopicEndpoint()
Creates a non-durable Topic Endpoint.
|
TopicEndpoint |
JCSMPSession.createNonDurableTopicEndpoint(String name)
Creates a non-durable Topic Endpoint based on the given name.
|
Requestor |
JCSMPSession.createRequestor()
Creates a new
Requestor for this Session. |
StreamMessage |
Producer.createStreamMessage()
Applications use this method to create a
StreamMessage . |
StreamXMLMessage |
Producer.createStreamXMLMessage()
Deprecated.
|
StreamXMLMessage |
Producer.createStreamXMLMessage(InputStream stream)
Deprecated.
|
Queue |
JCSMPSession.createTemporaryQueue()
Creates a temporary Queue for this Session.
|
Queue |
JCSMPSession.createTemporaryQueue(String name)
Creates a temporary Queue with the given name.
|
Topic |
JCSMPSession.createTemporaryTopic()
Creates a temporary Topic for this Session.
|
TextMessage |
Producer.createTextMessage()
Applications use this method to create a
TextMessage . |
TextXMLMessage |
Producer.createTextXMLMessage()
Deprecated.
|
TextXMLMessage |
Producer.createTextXMLMessage(String text)
Deprecated.
|
TransactedSession |
JCSMPSession.createTransactedSession()
Creates a new
TransactedSession with the connected appliance. |
XMLContentMessage |
Producer.createXMLContentMessage()
Applications use this method to create a
XMLContentMessage . |
void |
JCSMPSession.deprovision(Endpoint endpoint,
long deprovisionFlags)
Deprovisions an Endpoint on the appliance.
|
Object |
JCSMPSession.getCapability(CapabilityType type)
Gets the value of a capability for the currently connected Session.
|
XMLMessageConsumer |
JCSMPSession.getMessageConsumer()
Deprecated.
|
XMLMessageConsumer |
JCSMPSession.getMessageConsumer(JCSMPReconnectEventHandler reconnectHandler)
Deprecated.
|
XMLMessageConsumer |
JCSMPSession.getMessageConsumer(JCSMPReconnectEventHandler reconnectHandler,
XMLMessageListener listener)
Get a default
XMLMessageConsumer with a reconnect event
handler. |
XMLMessageConsumer |
JCSMPSession.getMessageConsumer(SubscriptionStateProvider subscriptionStateProvider)
Deprecated.
|
XMLMessageConsumer |
JCSMPSession.getMessageConsumer(SubscriptionStateProvider subscriptionStateProvider,
JCSMPReconnectEventHandler reconnectHandler)
|
XMLMessageConsumer |
JCSMPSession.getMessageConsumer(SubscriptionStateProvider subscriptionStateProvider,
JCSMPReconnectEventHandler reconnectHandler,
XMLMessageListener listener)
Deprecated.
Subscriptions out-of-sync checking is no longer supported.
This method will be removed in a future version.
|
XMLMessageConsumer |
JCSMPSession.getMessageConsumer(SubscriptionStateProvider subscriptionStateProvider,
XMLMessageListener listener)
Deprecated.
Subscriptions out-of-sync checking is no longer supported.
This method will be removed in a future version.
|
XMLMessageConsumer |
JCSMPSession.getMessageConsumer(XMLMessageListener listener)
Get a default
XMLMessageConsumer . |
XMLMessageProducer |
JCSMPSession.getMessageProducer()
Deprecated.
Please see
JCSMPSession.getMessageProducer(JCSMPStreamingPublishEventHandler) .
Note that using this deprecated method can introduce a performance
penalty during a streaming publishing Session because it forces the appliance to
transmit acknowledgements to every message. Using the recommended
JCSMPSession.getMessageProducer(JCSMPStreamingPublishEventHandler) form
eliminates this problem. |
XMLMessageProducer |
JCSMPSession.getMessageProducer(JCSMPStreamingPublishEventHandler callback)
Get an instance of
XMLMessageProducer . |
XMLMessageProducer |
JCSMPSession.getMessageProducer(JCSMPStreamingPublishEventHandler streamCallback,
JCSMPProducerEventHandler eventCallback)
Get an instance of
XMLMessageProducer . |
BytesXMLMessage |
Browser.getNext()
Retrieve the next message from the Browser's local message buffer, if one
is available, waiting if necessary up to the timeout configured in
BrowserProperties . |
BytesXMLMessage |
Browser.getNext(int timeoutInMillis)
Retrieve the next message from the Browser's local message buffer, if one
is available, waiting if necessary up to
timeoutInMillis ms. |
BytesXMLMessage |
Browser.getNextNoWait()
If there is at least one message available in the Browser's local message
buffer, return it immediately; otherwise, return null.
|
JCSMPStreamingPublishEventHandler |
Producer.getStreamingCallbackHandler()
Deprecated.
|
boolean |
Browser.hasMore()
Returns true if there is at least one message available in the Browser's
local message buffer.
|
void |
JCSMPReconnectEventHandler.postReconnect()
Called after each reconnection.
|
boolean |
JCSMPReconnectEventHandler.preReconnect()
Called before each reconnection attempt.
|
void |
JCSMPSession.provision(Endpoint endpoint,
EndpointProperties props,
long provisionFlags)
Provisions an Endpoint on the appliance.
|
BytesXMLMessage |
Consumer.receive()
Receives the next available message, waiting until one is available.
|
BytesXMLMessage |
Consumer.receive(int timeoutInMillis)
Receives the next available message.
|
BytesXMLMessage |
Consumer.receiveNoWait()
Receives the next available message.
|
void |
Browser.remove(BytesXMLMessage message)
Remove a message from the appliance's Queue Endpoint.
|
void |
Session.removeSubscriber()
Deprecated.
Subscribers are now created and removed only through the
appliance's management interface. This method has the same
effect as
Session.clearSubscriber() |
void |
JCSMPSession.removeSubscription(Endpoint endpoint,
Subscription subscription,
int unsubscribeFlags)
Removes a subscription from an Endpoint on the appliance.
|
void |
JCSMPSession.removeSubscription(Endpoint endpoint,
Subscription subscription,
JCSMPResponseListener handler,
Object key)
Removes a subscription asynchronously from an Endpoint on the appliance.
|
void |
JCSMPSession.removeSubscription(Subscription subscription)
Removes a subscription from the appliance.
|
void |
JCSMPSession.removeSubscription(Subscription subscription,
boolean waitForConfirm)
Removes a subscription from the appliance.
|
void |
JCSMPSession.removeSubscription(Subscription subscription,
JCSMPResponseListener handler,
Object key)
Removes a subscription asynchronously from the appliance.
|
BytesXMLMessage |
Requestor.request(XMLMessage request,
long timeoutMillis,
Destination sendDestination)
Performs a request to the specified destination.
|
void |
XMLMessageProducer.send(XMLMessage message)
Deprecated.
|
void |
XMLMessageProducer.send(XMLMessage message,
Destination destination)
Sends a message to a destination, such as a Queue or Topic.
|
CacheRequestResult |
CacheSession.sendCacheRequest(Long requestId,
Topic topic,
boolean subscribe,
CacheLiveDataAction liveDataAction)
Send a synchronous cache request message.
|
void |
CacheSession.sendCacheRequest(Long requestId,
Topic topic,
boolean subscribe,
CacheLiveDataAction liveDataAction,
CacheRequestListener listener)
Send an asynchronous cache request message.
|
int |
XMLMessageProducer.sendMultiple(JCSMPSendMultipleEntry[] entries,
int offset,
int length,
int sendFlags)
Sends a batch of messages.
|
void |
XMLMessageProducer.sendReply(XMLMessage requestMessage,
XMLMessage replyMessage)
Convenience function for sending a reply message.
|
void |
JCSMPSession.setProperty(String property,
Object value)
Sets a modifiable Session property once the Session has been constructed.
|
void |
XMLMessageProducer.setStreamingCallbackHandler(JCSMPStreamingPublishEventHandler callback)
Deprecated.
As of release 4.1, please provide an
JCSMPStreamingPublishEventHandler when acquiring an
XMLMessageProducer from a session.
This method is deprecated and has no effect. |
void |
XMLMessage.settle(XMLMessage.Outcome outcome)
Settles a message in a requested way.
|
void |
Consumer.start()
Enables receiving messages from an appliance.
|
void |
JCSMPSession.unsubscribeDurableTopicEndpoint(DurableTopicEndpoint endpoint)
Unsubscribe from the durable Topic Endpoint.
|
Constructor and Description |
---|
StaleSessionException(String message,
JCSMPException cause) |
Modifier and Type | Class and Description |
---|---|
class |
RollbackException
An exception thrown when a transaction rolls back unexpectedly.
|
class |
TransactionResultUnknownException
An exception thrown when a transaction commit result is unknown.
|
Modifier and Type | Method and Description |
---|---|
void |
TransactedSession.commit()
Commit the active transaction.
|
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. |
XMLMessageProducer |
TransactedSession.createProducer(ProducerFlowProperties fprop,
JCSMPStreamingPublishEventHandler callback)
Creates a producer flow within this
TransactedSession and
associates it to this session. |
XMLMessageProducer |
TransactedSession.createProducer(ProducerFlowProperties fprop,
JCSMPStreamingPublishEventHandler streamCallback,
JCSMPProducerEventHandler eventCallback)
Creates a producer flow within this
TransactedSession and
associates it to this session. |
void |
TransactedSession.rollback()
Rollback the active transaction.
|
Copyright 2004-2024 Solace Corporation. All rights reserved.