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

Class SempBasicAuthClientExecutor

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable

public class SempBasicAuthClientExecutor
extends java.lang.Object
implements java.io.Serializable

A class to execute requests to SEMP v2 with Basic Auth authentication.

This approach takes advantage of SEMP Sessions. The session is established when a user authenticates with HTTP Basic authentication. When the response is 401 Unauthorized, the client will execute an additional request with Basic Auth header to refresh the token.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SempBasicAuthClientExecutor(java.lang.String host, java.lang.String username, java.lang.String password, java.lang.String vpnName, com.google.api.client.http.HttpRequestFactory httpRequestFactory)

Method Summary

Modifier and Type	Method and Description
long	getBacklogBytes(java.lang.String queueName)
boolean	isQueueNonExclusive(java.lang.String queueName)

Methods inherited from class java.lang.Object

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

Constructor Detail

SempBasicAuthClientExecutor

public SempBasicAuthClientExecutor(java.lang.String host,
                                   java.lang.String username,
                                   java.lang.String password,
                                   java.lang.String vpnName,
                                   com.google.api.client.http.HttpRequestFactory httpRequestFactory)

Method Detail

isQueueNonExclusive

public boolean isQueueNonExclusive(java.lang.String queueName)
                            throws java.io.IOException

Throws:

java.io.IOException

getBacklogBytes

public long getBacklogBytes(java.lang.String queueName)
                     throws java.io.IOException

Throws:

java.io.IOException