Skip to content

Commit

Permalink
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
go fmt
Browse files Browse the repository at this point in the history
180909 committed Aug 7, 2021
1 parent e4a000b commit 98eaad3
Showing 4 changed files with 26 additions and 30 deletions.
1 change: 0 additions & 1 deletion consumer/consumer.go
Original file line number Diff line number Diff line change
@@ -68,7 +68,6 @@ const (
_SubAll = "*"
)


// Message model defines the way how messages are delivered to each consumer clients.
// </p>
//
52 changes: 26 additions & 26 deletions errors/errors.go
Original file line number Diff line number Diff line change
@@ -20,31 +20,31 @@ package errors
import "errors"

var (
ErrRequestTimeout = errors.New("equest timeout")
ErrMQEmpty = errors.New("MessageQueue is nil")
ErrOffset = errors.New("offset < 0")
ErrNumbers = errors.New("numbers < 0")
ErrEmptyTopic = errors.New("empty topic")
ErrEmptyNameSrv = errors.New("empty namesrv")
ErrEmptyGroupID = errors.New("empty group id")
ErrTestMin = errors.New("test minutes must be positive integer")
ErrRequestTimeout = errors.New("equest timeout")
ErrMQEmpty = errors.New("MessageQueue is nil")
ErrOffset = errors.New("offset < 0")
ErrNumbers = errors.New("numbers < 0")
ErrEmptyTopic = errors.New("empty topic")
ErrEmptyNameSrv = errors.New("empty namesrv")
ErrEmptyGroupID = errors.New("empty group id")
ErrTestMin = errors.New("test minutes must be positive integer")
ErrOperationInterval = errors.New("operation interval must be positive integer")
ErrMessageBody = errors.New("message body size must be positive integer")
ErrEmptyExpression = errors.New("empty expression")
ErrCreated = errors.New("consumer group has been created")
ErrBrokerNotFound = errors.New("broker can not found")
ErrStartTopic = errors.New("cannot subscribe topic since client either failed to start or has been shutdown.")
ErrResponse = errors.New("response error")
ErrCompressLevel = errors.New("unsupported compress level")
ErrUnknownIP = errors.New("unknown IP address")
ErrService = errors.New("service close is not running, please check")
ErrTopicNotExist = errors.New("topic not exist")
ErrNotExisted = errors.New("not existed")
ErrNoNameserver = errors.New("nameServerAddrs can't be empty.")
ErrMultiIP = errors.New("multiple IP addr does not support")
ErrIllegalIP = errors.New("IP addr error")
ErrTopicEmpty = errors.New("topic is nil")
ErrMessageEmpty = errors.New("message is nil")
ErrNotRunning = errors.New("producer not started")
ErrPullConsumer = errors.New("pull consumer has not supported")
ErrMessageBody = errors.New("message body size must be positive integer")
ErrEmptyExpression = errors.New("empty expression")
ErrCreated = errors.New("consumer group has been created")
ErrBrokerNotFound = errors.New("broker can not found")
ErrStartTopic = errors.New("cannot subscribe topic since client either failed to start or has been shutdown.")
ErrResponse = errors.New("response error")
ErrCompressLevel = errors.New("unsupported compress level")
ErrUnknownIP = errors.New("unknown IP address")
ErrService = errors.New("service close is not running, please check")
ErrTopicNotExist = errors.New("topic not exist")
ErrNotExisted = errors.New("not existed")
ErrNoNameserver = errors.New("nameServerAddrs can't be empty.")
ErrMultiIP = errors.New("multiple IP addr does not support")
ErrIllegalIP = errors.New("IP addr error")
ErrTopicEmpty = errors.New("topic is nil")
ErrMessageEmpty = errors.New("message is nil")
ErrNotRunning = errors.New("producer not started")
ErrPullConsumer = errors.New("pull consumer has not supported")
)
2 changes: 0 additions & 2 deletions internal/utils/errors.go
Original file line number Diff line number Diff line change
@@ -21,8 +21,6 @@ import (
"github.com/apache/rocketmq-client-go/v2/rlog"
)



func CheckError(action string, err error) {
if err != nil {
rlog.Error(action, map[string]interface{}{
1 change: 0 additions & 1 deletion producer/producer.go
Original file line number Diff line number Diff line change
@@ -36,7 +36,6 @@ import (
"github.com/apache/rocketmq-client-go/v2/rlog"
)


type defaultProducer struct {
group string
client internal.RMQClient

0 comments on commit 98eaad3

Please sign in to comment.