Commit f1b0ee2

committed

📦 new(proposal:transport) a way to abstruct away the rabbitmq

Solve issue #158 Disconnects rabbitmq and allows addition of kafka or any other transport

1 parent 60007d8 commit f1b0ee2Copy full SHA for f1b0ee2

File tree

+19

-1

lines changed

+19

-1

lines changed

Lines changed: 19 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -6,7 +6,6 @@ import (`
`6`	`6`	`"time"`
`7`	`7`
`8`	`8`	`"github.com/sirupsen/logrus"`
`9`		`-`
`10`	`9`	`"github.com/streadway/amqp"`
`11`	`10`	`)`
`12`	`11`
`@@ -284,3 +283,22 @@ type Logged interface {`
`284`	`283`	`SetLogger(entry logrus.FieldLogger)`
`285`	`284`	`Log() logrus.FieldLogger`
`286`	`285`	`}`
	`286`	`+`
	`287`	`+type Transport interface {`
	`288`	`+ Messaging`
	`289`	`+ Logged`
	`290`	`+ Health`
	`291`	`+`
	`292`	`+ Start() error`
	`293`	`+ Stop() error`
	`294`	`+`
	`295`	`+ RPCChannel() <-chan BusMessage`
	`296`	`+ MessageChannel() <-chan BusMessage`
	`297`	`+`
	`298`	`+ ErrorChan() <-chan error`
	`299`	`+ BackPressureChannel() <-chan bool`
	`300`	`+`
	`301`	`+ ListenOnEvent(exchange, topic string) error`
	`302`	`+}`
	`303`	`+`
	`304`	`+type NewTransport func(svcName, connString, DLX string, prefetchCount, maxRetryCount uint, purgeOnStartup, withConfirms bool, logger logrus.FieldLogger) Transport`

Comments

(0)