Fixed eventhubs build break (#4798)
* Fixed eventhubs build break * Morebuild breaks
This commit is contained in:
Родитель
fd073360cf
Коммит
d1544744bf
|
@ -46,7 +46,7 @@ namespace Azure { namespace Messaging { namespace EventHubs { namespace Test {
|
|||
|
||||
checkpoints = checkpointStore.ListCheckpoints(
|
||||
"ns.servicebus.windows.net", "event-hub-name", "$Default");
|
||||
EXPECT_EQ(checkpoints.size(), 1);
|
||||
EXPECT_EQ(checkpoints.size(), 1ul);
|
||||
EXPECT_EQ("$Default", checkpoints[0].ConsumerGroup);
|
||||
EXPECT_EQ("event-hub-name", checkpoints[0].EventHubName);
|
||||
EXPECT_EQ("ns.servicebus.windows.net", checkpoints[0].EventHubHostName);
|
||||
|
@ -65,7 +65,7 @@ namespace Azure { namespace Messaging { namespace EventHubs { namespace Test {
|
|||
|
||||
checkpoints = checkpointStore.ListCheckpoints(
|
||||
"ns.servicebus.windows.net", "event-hub-name", "$Default");
|
||||
EXPECT_EQ(checkpoints.size(), 1);
|
||||
EXPECT_EQ(checkpoints.size(), 1ul);
|
||||
EXPECT_EQ("$Default", checkpoints[0].ConsumerGroup);
|
||||
EXPECT_EQ("event-hub-name", checkpoints[0].EventHubName);
|
||||
EXPECT_EQ("ns.servicebus.windows.net", checkpoints[0].EventHubHostName);
|
||||
|
|
|
@ -93,7 +93,7 @@ TEST_F(EventDataTest, EventDataBodyTest)
|
|||
auto message
|
||||
= Azure::Messaging::EventHubs::_detail::EventDataFactory::EventDataToAmqpMessage(msg);
|
||||
|
||||
EXPECT_EQ(message.GetBodyAsBinary().size(), 1);
|
||||
EXPECT_EQ(message.GetBodyAsBinary().size(), 1ul);
|
||||
EXPECT_EQ(msg.Body.Data, message.GetBodyAsBinary()[0]);
|
||||
}
|
||||
|
||||
|
@ -105,7 +105,7 @@ TEST_F(EventDataTest, EventDataBodyTest)
|
|||
|
||||
auto message
|
||||
= Azure::Messaging::EventHubs::_detail::EventDataFactory::EventDataToAmqpMessage(msg);
|
||||
EXPECT_EQ(message.GetBodyAsAmqpList().size(), 1);
|
||||
EXPECT_EQ(message.GetBodyAsAmqpList().size(), 1ul);
|
||||
EXPECT_EQ(msg.Body.Sequence, message.GetBodyAsAmqpList()[0]);
|
||||
}
|
||||
|
||||
|
|
|
@ -55,7 +55,7 @@ namespace Azure { namespace Messaging { namespace EventHubs { namespace Test {
|
|||
void RequireBalanced(
|
||||
std::vector<Models::Ownership> ownerships,
|
||||
size_t totalPartitions,
|
||||
int numConsumers)
|
||||
size_t numConsumers)
|
||||
{
|
||||
size_t min = totalPartitions / numConsumers;
|
||||
size_t max = min;
|
||||
|
|
Загрузка…
Ссылка в новой задаче