It would also be ideal if someone extended the SqsIO transform to allow
specifying endpoints via a builder method.
On Fri, Sep 25, 2020 at 9:50 AM Luke Cwik wrote:
> You can create a PipelineOptions interface with a unique endpoint
> identifier for each service you want to use like:
> public
You can create a PipelineOptions interface with a unique endpoint
identifier for each service you want to use like:
public interface AwsEndpointOptions extends PipelineOptions {
@Default.InstanceFactory(FallbackToAwsOptions.class);
String getSnsEndpoint();
void setSnsEndpoint();
We're currently working on getting our Beam app working with localstack (and
potentially other AWS regions). We're using SqsIO and S3 as part of our
pipeline (with other AWS components likely to come into the mix). While I
could cast the PipelineOptions to AwsOptions and then call
