Package org.apache.beam.sdk.io.solace.broker

Class JcsmpSessionService

java.lang.Object

org.apache.beam.sdk.io.solace.broker.SessionService

org.apache.beam.sdk.io.solace.broker.JcsmpSessionService

All Implemented Interfaces:

Serializable

public abstract class JcsmpSessionService
extends SessionService

A class that manages a connection to a Solace broker using basic authentication.

This class provides a way to connect to a Solace broker and receive messages from a queue.

See Also:

• Serialized Form

Field Summary

Fields inherited from class org.apache.beam.sdk.io.solace.broker.SessionService

DEFAULT_VPN_NAME

Constructor Summary

Constructors

Constructor	Description
JcsmpSessionService()

Method Summary

Modifier and Type	Method	Description
void	close()	Gracefully closes the connection to the service.
void	connect()	Establishes a connection to the service.
static JcsmpSessionService	create(JCSMPProperties jcsmpProperties, Queue queue)
MessageProducer	getInitializedProducer(SolaceIO.SubmissionMode submissionMode)	Returns a MessageProducer object for publishing messages to Solace.
Queue<Solace.PublishResult>	getPublishedResultsQueue()	Returns the Queue<Solace.PublishResult> instance associated with this session, with the asynchronously received callbacks from Solace for message publications.
MessageReceiver	getReceiver()	Returns a MessageReceiver object for receiving messages from Solace.
JCSMPProperties	getSessionProperties()	Override this method and provide your specific properties, including all those related to authentication, and possibly others too.

Methods inherited from class org.apache.beam.sdk.io.solace.broker.SessionService

equals, hashCode, initializeWriteSessionProperties

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Details

JcsmpSessionService

public JcsmpSessionService()

Method Details

create

public static JcsmpSessionService create(JCSMPProperties jcsmpProperties,
 @Nullable
 Queue queue)

getSessionProperties

public JCSMPProperties getSessionProperties()

Description copied from class: SessionService

Override this method and provide your specific properties, including all those related to authentication, and possibly others too.

The method will be used whenever the session needs to be created or refreshed. If you are setting credentials with expiration, just make sure that the latest available credentials (e.g. renewed token) are set when the method is called.

For a list of all the properties that can be set, please check the following link:

• https://docs.solace.com/API-Developer-Online-Ref-Documentation/java/com/solacesystems/jcsmp/JCSMPProperties.html

Specified by:

getSessionProperties in class SessionService

connect

public void connect()

Description copied from class: SessionService

Establishes a connection to the service. This could involve providing connection details like host, port, VPN name, username, and password.

Specified by:

connect in class SessionService

close

public void close()

Description copied from class: SessionService

Gracefully closes the connection to the service.

Specified by:

close in class SessionService

getReceiver

public MessageReceiver getReceiver()

Description copied from class: SessionService

Returns a MessageReceiver object for receiving messages from Solace. If it is the first time this method is used, the receiver is created from the session instance, otherwise it returns the receiver created initially.

Specified by:

getReceiver in class SessionService

getInitializedProducer

public MessageProducer getInitializedProducer(SolaceIO.SubmissionMode submissionMode)

Description copied from class: SessionService

Returns a MessageProducer object for publishing messages to Solace. If it is the first time this method is used, the producer is created from the session instance, otherwise it returns the producer created initially.

Specified by:

getInitializedProducer in class SessionService

getPublishedResultsQueue

public Queue<Solace.PublishResult> getPublishedResultsQueue()

Description copied from class: SessionService

Returns the Queue<Solace.PublishResult> instance associated with this session, with the asynchronously received callbacks from Solace for message publications. The queue implementation has to be thread-safe for production use-cases.

Specified by:

getPublishedResultsQueue in class SessionService