File tree 7 files changed +9
-10
lines changed
7 files changed +9
-10
lines changed Original file line number Diff line number Diff line change 19
19
20
20
if (NOT MSVC )
21
21
set (CMAKE_C_FLAGS " -std=c99 ${CMAKE_C_FLAGS} " )
22
+ add_compile_options (-Wextra -Wno-unused-parameter)
22
23
endif ()
23
24
24
25
set (SAMPLE_ASYNC_PRODUCER_SOURCES
Original file line number Diff line number Diff line change @@ -73,7 +73,7 @@ class PULSAR_PUBLIC BrokerConsumerStats {
73
73
virtual const std::string getConnectedSince () const ;
74
74
75
75
/* * Returns Whether this subscription is Exclusive or Shared or Failover */
76
- virtual const ConsumerType getType () const ;
76
+ virtual ConsumerType getType () const ;
77
77
78
78
/* * Returns the rate of messages expired on this subscription. msg/s */
79
79
virtual double getMsgRateExpired () const ;
Original file line number Diff line number Diff line change @@ -176,7 +176,7 @@ class PULSAR_PUBLIC Message {
176
176
/* *
177
177
* Get the redelivery count for this message
178
178
*/
179
- const int getRedeliveryCount () const ;
179
+ int getRedeliveryCount () const ;
180
180
181
181
/* *
182
182
* Check if schema version exists
Original file line number Diff line number Diff line change @@ -195,13 +195,13 @@ PULSAR_PUBLIC const char *pulsar_client_configuration_get_listener_name(pulsar_c
195
195
PULSAR_PUBLIC void pulsar_client_configuration_set_partitions_update_interval (
196
196
pulsar_client_configuration_t * conf , const unsigned int intervalInSeconds );
197
197
198
- PULSAR_PUBLIC const unsigned int pulsar_client_configuration_get_partitions_update_interval (
198
+ PULSAR_PUBLIC unsigned int pulsar_client_configuration_get_partitions_update_interval (
199
199
pulsar_client_configuration_t * conf );
200
200
201
201
/*
202
202
* Get the stats interval set in the client.
203
203
*/
204
- PULSAR_PUBLIC const unsigned int pulsar_client_configuration_get_stats_interval_in_seconds (
204
+ PULSAR_PUBLIC unsigned int pulsar_client_configuration_get_stats_interval_in_seconds (
205
205
pulsar_client_configuration_t * conf );
206
206
207
207
PULSAR_PUBLIC void pulsar_client_configuration_set_keep_alive_interval_in_seconds (
Original file line number Diff line number Diff line change @@ -63,7 +63,7 @@ const std::string BrokerConsumerStats::getAddress() const { return impl_->getAdd
63
63
64
64
const std::string BrokerConsumerStats::getConnectedSince () const { return impl_->getConnectedSince (); }
65
65
66
- const ConsumerType BrokerConsumerStats::getType () const { return impl_->getType (); }
66
+ ConsumerType BrokerConsumerStats::getType () const { return impl_->getType (); }
67
67
68
68
double BrokerConsumerStats::getMsgRateExpired () const { return impl_->getMsgRateExpired (); }
69
69
Original file line number Diff line number Diff line change @@ -184,7 +184,7 @@ const std::string& Message::getTopicName() const {
184
184
return impl_->getTopicName ();
185
185
}
186
186
187
- const int Message::getRedeliveryCount () const {
187
+ int Message::getRedeliveryCount () const {
188
188
if (!impl_) {
189
189
return 0 ;
190
190
}
Original file line number Diff line number Diff line change @@ -173,8 +173,7 @@ void pulsar_client_configuration_set_stats_interval_in_seconds(pulsar_client_con
173
173
conf->conf .setStatsIntervalInSeconds (interval);
174
174
}
175
175
176
- const unsigned int pulsar_client_configuration_get_stats_interval_in_seconds (
177
- pulsar_client_configuration_t *conf) {
176
+ unsigned int pulsar_client_configuration_get_stats_interval_in_seconds (pulsar_client_configuration_t *conf) {
178
177
return conf->conf .getStatsIntervalInSeconds ();
179
178
}
180
179
@@ -204,8 +203,7 @@ void pulsar_client_configuration_set_partitions_update_interval(pulsar_client_co
204
203
conf->conf .setPartititionsUpdateInterval (intervalInSeconds);
205
204
}
206
205
207
- const unsigned int pulsar_client_configuration_get_partitions_update_interval (
208
- pulsar_client_configuration_t *conf) {
206
+ unsigned int pulsar_client_configuration_get_partitions_update_interval (pulsar_client_configuration_t *conf) {
209
207
return conf->conf .getPartitionsUpdateInterval ();
210
208
}
211
209
You can’t perform that action at this time.
0 commit comments