Terraform

    1. resource "jetstream_stream" "ORDERS" {
    2. name = "ORDERS"
    3. subjects = ["ORDERS.*"]
    4. storage = "file"
    5. max_age = 60 * 60 * 24 * 365
    6. }
    7. resource "jetstream_consumer" "ORDERS_NEW" {
    8. stream_id = jetstream_stream.ORDERS.id
    9. durable_name = "NEW"
    10. filter_subject = "ORDERS.received"
    11. sample_freq = 100
    12. }
    13. resource "jetstream_consumer" "ORDERS_DISPATCH" {
    14. stream_id = jetstream_stream.ORDERS.id
    15. durable_name = "DISPATCH"
    16. deliver_all = true
    17. filter_subject = "ORDERS.processed"
    18. sample_freq = 100
    19. resource "jetstream_consumer" "ORDERS_MONITOR" {
    20. stream_id = jetstream_stream.ORDERS.id
    21. durable_name = "MONITOR"
    22. deliver_last = true
    23. ack_policy = "none"
    24. delivery_subject = "monitor.ORDERS"
    25. }
    26. output "ORDERS_SUBJECTS" {
    27. }