reduce message send and increase batch clear size
This commit is contained in:
Родитель
5b8a910be7
Коммит
652d45f659
|
@ -48,7 +48,7 @@ func TestMessageBatch_Clear(t *testing.T) {
|
|||
ok, err := mb.Add(NewMessageFromString("foo"))
|
||||
assert.True(t, ok)
|
||||
assert.NoError(t, err)
|
||||
assert.Equal(t, 148, mb.Size())
|
||||
assert.Equal(t, 175, mb.Size())
|
||||
|
||||
mb.Clear()
|
||||
assert.Equal(t, 100, mb.Size())
|
||||
|
|
|
@ -671,7 +671,7 @@ func testQueueSendAndReceive(ctx context.Context, t *testing.T, q *Queue) {
|
|||
func (suite *serviceBusSuite) TestIssue73QueueClient() {
|
||||
tests := map[string]func(context.Context, *testing.T, *Queue){
|
||||
"SimpleSend200_NoZeroCheck": func(ctx context.Context, t *testing.T, queue *Queue) {
|
||||
for i := 0; i < 200; i++ {
|
||||
for i := 0; i < 50; i++ {
|
||||
testQueueSend(ctx, t, queue)
|
||||
}
|
||||
assertMessageCount(ctx, t, queue.namespace, queue.Name, 200)
|
||||
|
|
Загрузка…
Ссылка в новой задаче