Minor clean up

Author: marselester

LICENSE

@@ -1,6 +1,6 @@
 MIT License
 
-Copyright (c) 2022 Marsel Mavletkulov
+Copyright (c) 2025 Marsel Mavletkulov
 
 Permission is hereby granted, free of charge, to any person obtaining a copy
 of this software and associated documentation files (the "Software"), to deal

README.md

@@ -109,8 +109,6 @@ $ go run ./consumer/
 received a=fizz b=bazz
 ```
 
-To send a task with Celery Protocol version 1, run *producer_v1.py* instead of *producer.py*.
-
 </details>
 
 <details>
@@ -179,7 +177,6 @@ $ go run ./retry/
 
 </details>
 
-
 ### RabbitMQ Examples
 
 RabbitMQ examples can be found in [the rabbitmq examples](examples/rabbitmq) dir.
@@ -217,11 +214,8 @@ $ go run ./consumer/
 received a=fizz b=bazz
 ```
 
-To send a task with Celery Protocol version 1, run *producer_v1.py* instead of *producer.py*.
-
 </details>
 
-
 ## Testing
 
 Tests require both a Redis and a RabbitMQ server running locally.

examples/producer.py

@@ -53,14 +53,6 @@ func WithReceiveTimeout(timeout time.Duration) BrokerOption {
 	}
 }
 
-// WithRawMode sets rawMode, which, if true, disables marshaling of data structures between internal and RabbitMQ Celery formats.
-// Note that rawMode defaults to false, and should only be set to true inside the broker unit tests.
-func WithRawMode(rawMode bool) BrokerOption {
-	return func(br *Broker) {
-		br.rawMode = rawMode
-	}
-}
-
 // WithClient sets RabbitMQ client representing a connection to RabbitMQ.
 func WithClient(c *amqp.Connection) BrokerOption {
 	return func(br *Broker) {

rabbitmq/broker.go

@@ -8,7 +8,6 @@ import (
 )
 
 func TestReceive(t *testing.T) {
-
 	q := "rabbitmqq"
 
 	tests := map[string]struct {
@@ -35,7 +34,8 @@ func TestReceive(t *testing.T) {
 
 	for name, tc := range tests {
 		t.Run(name, func(t *testing.T) {
-			br := NewBroker(WithReceiveTimeout(time.Second), WithRawMode(true))
+			br := NewBroker(WithReceiveTimeout(time.Second))
+			br.rawMode = true
 			br.Observe([]string{q})
 
 			t.Cleanup(func() {