| 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.serialization | |
| com.solacesystems.jcsmp.transaction |
| Modifier and Type | Method and Description |
|---|---|
XMLMessageListener |
XMLMessageConsumer.getMessageListener()
Gets the message consumer's message listener.
|
| Modifier and Type | Method and Description |
|---|---|
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)
|
XMLMessageConsumer |
JCSMPSession.getMessageConsumer(JCSMPReconnectEventHandler reconnectHandler,
XMLMessageListener listener)
Get a default
XMLMessageConsumer with a reconnect event
handler. |
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. |
void |
XMLMessageConsumer.setMessageListener(XMLMessageListener listener)
Deprecated.
As of release 4.1, please provide an
XMLMessageListener when acquiring an
XMLMessageConsumer from a session.
This method is deprecated and provided for backwards-compatibility; if using it, note
that it must be called immediately after acquiring the
XMLMessageConsumer, before it is started, and it may only be called
once. Failure to respect these conditions will result in an
IllegalStateException being thrown. |
| Modifier and Type | Method and Description |
|---|---|
static <T> XMLMessageListener |
Consumed.with(com.solace.serdes.Deserializer<T> deserializer,
BiConsumer<BytesXMLMessage,T> onData,
BiConsumer<BytesXMLMessage,RuntimeException> onDeserializationException,
Consumer<JCSMPException> onListenerException)
Creates an
XMLMessageListener used by XMLMessageConsumer with lamda functions for message payload
deserialize. |
| 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-2025 Solace Corporation. All rights reserved.