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

Class SessionServiceFactory

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable

Direct Known Subclasses:

BasicAuthJcsmpSessionServiceFactory, GCPSecretSessionServiceFactory

public abstract class SessionServiceFactory
extends java.lang.Object
implements java.io.Serializable

This abstract class serves as a blueprint for creating `SessionService` objects. It introduces a queue property and mandates the implementation of a create() method in concrete subclasses.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SessionServiceFactory()

Method Summary

Modifier and Type	Method and Description
abstract SessionService	create() This is the core method that subclasses must implement.
void	setQueue(com.solacesystems.jcsmp.Queue queue) This method is called in the SolaceIO.Read.expand(org.apache.beam.sdk.values.PBegin) method to set the Queue reference.

Methods inherited from class java.lang.Object

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

Constructor Detail

SessionServiceFactory

public SessionServiceFactory()

Method Detail

create

public abstract SessionService create()

This is the core method that subclasses must implement. It defines how to construct and return a SessionService object.

setQueue

public void setQueue(com.solacesystems.jcsmp.Queue queue)

This method is called in the SolaceIO.Read.expand(org.apache.beam.sdk.values.PBegin) method to set the Queue reference.