Skip to content

Commit

Permalink
chore(pipes-sources): update readme to use SqsTarget (#31980)
Browse files Browse the repository at this point in the history
  • Loading branch information
msambol authored Nov 1, 2024
1 parent 73378f2 commit 85fd5f7
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 4 deletions.
8 changes: 4 additions & 4 deletions packages/@aws-cdk/aws-pipes-sources-alpha/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@ const pipeSource = new sources.SqsSource(sourceQueue);

const pipe = new pipes.Pipe(this, 'Pipe', {
source: pipeSource,
target: new SomeTarget(targetQueue)
target: new SqsTarget(targetQueue)
});
```

Expand All @@ -57,7 +57,7 @@ const pipeSource = new sources.SqsSource(sourceQueue, {

const pipe = new pipes.Pipe(this, 'Pipe', {
source: pipeSource,
target: new SomeTarget(targetQueue)
target: new SqsTarget(targetQueue)
});
```

Expand All @@ -75,7 +75,7 @@ const pipeSource = new sources.KinesisSource(sourceStream, {

const pipe = new pipes.Pipe(this, 'Pipe', {
source: pipeSource,
target: new SomeTarget(targetQueue)
target: new SqsTarget(targetQueue)
});
```

Expand All @@ -99,6 +99,6 @@ const pipeSource = new sources.DynamoDBSource(table, {

const pipe = new pipes.Pipe(this, 'Pipe', {
source: pipeSource,
target: new SomeTarget(targetQueue)
target: new SqsTarget(targetQueue)
});
```
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@ import * as ddb from 'aws-cdk-lib/aws-dynamodb';
import { Construct } from 'constructs';
import * as pipes from '@aws-cdk/aws-pipes-alpha';
import * as sources from '@aws-cdk/aws-pipes-sources-alpha';
import { SqsTarget } from '@aws-cdk/aws-pipes-targets-alpha';

class SomeTarget implements pipes.ITarget {
targetArn: string;
Expand Down

0 comments on commit 85fd5f7

Please sign in to comment.