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

Class BasicAuthJcsmpSessionService

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable, SessionService

public class BasicAuthJcsmpSessionService
extends java.lang.Object
implements 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. The connection is established using basic authentication.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
BasicAuthJcsmpSessionService(java.lang.String queueName, java.lang.String host, java.lang.String username, java.lang.String password, java.lang.String vpnName) Creates a new BasicAuthJcsmpSessionService with the given parameters.

Method Summary

Modifier and Type	Method and Description
void	close() Gracefully closes the connection to the service.
void	connect() Establishes a connection to the service.
MessageReceiver	createReceiver() Creates a MessageReceiver object for receiving messages from Solace.
boolean	isClosed() Checks whether the connection to the service is currently closed.

Methods inherited from class java.lang.Object

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

Constructor Detail

BasicAuthJcsmpSessionService

public BasicAuthJcsmpSessionService(java.lang.String queueName,
                                    java.lang.String host,
                                    java.lang.String username,
                                    java.lang.String password,
                                    java.lang.String vpnName)

Creates a new BasicAuthJcsmpSessionService with the given parameters.

Parameters:

queueName - The name of the queue to receive messages from.

host - The host name or IP address of the Solace broker. Format: Host[:Port]

username - The username to use for authentication.

password - The password to use for authentication.

vpnName - The name of the VPN to connect to.

Method Detail

connect

public void connect()

Description copied from interface: 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 interface SessionService

close

public void close()

Description copied from interface: SessionService

Gracefully closes the connection to the service.

Specified by:

close in interface SessionService

createReceiver

public MessageReceiver createReceiver()

Description copied from interface: SessionService

Creates a MessageReceiver object for receiving messages from Solace. Typically, this object is created from the session instance.

Specified by:

createReceiver in interface SessionService

isClosed

public boolean isClosed()

Description copied from interface: SessionService

Checks whether the connection to the service is currently closed. This method is called when an `UnboundedSolaceReader` is starting to read messages - a session will be created if this returns true.

Specified by:

isClosed in interface SessionService