docs: update direct exchange example

Author: appleboy

_example/producer-consumer/consumer/main.go

@@ -32,8 +32,9 @@ func main() {
 
 	// define the worker
 	w := rabbitmq.NewWorker(
-		rabbitmq.WithSubj("sample_2"),
-		rabbitmq.WithExchangeType("fanout"),
+		rabbitmq.WithSubj("direct_queue"),
+		rabbitmq.WithExchangeType(rabbitmq.ExchangeDirect),
+		rabbitmq.WithExchangeName("direct_queue"),
 		rabbitmq.WithRunFunc(func(ctx context.Context, m core.QueuedMessage) error {
 			var v *job
 			if err := json.Unmarshal(m.Bytes(), &v); err != nil {

_example/producer-consumer/producer/main.go

@@ -27,8 +27,9 @@ func main() {
 
 	// define the worker
 	w := rabbitmq.NewWorker(
-		rabbitmq.WithSubj("sample_2"),
-		rabbitmq.WithExchangeType("fanout"),
+		rabbitmq.WithSubj("direct_queue"),
+		rabbitmq.WithExchangeType(rabbitmq.ExchangeDirect),
+		rabbitmq.WithExchangeName("direct_queue"),
 	)
 
 	// define the queue