Teerapong Singthong iamgoangle

## retry-producer.go
package main

import (
	"encoding/json"
	"fmt"
	"log"

	"github.com/iamgoangle/rabbit-go/internal/rabbitmq"
)

## retry-consumer.go
package main

import (
	"log"
	"math/rand"

	"github.com/streadway/amqp"

	"github.com/iamgoangle/rabbit-go/internal/rabbitmq"
)

## setup-queue.go
package main

import (
	"log"

	"github.com/iamgoangle/rabbit-go/internal/rabbitmq"
	"github.com/streadway/amqp"
)

func main() {

## setup-exchange.go
package main

import (
	"log"

	"github.com/iamgoangle/rabbit-go/internal/rabbitmq"
)

func main() {
	conn, err := rabbitmq.NewConnection(rabbitmq.ConfigConnection{

## topic-consumer.go
package main

import (
	"log"
	"os"

	"github.com/iamgoangle/rabbit-go/internal/rabbitmq"
)

// ROUTING_KEY=asia.thailand.* QUEUE=asia.thailand.all.province go run consumer.go

## topic-producer.go
package main

import (
	"encoding/json"
	"fmt"
	"log"
	"os"
	"time"

	"github.com/iamgoangle/rabbit-go/internal/rabbitmq"

## fanout-consumer.go
package main

import (
	"log"

	"github.com/iamgoangle/rabbit-go/internal/rabbitmq"
)

func main() {
	conn, err := rabbitmq.NewConnection(rabbitmq.ConfigConnection{

## fanout-producer.go
package main

import (
	"encoding/json"
	"fmt"
	"log"
	"time"

	"github.com/iamgoangle/rabbit-go/internal/rabbitmq"
)

## direct-topic-consumer.go
package main

import (
	"log"
	"os"

	"github.com/iamgoangle/rabbit-go/internal/rabbitmq"
)

// ROUTING_KEY=asia.thailand QUEUE=asia.thailand.queue go run consumer.go

## direct-topic-producer.go
package main

import (
	"encoding/json"
	"fmt"
	"log"
	"os"

	"github.com/iamgoangle/rabbit-go/internal/rabbitmq"
)
	package main

	import (
	"encoding/json"
	"fmt"
	"log"

	"github.com/iamgoangle/rabbit-go/internal/rabbitmq"
	)