|
@@ -124,6 +124,12 @@ func (b *MockBroker) serverError(err error, conn net.Conn) bool {
|
|
|
|
|
|
|
|
|
func NewMockBroker(t TestState, brokerID int32) *MockBroker {
|
|
|
+ return NewMockBrokerAddr(t, brokerID, "localhost:0")
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+func NewMockBrokerAddr(t TestState, brokerID int32, addr string) *MockBroker {
|
|
|
var err error
|
|
|
|
|
|
broker := &MockBroker{
|
|
@@ -133,7 +139,7 @@ func NewMockBroker(t TestState, brokerID int32) *MockBroker {
|
|
|
expectations: make(chan encoder, 512),
|
|
|
}
|
|
|
|
|
|
- broker.listener, err = net.Listen("tcp", "localhost:0")
|
|
|
+ broker.listener, err = net.Listen("tcp", addr)
|
|
|
if err != nil {
|
|
|
t.Fatal(err)
|
|
|
}
|