Skip to content

Commit

Permalink
Change pkg name
Browse files Browse the repository at this point in the history
  • Loading branch information
@d1slike
d1slike committed Apr 1, 2024
1 parent 0ba0db9 commit 1dfc42d
Show file tree
Hide file tree
Showing 19 changed files with 41 additions and 41 deletions.
2 changes: 1 addition & 1 deletion .github/workflows/main.yml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ on: [push, pull_request]
jobs:
build:
runs-on: ubuntu-latest
container: golang:1.21
container: golang:1.22
services:
rmq:
image: rabbitmq:3.12-management-alpine
Expand Down
2 changes: 1 addition & 1 deletion LICENSE
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
MIT License

Copyright (c) 2021 integration-system
Copyright (c) 2021 txix-open

Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"), to deal
Expand Down
6 changes: 3 additions & 3 deletions README.md
View file
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
# GRMQ
## Go Rabbit MQ
![Build and test](https://github.com/integration-system/grmq/actions/workflows/main.yml/badge.svg)
[![codecov](https://codecov.io/gh/integration-system/grmq/branch/main/graph/badge.svg?token=JMTTJ5O6WB)](https://codecov.io/gh/integration-system/grmq)
[![Go Report Card](https://goreportcard.com/badge/github.com/integration-system/grmq)](https://goreportcard.com/report/github.com/integration-system/grmq)
![Build and test](https://github.com/txix-open/grmq/actions/workflows/main.yml/badge.svg)
[![codecov](https://codecov.io/gh/txix-open/grmq/branch/main/graph/badge.svg?token=JMTTJ5O6WB)](https://codecov.io/gh/txix-open/grmq)
[![Go Report Card](https://goreportcard.com/badge/github.com/txix-open/grmq)](https://goreportcard.com/report/github.com/txix-open/grmq)

What are the typical use-cases for RabbitMQ broker ?
* We create a durable topology (exchanges, queues, bindings).
Expand Down
6 changes: 3 additions & 3 deletions client.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -6,11 +6,11 @@ import (
"sync/atomic"
"time"

"github.com/integration-system/grmq/consumer"
"github.com/integration-system/grmq/publisher"
"github.com/integration-system/grmq/topology"
"github.com/pkg/errors"
amqp "github.com/rabbitmq/amqp091-go"
"github.com/txix-open/grmq/consumer"
"github.com/txix-open/grmq/publisher"
"github.com/txix-open/grmq/topology"
)

type closer interface {
Expand Down
6 changes: 3 additions & 3 deletions client_options.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -3,9 +3,9 @@ package grmq
import (
"time"

"github.com/integration-system/grmq/consumer"
"github.com/integration-system/grmq/publisher"
"github.com/integration-system/grmq/topology"
"github.com/txix-open/grmq/consumer"
"github.com/txix-open/grmq/publisher"
"github.com/txix-open/grmq/topology"
)

type ClientOption func(c *Client)
Expand Down
10 changes: 5 additions & 5 deletions client_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -7,13 +7,13 @@ import (
"testing"
"time"

"github.com/integration-system/grmq"
"github.com/integration-system/grmq/consumer"
"github.com/integration-system/grmq/publisher"
"github.com/integration-system/grmq/retry"
"github.com/integration-system/grmq/topology"
"github.com/rabbitmq/amqp091-go"
"github.com/stretchr/testify/require"
"github.com/txix-open/grmq"
"github.com/txix-open/grmq/consumer"
"github.com/txix-open/grmq/publisher"
"github.com/txix-open/grmq/retry"
"github.com/txix-open/grmq/topology"
)

func TestClient(t *testing.T) {
Expand Down
4 changes: 2 additions & 2 deletions consumer.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -4,10 +4,10 @@ import (
"context"
"sync"

"github.com/integration-system/grmq/consumer"
"github.com/integration-system/grmq/retry"
"github.com/pkg/errors"
amqp "github.com/rabbitmq/amqp091-go"
"github.com/txix-open/grmq/consumer"
"github.com/txix-open/grmq/retry"
)

type Consumer struct {
Expand Down
2 changes: 1 addition & 1 deletion consumer/consumer.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import (
"fmt"
"os"

"github.com/integration-system/grmq/retry"
"github.com/txix-open/grmq/retry"
)

type Closer interface {
Expand Down
2 changes: 1 addition & 1 deletion consumer/consumer_options.go
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package consumer

import (
"github.com/integration-system/grmq/retry"
"github.com/txix-open/grmq/retry"
)

type Option func(c *Consumer)
Expand Down
2 changes: 1 addition & 1 deletion consumer/delivery.go
View file
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
package consumer

import (
"github.com/integration-system/grmq/retry"
"github.com/pkg/errors"
amqp "github.com/rabbitmq/amqp091-go"
"github.com/txix-open/grmq/retry"
)

var (
Expand Down
6 changes: 3 additions & 3 deletions consumer_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -6,10 +6,10 @@ import (
"testing"
"time"

"github.com/integration-system/grmq"
"github.com/integration-system/grmq/consumer"
"github.com/integration-system/grmq/publisher"
"github.com/stretchr/testify/require"
"github.com/txix-open/grmq"
"github.com/txix-open/grmq/consumer"
"github.com/txix-open/grmq/publisher"
)

func TestConsumer_Run(t *testing.T) {
Expand Down
2 changes: 1 addition & 1 deletion declarator.go
View file
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
package grmq

import (
"github.com/integration-system/grmq/topology"
"github.com/pkg/errors"
amqp "github.com/rabbitmq/amqp091-go"
"github.com/txix-open/grmq/topology"
)

type Declarator struct {
Expand Down
10 changes: 5 additions & 5 deletions example/main.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -7,12 +7,12 @@ import (
"os"
"time"

"github.com/integration-system/grmq"
"github.com/integration-system/grmq/consumer"
"github.com/integration-system/grmq/publisher"
"github.com/integration-system/grmq/retry"
"github.com/integration-system/grmq/topology"
"github.com/rabbitmq/amqp091-go"
"github.com/txix-open/grmq"
"github.com/txix-open/grmq/consumer"
"github.com/txix-open/grmq/publisher"
"github.com/txix-open/grmq/retry"
"github.com/txix-open/grmq/topology"
)

type LogObserver struct {
Expand Down
6 changes: 3 additions & 3 deletions go.mod
View file
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@
module github.com/integration-system/grmq
module github.com/txix-open/grmq

go 1.21
go 1.22

require (
github.com/pkg/errors v0.9.1
github.com/rabbitmq/amqp091-go v1.9.0
github.com/stretchr/testify v1.8.4
github.com/stretchr/testify v1.9.0
)

require (
Expand Down
4 changes: 2 additions & 2 deletions go.sum
View file
Original file line number Diff line number Diff line change
Expand Up @@ -16,8 +16,8 @@ github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+
github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=
github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU=
github.com/stretchr/testify v1.8.4 h1:CcVxjf3Q8PM0mHUKJCdn+eZZtm5yQwehR5yeSVQQcUk=
github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo=
github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg=
github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
go.uber.org/goleak v1.2.1 h1:NBol2c7O1ZokfZ0LEU9K6Whx/KnwvepVetCUhtKja4A=
go.uber.org/goleak v1.2.1/go.mod h1:qlT2yGI9QafXHhZZLxlSuNsMw3FFLxBr+tBRlmO1xH4=
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
Expand Down
4 changes: 2 additions & 2 deletions observer.go
View file
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
package grmq

import (
"github.com/integration-system/grmq/consumer"
"github.com/integration-system/grmq/publisher"
"github.com/txix-open/grmq/consumer"
"github.com/txix-open/grmq/publisher"
)

type Observer interface {
Expand Down
2 changes: 1 addition & 1 deletion publisher.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -4,9 +4,9 @@ import (
"context"
"sync"

publisher2 "github.com/integration-system/grmq/publisher"
"github.com/pkg/errors"
amqp "github.com/rabbitmq/amqp091-go"
publisher2 "github.com/txix-open/grmq/publisher"
)

type Publisher struct {
Expand Down
4 changes: 2 additions & 2 deletions publisher_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -5,10 +5,10 @@ import (
"testing"
"time"

"github.com/integration-system/grmq"
"github.com/integration-system/grmq/publisher"
"github.com/rabbitmq/amqp091-go"
"github.com/stretchr/testify/require"
"github.com/txix-open/grmq"
"github.com/txix-open/grmq/publisher"
)

func TestPublisher_Publish(t *testing.T) {
Expand Down
2 changes: 1 addition & 1 deletion topology/queue.go
View file
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
package topology

import (
"github.com/integration-system/grmq/retry"
amqp "github.com/rabbitmq/amqp091-go"
"github.com/txix-open/grmq/retry"
)

type QueueOption func(q *Queue)
Expand Down

0 comments on commit 1dfc42d

Please sign in to comment.