fix attach existing queue to stack

fogfish · Sep 29, 2024 · 8e9411b · 8e9411b
1 parent 4d25de2
commit 8e9411b
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 5 deletions.
diff --git a/broker/eventsqs/awscdk.go b/broker/eventsqs/awscdk.go
@@ -90,10 +90,10 @@ func (broker *Broker) NewQueue(props *awssqs.QueueProps) awssqs.IQueue {
 	return broker.Queue
 }
 
-func (broker *Broker) AddQueue(queueName string) awssqs.IQueue {
+func (broker *Broker) AddQueue(queueArn *string) awssqs.IQueue {
 	broker.Queue = awssqs.Queue_FromQueueAttributes(broker.Construct, jsii.String("Bus"),
 		&awssqs.QueueAttributes{
-			QueueName: jsii.String(queueName),
+			QueueArn: queueArn,
 		},
 	)
 

diff --git a/broker/eventsqs/examples/serverless/main.go b/broker/eventsqs/examples/serverless/main.go
@@ -29,13 +29,22 @@ func main() {
 	)
 
 	broker := eventsqs.NewBroker(stack, jsii.String("Broker"), nil)
-	broker.NewQueue(nil)
+	broker.AddQueue(
+		stack.FormatArn(
+			&awscdk.ArnComponents{
+				Service:  jsii.String("sqs"),
+				Account:  awscdk.Aws_ACCOUNT_ID(),
+				Region:   awscdk.Aws_REGION(),
+				Resource: jsii.String("swarm-test"),
+			},
+		),
+	)
 
 	broker.NewSink(
 		&eventsqs.SinkProps{
 			Function: &scud.FunctionGoProps{
-				SourceCodeModule: "github.com/fogfish/swarm",
-				SourceCodeLambda: "examples/eventsqs/dequeue",
+				SourceCodeModule: "github.com/fogfish/swarm/broker/eventsqs",
+				SourceCodeLambda: "examples/dequeue/typed",
 			},
 		},
 	)