File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -2623,7 +2623,7 @@ func TestProducerKeepReconnectingAndThenCallSendAsync(t *testing.T) {
26232623
26242624 testProducer .SendAsync (context .Background (), & ProducerMessage {
26252625 Payload : []byte ("test" ),
2626- }, func (messageID MessageID , message * ProducerMessage , err error ) {
2626+ }, func (_ MessageID , _ * ProducerMessage , err error ) {
26272627 errChan <- err
26282628 })
26292629 // should success
@@ -2637,7 +2637,7 @@ func TestProducerKeepReconnectingAndThenCallSendAsync(t *testing.T) {
26372637 // send again
26382638 testProducer .SendAsync (context .Background (), & ProducerMessage {
26392639 Payload : []byte ("test" ),
2640- }, func (messageID MessageID , message * ProducerMessage , err error ) {
2640+ }, func (_ MessageID , _ * ProducerMessage , err error ) {
26412641 errChan <- err
26422642 })
26432643 // should get a timeout error
@@ -2667,7 +2667,7 @@ func TestProducerKeepReconnectingAndThenCallSendAsync(t *testing.T) {
26672667 // send again
26682668 testProducer .SendAsync (context .Background (), & ProducerMessage {
26692669 Payload : []byte ("test" ),
2670- }, func (messageID MessageID , message * ProducerMessage , err error ) {
2670+ }, func (_ MessageID , _ * ProducerMessage , err error ) {
26712671 errChan <- err
26722672 })
26732673 // should success
You can’t perform that action at this time.
0 commit comments