Skip to content

Commit 85fd5f7

Browse files
authored
chore(pipes-sources): update readme to use SqsTarget (#31980)
1 parent 73378f2 commit 85fd5f7

File tree

2 files changed

+5
-4
lines changed

2 files changed

+5
-4
lines changed

packages/@aws-cdk/aws-pipes-sources-alpha/README.md

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ const pipeSource = new sources.SqsSource(sourceQueue);
4040

4141
const pipe = new pipes.Pipe(this, 'Pipe', {
4242
source: pipeSource,
43-
target: new SomeTarget(targetQueue)
43+
target: new SqsTarget(targetQueue)
4444
});
4545
```
4646

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

5858
const pipe = new pipes.Pipe(this, 'Pipe', {
5959
source: pipeSource,
60-
target: new SomeTarget(targetQueue)
60+
target: new SqsTarget(targetQueue)
6161
});
6262
```
6363

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

7676
const pipe = new pipes.Pipe(this, 'Pipe', {
7777
source: pipeSource,
78-
target: new SomeTarget(targetQueue)
78+
target: new SqsTarget(targetQueue)
7979
});
8080
```
8181

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

100100
const pipe = new pipes.Pipe(this, 'Pipe', {
101101
source: pipeSource,
102-
target: new SomeTarget(targetQueue)
102+
target: new SqsTarget(targetQueue)
103103
});
104104
```

packages/@aws-cdk/aws-pipes-sources-alpha/rosetta/default.ts-fixture

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@ import * as ddb from 'aws-cdk-lib/aws-dynamodb';
66
import { Construct } from 'constructs';
77
import * as pipes from '@aws-cdk/aws-pipes-alpha';
88
import * as sources from '@aws-cdk/aws-pipes-sources-alpha';
9+
import { SqsTarget } from '@aws-cdk/aws-pipes-targets-alpha';
910

1011
class SomeTarget implements pipes.ITarget {
1112
targetArn: string;

0 commit comments

Comments
 (0)