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

Class BasicAuthJcsmpSessionServiceFactory

java.lang.Object

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

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

All Implemented Interfaces:

java.io.Serializable

public abstract class BasicAuthJcsmpSessionServiceFactory
extends SessionServiceFactory

A factory for creating JcsmpSessionService instances. Extends SessionServiceFactory.

This factory provides a way to create JcsmpSessionService that use Basic Authentication.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BasicAuthJcsmpSessionServiceFactory.Builder

Constructor Summary

Constructors

Constructor and Description
BasicAuthJcsmpSessionServiceFactory()

Method Summary

Modifier and Type	Method and Description
static BasicAuthJcsmpSessionServiceFactory.Builder	builder()
SessionService	create() This is the core method that subclasses must implement.
abstract java.lang.String	host() The host name or IP address of the Solace broker.
abstract java.lang.String	password() The password to use for authentication.
abstract java.lang.String	username() The username to use for authentication.
abstract java.lang.String	vpnName() The name of the VPN to connect to.

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

equals, getQueue, getSubmissionMode, hashCode, setQueue, setSubmissionMode

Methods inherited from class java.lang.Object

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

Constructor Detail

BasicAuthJcsmpSessionServiceFactory

public BasicAuthJcsmpSessionServiceFactory()

Method Detail

host

public abstract java.lang.String host()

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

username

public abstract java.lang.String username()

The username to use for authentication.

password

public abstract java.lang.String password()

The password to use for authentication.

vpnName

public abstract java.lang.String vpnName()

The name of the VPN to connect to.

builder

public static BasicAuthJcsmpSessionServiceFactory.Builder builder()

create

public SessionService create()

Description copied from class: SessionServiceFactory

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

Specified by:

create in class SessionServiceFactory