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

Class SempBasicAuthClientExecutor

java.lang.Object

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

All Implemented Interfaces:

Serializable

public class SempBasicAuthClientExecutor
extends Object
implements 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	Description
SempBasicAuthClientExecutor(String host, String username, String password, String vpnName, com.google.api.client.http.HttpRequestFactory httpRequestFactory)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

SempBasicAuthClientExecutor

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

Method Details

isQueueNonExclusive

public boolean isQueueNonExclusive(String queueName)
                            throws IOException

Throws:

IOException

getBacklogBytes

public long getBacklogBytes(String queueName)
                     throws IOException

Throws:

IOException