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 `SessionServiceFactory` objects. It introduces a queue property and mandates the implementation of a create() method in concrete subclasses.

For basic authentication, use BasicAuthJcsmpSessionServiceFactory.

For other situations, you need to extend this class. Classes extending from this abstract class must implement the `equals` method so two instances can be compared by value, and not by reference. We recommend using AutoValue for that.

 {@literal @}AutoValue
 public abstract class MyFactory implements SessionServiceClientFactory {

   abstract String value1();

   abstract String value2();

   public static MyFactory create(String value1, String value2) {
     return new AutoValue_MyFactory.Builder(value1, value2);
   }

   ...

   {@literal @}Override
   public SessionService create() {
     ...
   }
 }
 

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.
abstract boolean	equals(@Nullable java.lang.Object other) You need to override this method to be able to compare these objects by value.
@Nullable SolaceIO.SubmissionMode	getSubmissionMode()
abstract int	hashCode() You need to override this method to be able to compare these objects by value.
void	setQueue(Queue queue) This method is called in the SolaceIO.Read.expand(org.apache.beam.sdk.values.PBegin) method to set the Queue reference.
void	setSubmissionMode(SolaceIO.SubmissionMode submissionMode) Called by the write connector to set the submission mode used to create the message producers.

Methods inherited from class java.lang.Object

clone, finalize, getClass, 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.

equals

public abstract boolean equals(@Nullable java.lang.Object other)

You need to override this method to be able to compare these objects by value. We recommend using AutoValue for that.

Overrides:

equals in class java.lang.Object

hashCode

public abstract int hashCode()

You need to override this method to be able to compare these objects by value. We recommend using AutoValue for that.

Overrides:

hashCode in class java.lang.Object

setQueue

public void setQueue(Queue queue)

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

setSubmissionMode

public void setSubmissionMode(SolaceIO.SubmissionMode submissionMode)

Called by the write connector to set the submission mode used to create the message producers.

getSubmissionMode

public @Nullable SolaceIO.SubmissionMode getSubmissionMode()