This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 7dd64d0 Regenerated the PulsarApi from proto with latest protoc
(#1227)
7dd64d0 is described below
commit 7dd64d072060c7ccadcc9ff747ace3658be1584f
Author: Matteo Merli <mme...@apache.org>
AuthorDate: Mon Feb 12 20:31:01 2018 -0800
Regenerated the PulsarApi from proto with latest protoc (#1227)
---
.../apache/pulsar/common/api/proto/PulsarApi.java | 680 +++++++++++----------
1 file changed, 374 insertions(+), 306 deletions(-)
diff --git
a/pulsar-common/src/main/java/org/apache/pulsar/common/api/proto/PulsarApi.java
b/pulsar-common/src/main/java/org/apache/pulsar/common/api/proto/PulsarApi.java
index 6bbe77e..2c13125 100644
---
a/pulsar-common/src/main/java/org/apache/pulsar/common/api/proto/PulsarApi.java
+++
b/pulsar-common/src/main/java/org/apache/pulsar/common/api/proto/PulsarApi.java
@@ -279,13 +279,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements MessageIdDataOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use MessageIdData.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private MessageIdData(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<MessageIdData> handle;
+ private MessageIdData(io.netty.util.Recycler.Handle<MessageIdData> handle)
{
this.handle = handle;
}
private static final io.netty.util.Recycler<MessageIdData> RECYCLER = new
io.netty.util.Recycler<MessageIdData>() {
- protected MessageIdData newObject(Handle handle) {
+ protected MessageIdData newObject(Handle<MessageIdData> handle) {
return new MessageIdData(handle);
}
};
@@ -295,10 +295,12 @@ public final class PulsarApi {
this.memoizedIsInitialized = -1;
this.bitField0_ = 0;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private MessageIdData(boolean noInit) {}
+ private MessageIdData(boolean noInit) {
+ this.handle = null;
+ }
private static final MessageIdData defaultInstance;
public static MessageIdData getDefaultInstance() {
@@ -506,20 +508,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.MessageIdData, Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.MessageIdDataOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.MessageIdData.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -778,13 +780,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements KeyValueOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use KeyValue.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private KeyValue(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<KeyValue> handle;
+ private KeyValue(io.netty.util.Recycler.Handle<KeyValue> handle) {
this.handle = handle;
}
private static final io.netty.util.Recycler<KeyValue> RECYCLER = new
io.netty.util.Recycler<KeyValue>() {
- protected KeyValue newObject(Handle handle) {
+ protected KeyValue newObject(Handle<KeyValue> handle) {
return new KeyValue(handle);
}
};
@@ -794,10 +796,12 @@ public final class PulsarApi {
this.memoizedIsInitialized = -1;
this.bitField0_ = 0;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private KeyValue(boolean noInit) {}
+ private KeyValue(boolean noInit) {
+ this.handle = null;
+ }
private static final KeyValue defaultInstance;
public static KeyValue getDefaultInstance() {
@@ -1013,20 +1017,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.KeyValue, Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.KeyValueOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.KeyValue.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -1245,13 +1249,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements KeyLongValueOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use KeyLongValue.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private KeyLongValue(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<KeyLongValue> handle;
+ private KeyLongValue(io.netty.util.Recycler.Handle<KeyLongValue> handle) {
this.handle = handle;
}
private static final io.netty.util.Recycler<KeyLongValue> RECYCLER = new
io.netty.util.Recycler<KeyLongValue>() {
- protected KeyLongValue newObject(Handle handle) {
+ protected KeyLongValue newObject(Handle<KeyLongValue> handle) {
return new KeyLongValue(handle);
}
};
@@ -1261,10 +1265,12 @@ public final class PulsarApi {
this.memoizedIsInitialized = -1;
this.bitField0_ = 0;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private KeyLongValue(boolean noInit) {}
+ private KeyLongValue(boolean noInit) {
+ this.handle = null;
+ }
private static final KeyLongValue defaultInstance;
public static KeyLongValue getDefaultInstance() {
@@ -1458,20 +1464,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.KeyLongValue, Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.KeyLongValueOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.KeyLongValue.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -1681,13 +1687,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements EncryptionKeysOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use EncryptionKeys.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private EncryptionKeys(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<EncryptionKeys> handle;
+ private EncryptionKeys(io.netty.util.Recycler.Handle<EncryptionKeys>
handle) {
this.handle = handle;
}
private static final io.netty.util.Recycler<EncryptionKeys> RECYCLER =
new io.netty.util.Recycler<EncryptionKeys>() {
- protected EncryptionKeys newObject(Handle handle) {
+ protected EncryptionKeys newObject(Handle<EncryptionKeys> handle) {
return new EncryptionKeys(handle);
}
};
@@ -1697,10 +1703,12 @@ public final class PulsarApi {
this.memoizedIsInitialized = -1;
this.bitField0_ = 0;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private EncryptionKeys(boolean noInit) {}
+ private EncryptionKeys(boolean noInit) {
+ this.handle = null;
+ }
private static final EncryptionKeys defaultInstance;
public static EncryptionKeys getDefaultInstance() {
@@ -1929,20 +1937,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.EncryptionKeys, Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.EncryptionKeysOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.EncryptionKeys.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -2320,13 +2328,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements MessageMetadataOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use MessageMetadata.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private MessageMetadata(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<MessageMetadata> handle;
+ private MessageMetadata(io.netty.util.Recycler.Handle<MessageMetadata>
handle) {
this.handle = handle;
}
private static final io.netty.util.Recycler<MessageMetadata> RECYCLER =
new io.netty.util.Recycler<MessageMetadata>() {
- protected MessageMetadata newObject(Handle handle) {
+ protected MessageMetadata newObject(Handle<MessageMetadata>
handle) {
return new MessageMetadata(handle);
}
};
@@ -2336,10 +2344,12 @@ public final class PulsarApi {
this.memoizedIsInitialized = -1;
this.bitField0_ = 0;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private MessageMetadata(boolean noInit) {}
+ private MessageMetadata(boolean noInit) {
+ this.handle = null;
+ }
private static final MessageMetadata defaultInstance;
public static MessageMetadata getDefaultInstance() {
@@ -2862,20 +2872,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.MessageMetadata,
Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.MessageMetadataOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.MessageMetadata.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -3774,13 +3784,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements SingleMessageMetadataOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use SingleMessageMetadata.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private SingleMessageMetadata(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<SingleMessageMetadata> handle;
+ private
SingleMessageMetadata(io.netty.util.Recycler.Handle<SingleMessageMetadata>
handle) {
this.handle = handle;
}
private static final io.netty.util.Recycler<SingleMessageMetadata>
RECYCLER = new io.netty.util.Recycler<SingleMessageMetadata>() {
- protected SingleMessageMetadata newObject(Handle handle) {
+ protected SingleMessageMetadata
newObject(Handle<SingleMessageMetadata> handle) {
return new SingleMessageMetadata(handle);
}
};
@@ -3790,10 +3800,12 @@ public final class PulsarApi {
this.memoizedIsInitialized = -1;
this.bitField0_ = 0;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private SingleMessageMetadata(boolean noInit) {}
+ private SingleMessageMetadata(boolean noInit) {
+ this.handle = null;
+ }
private static final SingleMessageMetadata defaultInstance;
public static SingleMessageMetadata getDefaultInstance() {
@@ -4018,20 +4030,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.SingleMessageMetadata,
Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.SingleMessageMetadataOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.SingleMessageMetadata.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -4377,13 +4389,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements CommandConnectOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use CommandConnect.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private CommandConnect(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<CommandConnect> handle;
+ private CommandConnect(io.netty.util.Recycler.Handle<CommandConnect>
handle) {
this.handle = handle;
}
private static final io.netty.util.Recycler<CommandConnect> RECYCLER =
new io.netty.util.Recycler<CommandConnect>() {
- protected CommandConnect newObject(Handle handle) {
+ protected CommandConnect newObject(Handle<CommandConnect> handle) {
return new CommandConnect(handle);
}
};
@@ -4393,10 +4405,12 @@ public final class PulsarApi {
this.memoizedIsInitialized = -1;
this.bitField0_ = 0;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private CommandConnect(boolean noInit) {}
+ private CommandConnect(boolean noInit) {
+ this.handle = null;
+ }
private static final CommandConnect defaultInstance;
public static CommandConnect getDefaultInstance() {
@@ -4822,20 +4836,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.CommandConnect, Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.CommandConnectOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.CommandConnect.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -5365,13 +5379,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements CommandConnectedOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use CommandConnected.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private CommandConnected(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<CommandConnected> handle;
+ private CommandConnected(io.netty.util.Recycler.Handle<CommandConnected>
handle) {
this.handle = handle;
}
private static final io.netty.util.Recycler<CommandConnected> RECYCLER =
new io.netty.util.Recycler<CommandConnected>() {
- protected CommandConnected newObject(Handle handle) {
+ protected CommandConnected newObject(Handle<CommandConnected>
handle) {
return new CommandConnected(handle);
}
};
@@ -5381,10 +5395,12 @@ public final class PulsarApi {
this.memoizedIsInitialized = -1;
this.bitField0_ = 0;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private CommandConnected(boolean noInit) {}
+ private CommandConnected(boolean noInit) {
+ this.handle = null;
+ }
private static final CommandConnected defaultInstance;
public static CommandConnected getDefaultInstance() {
@@ -5574,20 +5590,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.CommandConnected,
Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.CommandConnectedOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.CommandConnected.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -5825,13 +5841,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements CommandSubscribeOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use CommandSubscribe.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private CommandSubscribe(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<CommandSubscribe> handle;
+ private CommandSubscribe(io.netty.util.Recycler.Handle<CommandSubscribe>
handle) {
this.handle = handle;
}
private static final io.netty.util.Recycler<CommandSubscribe> RECYCLER =
new io.netty.util.Recycler<CommandSubscribe>() {
- protected CommandSubscribe newObject(Handle handle) {
+ protected CommandSubscribe newObject(Handle<CommandSubscribe>
handle) {
return new CommandSubscribe(handle);
}
};
@@ -5841,10 +5857,12 @@ public final class PulsarApi {
this.memoizedIsInitialized = -1;
this.bitField0_ = 0;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private CommandSubscribe(boolean noInit) {}
+ private CommandSubscribe(boolean noInit) {
+ this.handle = null;
+ }
private static final CommandSubscribe defaultInstance;
public static CommandSubscribe getDefaultInstance() {
@@ -6323,20 +6341,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.CommandSubscribe,
Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.CommandSubscribeOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.CommandSubscribe.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -7032,13 +7050,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements CommandPartitionedTopicMetadataOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use CommandPartitionedTopicMetadata.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private CommandPartitionedTopicMetadata(io.netty.util.Recycler.Handle
handle) {
+ private final
io.netty.util.Recycler.Handle<CommandPartitionedTopicMetadata> handle;
+ private
CommandPartitionedTopicMetadata(io.netty.util.Recycler.Handle<CommandPartitionedTopicMetadata>
handle) {
this.handle = handle;
}
private static final
io.netty.util.Recycler<CommandPartitionedTopicMetadata> RECYCLER = new
io.netty.util.Recycler<CommandPartitionedTopicMetadata>() {
- protected CommandPartitionedTopicMetadata newObject(Handle handle)
{
+ protected CommandPartitionedTopicMetadata
newObject(Handle<CommandPartitionedTopicMetadata> handle) {
return new CommandPartitionedTopicMetadata(handle);
}
};
@@ -7048,10 +7066,12 @@ public final class PulsarApi {
this.memoizedIsInitialized = -1;
this.bitField0_ = 0;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private CommandPartitionedTopicMetadata(boolean noInit) {}
+ private CommandPartitionedTopicMetadata(boolean noInit) {
+ this.handle = null;
+ }
private static final CommandPartitionedTopicMetadata defaultInstance;
public static CommandPartitionedTopicMetadata getDefaultInstance() {
@@ -7365,20 +7385,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.CommandPartitionedTopicMetadata,
Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.CommandPartitionedTopicMetadataOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.CommandPartitionedTopicMetadata.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -7744,13 +7764,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements CommandPartitionedTopicMetadataResponseOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use CommandPartitionedTopicMetadataResponse.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private
CommandPartitionedTopicMetadataResponse(io.netty.util.Recycler.Handle handle) {
+ private final
io.netty.util.Recycler.Handle<CommandPartitionedTopicMetadataResponse> handle;
+ private
CommandPartitionedTopicMetadataResponse(io.netty.util.Recycler.Handle<CommandPartitionedTopicMetadataResponse>
handle) {
this.handle = handle;
}
private static final
io.netty.util.Recycler<CommandPartitionedTopicMetadataResponse> RECYCLER = new
io.netty.util.Recycler<CommandPartitionedTopicMetadataResponse>() {
- protected CommandPartitionedTopicMetadataResponse newObject(Handle
handle) {
+ protected CommandPartitionedTopicMetadataResponse
newObject(Handle<CommandPartitionedTopicMetadataResponse> handle) {
return new CommandPartitionedTopicMetadataResponse(handle);
}
};
@@ -7760,10 +7780,12 @@ public final class PulsarApi {
this.memoizedIsInitialized = -1;
this.bitField0_ = 0;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private CommandPartitionedTopicMetadataResponse(boolean noInit) {}
+ private CommandPartitionedTopicMetadataResponse(boolean noInit) {
+ this.handle = null;
+ }
private static final CommandPartitionedTopicMetadataResponse
defaultInstance;
public static CommandPartitionedTopicMetadataResponse getDefaultInstance()
{
@@ -8048,20 +8070,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.CommandPartitionedTopicMetadataResponse,
Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.CommandPartitionedTopicMetadataResponseOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.CommandPartitionedTopicMetadataResponse.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -8396,13 +8418,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements CommandLookupTopicOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use CommandLookupTopic.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private CommandLookupTopic(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<CommandLookupTopic> handle;
+ private
CommandLookupTopic(io.netty.util.Recycler.Handle<CommandLookupTopic> handle) {
this.handle = handle;
}
private static final io.netty.util.Recycler<CommandLookupTopic> RECYCLER
= new io.netty.util.Recycler<CommandLookupTopic>() {
- protected CommandLookupTopic newObject(Handle handle) {
+ protected CommandLookupTopic newObject(Handle<CommandLookupTopic>
handle) {
return new CommandLookupTopic(handle);
}
};
@@ -8412,10 +8434,12 @@ public final class PulsarApi {
this.memoizedIsInitialized = -1;
this.bitField0_ = 0;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private CommandLookupTopic(boolean noInit) {}
+ private CommandLookupTopic(boolean noInit) {
+ this.handle = null;
+ }
private static final CommandLookupTopic defaultInstance;
public static CommandLookupTopic getDefaultInstance() {
@@ -8747,20 +8771,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.CommandLookupTopic,
Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.CommandLookupTopicOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.CommandLookupTopic.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -9173,13 +9197,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements CommandLookupTopicResponseOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use CommandLookupTopicResponse.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private CommandLookupTopicResponse(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<CommandLookupTopicResponse>
handle;
+ private
CommandLookupTopicResponse(io.netty.util.Recycler.Handle<CommandLookupTopicResponse>
handle) {
this.handle = handle;
}
private static final io.netty.util.Recycler<CommandLookupTopicResponse>
RECYCLER = new io.netty.util.Recycler<CommandLookupTopicResponse>() {
- protected CommandLookupTopicResponse newObject(Handle handle) {
+ protected CommandLookupTopicResponse
newObject(Handle<CommandLookupTopicResponse> handle) {
return new CommandLookupTopicResponse(handle);
}
};
@@ -9189,10 +9213,12 @@ public final class PulsarApi {
this.memoizedIsInitialized = -1;
this.bitField0_ = 0;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private CommandLookupTopicResponse(boolean noInit) {}
+ private CommandLookupTopicResponse(boolean noInit) {
+ this.handle = null;
+ }
private static final CommandLookupTopicResponse defaultInstance;
public static CommandLookupTopicResponse getDefaultInstance() {
@@ -9578,20 +9604,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.CommandLookupTopicResponse,
Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.CommandLookupTopicResponseOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.CommandLookupTopicResponse.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -10063,13 +10089,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements CommandProducerOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use CommandProducer.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private CommandProducer(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<CommandProducer> handle;
+ private CommandProducer(io.netty.util.Recycler.Handle<CommandProducer>
handle) {
this.handle = handle;
}
private static final io.netty.util.Recycler<CommandProducer> RECYCLER =
new io.netty.util.Recycler<CommandProducer>() {
- protected CommandProducer newObject(Handle handle) {
+ protected CommandProducer newObject(Handle<CommandProducer>
handle) {
return new CommandProducer(handle);
}
};
@@ -10079,10 +10105,12 @@ public final class PulsarApi {
this.memoizedIsInitialized = -1;
this.bitField0_ = 0;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private CommandProducer(boolean noInit) {}
+ private CommandProducer(boolean noInit) {
+ this.handle = null;
+ }
private static final CommandProducer defaultInstance;
public static CommandProducer getDefaultInstance() {
@@ -10391,20 +10419,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.CommandProducer,
Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.CommandProducerOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.CommandProducer.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -10854,13 +10882,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements CommandSendOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use CommandSend.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private CommandSend(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<CommandSend> handle;
+ private CommandSend(io.netty.util.Recycler.Handle<CommandSend> handle) {
this.handle = handle;
}
private static final io.netty.util.Recycler<CommandSend> RECYCLER = new
io.netty.util.Recycler<CommandSend>() {
- protected CommandSend newObject(Handle handle) {
+ protected CommandSend newObject(Handle<CommandSend> handle) {
return new CommandSend(handle);
}
};
@@ -10870,10 +10898,12 @@ public final class PulsarApi {
this.memoizedIsInitialized = -1;
this.bitField0_ = 0;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private CommandSend(boolean noInit) {}
+ private CommandSend(boolean noInit) {
+ this.handle = null;
+ }
private static final CommandSend defaultInstance;
public static CommandSend getDefaultInstance() {
@@ -11063,20 +11093,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.CommandSend, Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.CommandSendOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.CommandSend.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -11304,13 +11334,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements CommandSendReceiptOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use CommandSendReceipt.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private CommandSendReceipt(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<CommandSendReceipt> handle;
+ private
CommandSendReceipt(io.netty.util.Recycler.Handle<CommandSendReceipt> handle) {
this.handle = handle;
}
private static final io.netty.util.Recycler<CommandSendReceipt> RECYCLER
= new io.netty.util.Recycler<CommandSendReceipt>() {
- protected CommandSendReceipt newObject(Handle handle) {
+ protected CommandSendReceipt newObject(Handle<CommandSendReceipt>
handle) {
return new CommandSendReceipt(handle);
}
};
@@ -11320,10 +11350,12 @@ public final class PulsarApi {
this.memoizedIsInitialized = -1;
this.bitField0_ = 0;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private CommandSendReceipt(boolean noInit) {}
+ private CommandSendReceipt(boolean noInit) {
+ this.handle = null;
+ }
private static final CommandSendReceipt defaultInstance;
public static CommandSendReceipt getDefaultInstance() {
@@ -11519,20 +11551,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.CommandSendReceipt,
Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.CommandSendReceiptOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.CommandSendReceipt.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -11797,13 +11829,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements CommandSendErrorOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use CommandSendError.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private CommandSendError(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<CommandSendError> handle;
+ private CommandSendError(io.netty.util.Recycler.Handle<CommandSendError>
handle) {
this.handle = handle;
}
private static final io.netty.util.Recycler<CommandSendError> RECYCLER =
new io.netty.util.Recycler<CommandSendError>() {
- protected CommandSendError newObject(Handle handle) {
+ protected CommandSendError newObject(Handle<CommandSendError>
handle) {
return new CommandSendError(handle);
}
};
@@ -11813,10 +11845,12 @@ public final class PulsarApi {
this.memoizedIsInitialized = -1;
this.bitField0_ = 0;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private CommandSendError(boolean noInit) {}
+ private CommandSendError(boolean noInit) {
+ this.handle = null;
+ }
private static final CommandSendError defaultInstance;
public static CommandSendError getDefaultInstance() {
@@ -12054,20 +12088,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.CommandSendError,
Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.CommandSendErrorOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.CommandSendError.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -12356,13 +12390,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements CommandMessageOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use CommandMessage.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private CommandMessage(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<CommandMessage> handle;
+ private CommandMessage(io.netty.util.Recycler.Handle<CommandMessage>
handle) {
this.handle = handle;
}
private static final io.netty.util.Recycler<CommandMessage> RECYCLER =
new io.netty.util.Recycler<CommandMessage>() {
- protected CommandMessage newObject(Handle handle) {
+ protected CommandMessage newObject(Handle<CommandMessage> handle) {
return new CommandMessage(handle);
}
};
@@ -12372,10 +12406,12 @@ public final class PulsarApi {
this.memoizedIsInitialized = -1;
this.bitField0_ = 0;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private CommandMessage(boolean noInit) {}
+ private CommandMessage(boolean noInit) {
+ this.handle = null;
+ }
private static final CommandMessage defaultInstance;
public static CommandMessage getDefaultInstance() {
@@ -12551,20 +12587,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.CommandMessage, Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.CommandMessageOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.CommandMessage.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -12798,13 +12834,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements CommandAckOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use CommandAck.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private CommandAck(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<CommandAck> handle;
+ private CommandAck(io.netty.util.Recycler.Handle<CommandAck> handle) {
this.handle = handle;
}
private static final io.netty.util.Recycler<CommandAck> RECYCLER = new
io.netty.util.Recycler<CommandAck>() {
- protected CommandAck newObject(Handle handle) {
+ protected CommandAck newObject(Handle<CommandAck> handle) {
return new CommandAck(handle);
}
};
@@ -12814,10 +12850,12 @@ public final class PulsarApi {
this.memoizedIsInitialized = -1;
this.bitField0_ = 0;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private CommandAck(boolean noInit) {}
+ private CommandAck(boolean noInit) {
+ this.handle = null;
+ }
private static final CommandAck defaultInstance;
public static CommandAck getDefaultInstance() {
@@ -13159,20 +13197,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.CommandAck, Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.CommandAckOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.CommandAck.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -13598,13 +13636,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements CommandFlowOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use CommandFlow.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private CommandFlow(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<CommandFlow> handle;
+ private CommandFlow(io.netty.util.Recycler.Handle<CommandFlow> handle) {
this.handle = handle;
}
private static final io.netty.util.Recycler<CommandFlow> RECYCLER = new
io.netty.util.Recycler<CommandFlow>() {
- protected CommandFlow newObject(Handle handle) {
+ protected CommandFlow newObject(Handle<CommandFlow> handle) {
return new CommandFlow(handle);
}
};
@@ -13614,10 +13652,12 @@ public final class PulsarApi {
this.memoizedIsInitialized = -1;
this.bitField0_ = 0;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private CommandFlow(boolean noInit) {}
+ private CommandFlow(boolean noInit) {
+ this.handle = null;
+ }
private static final CommandFlow defaultInstance;
public static CommandFlow getDefaultInstance() {
@@ -13789,20 +13829,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.CommandFlow, Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.CommandFlowOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.CommandFlow.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -13991,13 +14031,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements CommandUnsubscribeOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use CommandUnsubscribe.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private CommandUnsubscribe(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<CommandUnsubscribe> handle;
+ private
CommandUnsubscribe(io.netty.util.Recycler.Handle<CommandUnsubscribe> handle) {
this.handle = handle;
}
private static final io.netty.util.Recycler<CommandUnsubscribe> RECYCLER
= new io.netty.util.Recycler<CommandUnsubscribe>() {
- protected CommandUnsubscribe newObject(Handle handle) {
+ protected CommandUnsubscribe newObject(Handle<CommandUnsubscribe>
handle) {
return new CommandUnsubscribe(handle);
}
};
@@ -14007,10 +14047,12 @@ public final class PulsarApi {
this.memoizedIsInitialized = -1;
this.bitField0_ = 0;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private CommandUnsubscribe(boolean noInit) {}
+ private CommandUnsubscribe(boolean noInit) {
+ this.handle = null;
+ }
private static final CommandUnsubscribe defaultInstance;
public static CommandUnsubscribe getDefaultInstance() {
@@ -14182,20 +14224,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.CommandUnsubscribe,
Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.CommandUnsubscribeOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.CommandUnsubscribe.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -14388,13 +14430,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements CommandSeekOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use CommandSeek.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private CommandSeek(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<CommandSeek> handle;
+ private CommandSeek(io.netty.util.Recycler.Handle<CommandSeek> handle) {
this.handle = handle;
}
private static final io.netty.util.Recycler<CommandSeek> RECYCLER = new
io.netty.util.Recycler<CommandSeek>() {
- protected CommandSeek newObject(Handle handle) {
+ protected CommandSeek newObject(Handle<CommandSeek> handle) {
return new CommandSeek(handle);
}
};
@@ -14404,10 +14446,12 @@ public final class PulsarApi {
this.memoizedIsInitialized = -1;
this.bitField0_ = 0;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private CommandSeek(boolean noInit) {}
+ private CommandSeek(boolean noInit) {
+ this.handle = null;
+ }
private static final CommandSeek defaultInstance;
public static CommandSeek getDefaultInstance() {
@@ -14603,20 +14647,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.CommandSeek, Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.CommandSeekOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.CommandSeek.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -14869,13 +14913,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements CommandReachedEndOfTopicOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use CommandReachedEndOfTopic.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private CommandReachedEndOfTopic(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<CommandReachedEndOfTopic>
handle;
+ private
CommandReachedEndOfTopic(io.netty.util.Recycler.Handle<CommandReachedEndOfTopic>
handle) {
this.handle = handle;
}
private static final io.netty.util.Recycler<CommandReachedEndOfTopic>
RECYCLER = new io.netty.util.Recycler<CommandReachedEndOfTopic>() {
- protected CommandReachedEndOfTopic newObject(Handle handle) {
+ protected CommandReachedEndOfTopic
newObject(Handle<CommandReachedEndOfTopic> handle) {
return new CommandReachedEndOfTopic(handle);
}
};
@@ -14885,10 +14929,12 @@ public final class PulsarApi {
this.memoizedIsInitialized = -1;
this.bitField0_ = 0;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private CommandReachedEndOfTopic(boolean noInit) {}
+ private CommandReachedEndOfTopic(boolean noInit) {
+ this.handle = null;
+ }
private static final CommandReachedEndOfTopic defaultInstance;
public static CommandReachedEndOfTopic getDefaultInstance() {
@@ -15038,20 +15084,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.CommandReachedEndOfTopic, Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.CommandReachedEndOfTopicOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.CommandReachedEndOfTopic.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -15201,13 +15247,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements CommandCloseProducerOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use CommandCloseProducer.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private CommandCloseProducer(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<CommandCloseProducer> handle;
+ private
CommandCloseProducer(io.netty.util.Recycler.Handle<CommandCloseProducer>
handle) {
this.handle = handle;
}
private static final io.netty.util.Recycler<CommandCloseProducer>
RECYCLER = new io.netty.util.Recycler<CommandCloseProducer>() {
- protected CommandCloseProducer newObject(Handle handle) {
+ protected CommandCloseProducer
newObject(Handle<CommandCloseProducer> handle) {
return new CommandCloseProducer(handle);
}
};
@@ -15217,10 +15263,12 @@ public final class PulsarApi {
this.memoizedIsInitialized = -1;
this.bitField0_ = 0;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private CommandCloseProducer(boolean noInit) {}
+ private CommandCloseProducer(boolean noInit) {
+ this.handle = null;
+ }
private static final CommandCloseProducer defaultInstance;
public static CommandCloseProducer getDefaultInstance() {
@@ -15392,20 +15440,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.CommandCloseProducer,
Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.CommandCloseProducerOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.CommandCloseProducer.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -15594,13 +15642,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements CommandCloseConsumerOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use CommandCloseConsumer.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private CommandCloseConsumer(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<CommandCloseConsumer> handle;
+ private
CommandCloseConsumer(io.netty.util.Recycler.Handle<CommandCloseConsumer>
handle) {
this.handle = handle;
}
private static final io.netty.util.Recycler<CommandCloseConsumer>
RECYCLER = new io.netty.util.Recycler<CommandCloseConsumer>() {
- protected CommandCloseConsumer newObject(Handle handle) {
+ protected CommandCloseConsumer
newObject(Handle<CommandCloseConsumer> handle) {
return new CommandCloseConsumer(handle);
}
};
@@ -15610,10 +15658,12 @@ public final class PulsarApi {
this.memoizedIsInitialized = -1;
this.bitField0_ = 0;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private CommandCloseConsumer(boolean noInit) {}
+ private CommandCloseConsumer(boolean noInit) {
+ this.handle = null;
+ }
private static final CommandCloseConsumer defaultInstance;
public static CommandCloseConsumer getDefaultInstance() {
@@ -15785,20 +15835,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.CommandCloseConsumer,
Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.CommandCloseConsumerOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.CommandCloseConsumer.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -15989,13 +16039,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements CommandRedeliverUnacknowledgedMessagesOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use CommandRedeliverUnacknowledgedMessages.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private
CommandRedeliverUnacknowledgedMessages(io.netty.util.Recycler.Handle handle) {
+ private final
io.netty.util.Recycler.Handle<CommandRedeliverUnacknowledgedMessages> handle;
+ private
CommandRedeliverUnacknowledgedMessages(io.netty.util.Recycler.Handle<CommandRedeliverUnacknowledgedMessages>
handle) {
this.handle = handle;
}
private static final
io.netty.util.Recycler<CommandRedeliverUnacknowledgedMessages> RECYCLER = new
io.netty.util.Recycler<CommandRedeliverUnacknowledgedMessages>() {
- protected CommandRedeliverUnacknowledgedMessages newObject(Handle
handle) {
+ protected CommandRedeliverUnacknowledgedMessages
newObject(Handle<CommandRedeliverUnacknowledgedMessages> handle) {
return new CommandRedeliverUnacknowledgedMessages(handle);
}
};
@@ -16005,10 +16055,12 @@ public final class PulsarApi {
this.memoizedIsInitialized = -1;
this.bitField0_ = 0;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private CommandRedeliverUnacknowledgedMessages(boolean noInit) {}
+ private CommandRedeliverUnacknowledgedMessages(boolean noInit) {
+ this.handle = null;
+ }
private static final CommandRedeliverUnacknowledgedMessages
defaultInstance;
public static CommandRedeliverUnacknowledgedMessages getDefaultInstance() {
@@ -16193,20 +16245,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.CommandRedeliverUnacknowledgedMessages,
Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.CommandRedeliverUnacknowledgedMessagesOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.CommandRedeliverUnacknowledgedMessages.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -16470,13 +16522,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements CommandSuccessOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use CommandSuccess.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private CommandSuccess(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<CommandSuccess> handle;
+ private CommandSuccess(io.netty.util.Recycler.Handle<CommandSuccess>
handle) {
this.handle = handle;
}
private static final io.netty.util.Recycler<CommandSuccess> RECYCLER =
new io.netty.util.Recycler<CommandSuccess>() {
- protected CommandSuccess newObject(Handle handle) {
+ protected CommandSuccess newObject(Handle<CommandSuccess> handle) {
return new CommandSuccess(handle);
}
};
@@ -16486,10 +16538,12 @@ public final class PulsarApi {
this.memoizedIsInitialized = -1;
this.bitField0_ = 0;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private CommandSuccess(boolean noInit) {}
+ private CommandSuccess(boolean noInit) {
+ this.handle = null;
+ }
private static final CommandSuccess defaultInstance;
public static CommandSuccess getDefaultInstance() {
@@ -16639,20 +16693,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.CommandSuccess, Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.CommandSuccessOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.CommandSuccess.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -16806,13 +16860,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements CommandProducerSuccessOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use CommandProducerSuccess.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private CommandProducerSuccess(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<CommandProducerSuccess> handle;
+ private
CommandProducerSuccess(io.netty.util.Recycler.Handle<CommandProducerSuccess>
handle) {
this.handle = handle;
}
private static final io.netty.util.Recycler<CommandProducerSuccess>
RECYCLER = new io.netty.util.Recycler<CommandProducerSuccess>() {
- protected CommandProducerSuccess newObject(Handle handle) {
+ protected CommandProducerSuccess
newObject(Handle<CommandProducerSuccess> handle) {
return new CommandProducerSuccess(handle);
}
};
@@ -16822,10 +16876,12 @@ public final class PulsarApi {
this.memoizedIsInitialized = -1;
this.bitField0_ = 0;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private CommandProducerSuccess(boolean noInit) {}
+ private CommandProducerSuccess(boolean noInit) {
+ this.handle = null;
+ }
private static final CommandProducerSuccess defaultInstance;
public static CommandProducerSuccess getDefaultInstance() {
@@ -17037,20 +17093,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.CommandProducerSuccess,
Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.CommandProducerSuccessOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.CommandProducerSuccess.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -17293,13 +17349,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements CommandErrorOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use CommandError.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private CommandError(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<CommandError> handle;
+ private CommandError(io.netty.util.Recycler.Handle<CommandError> handle) {
this.handle = handle;
}
private static final io.netty.util.Recycler<CommandError> RECYCLER = new
io.netty.util.Recycler<CommandError>() {
- protected CommandError newObject(Handle handle) {
+ protected CommandError newObject(Handle<CommandError> handle) {
return new CommandError(handle);
}
};
@@ -17309,10 +17365,12 @@ public final class PulsarApi {
this.memoizedIsInitialized = -1;
this.bitField0_ = 0;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private CommandError(boolean noInit) {}
+ private CommandError(boolean noInit) {
+ this.handle = null;
+ }
private static final CommandError defaultInstance;
public static CommandError getDefaultInstance() {
@@ -17528,20 +17586,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.CommandError, Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.CommandErrorOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.CommandError.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -17783,13 +17841,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements CommandPingOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use CommandPing.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private CommandPing(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<CommandPing> handle;
+ private CommandPing(io.netty.util.Recycler.Handle<CommandPing> handle) {
this.handle = handle;
}
private static final io.netty.util.Recycler<CommandPing> RECYCLER = new
io.netty.util.Recycler<CommandPing>() {
- protected CommandPing newObject(Handle handle) {
+ protected CommandPing newObject(Handle<CommandPing> handle) {
return new CommandPing(handle);
}
};
@@ -17798,10 +17856,12 @@ public final class PulsarApi {
this.initFields();
this.memoizedIsInitialized = -1;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private CommandPing(boolean noInit) {}
+ private CommandPing(boolean noInit) {
+ this.handle = null;
+ }
private static final CommandPing defaultInstance;
public static CommandPing getDefaultInstance() {
@@ -17928,20 +17988,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.CommandPing, Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.CommandPingOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.CommandPing.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -18040,13 +18100,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements CommandPongOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use CommandPong.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private CommandPong(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<CommandPong> handle;
+ private CommandPong(io.netty.util.Recycler.Handle<CommandPong> handle) {
this.handle = handle;
}
private static final io.netty.util.Recycler<CommandPong> RECYCLER = new
io.netty.util.Recycler<CommandPong>() {
- protected CommandPong newObject(Handle handle) {
+ protected CommandPong newObject(Handle<CommandPong> handle) {
return new CommandPong(handle);
}
};
@@ -18055,10 +18115,12 @@ public final class PulsarApi {
this.initFields();
this.memoizedIsInitialized = -1;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private CommandPong(boolean noInit) {}
+ private CommandPong(boolean noInit) {
+ this.handle = null;
+ }
private static final CommandPong defaultInstance;
public static CommandPong getDefaultInstance() {
@@ -18185,20 +18247,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.CommandPong, Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.CommandPongOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.CommandPong.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -18305,13 +18367,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements CommandConsumerStatsOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use CommandConsumerStats.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private CommandConsumerStats(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<CommandConsumerStats> handle;
+ private
CommandConsumerStats(io.netty.util.Recycler.Handle<CommandConsumerStats>
handle) {
this.handle = handle;
}
private static final io.netty.util.Recycler<CommandConsumerStats>
RECYCLER = new io.netty.util.Recycler<CommandConsumerStats>() {
- protected CommandConsumerStats newObject(Handle handle) {
+ protected CommandConsumerStats
newObject(Handle<CommandConsumerStats> handle) {
return new CommandConsumerStats(handle);
}
};
@@ -18321,10 +18383,12 @@ public final class PulsarApi {
this.memoizedIsInitialized = -1;
this.bitField0_ = 0;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private CommandConsumerStats(boolean noInit) {}
+ private CommandConsumerStats(boolean noInit) {
+ this.handle = null;
+ }
private static final CommandConsumerStats defaultInstance;
public static CommandConsumerStats getDefaultInstance() {
@@ -18496,20 +18560,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.CommandConsumerStats,
Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.CommandConsumerStatsOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.CommandConsumerStats.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -18750,13 +18814,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements CommandConsumerStatsResponseOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use CommandConsumerStatsResponse.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private CommandConsumerStatsResponse(io.netty.util.Recycler.Handle handle)
{
+ private final io.netty.util.Recycler.Handle<CommandConsumerStatsResponse>
handle;
+ private
CommandConsumerStatsResponse(io.netty.util.Recycler.Handle<CommandConsumerStatsResponse>
handle) {
this.handle = handle;
}
private static final io.netty.util.Recycler<CommandConsumerStatsResponse>
RECYCLER = new io.netty.util.Recycler<CommandConsumerStatsResponse>() {
- protected CommandConsumerStatsResponse newObject(Handle handle) {
+ protected CommandConsumerStatsResponse
newObject(Handle<CommandConsumerStatsResponse> handle) {
return new CommandConsumerStatsResponse(handle);
}
};
@@ -18766,10 +18830,12 @@ public final class PulsarApi {
this.memoizedIsInitialized = -1;
this.bitField0_ = 0;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private CommandConsumerStatsResponse(boolean noInit) {}
+ private CommandConsumerStatsResponse(boolean noInit) {
+ this.handle = null;
+ }
private static final CommandConsumerStatsResponse defaultInstance;
public static CommandConsumerStatsResponse getDefaultInstance() {
@@ -19281,20 +19347,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.CommandConsumerStatsResponse,
Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.CommandConsumerStatsResponseOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.CommandConsumerStatsResponse.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
@@ -20120,13 +20186,13 @@ public final class PulsarApi {
com.google.protobuf.GeneratedMessageLite
implements BaseCommandOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedOutputStream.ByteBufGeneratedMessage
{
// Use BaseCommand.newBuilder() to construct.
- private io.netty.util.Recycler.Handle handle;
- private BaseCommand(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<BaseCommand> handle;
+ private BaseCommand(io.netty.util.Recycler.Handle<BaseCommand> handle) {
this.handle = handle;
}
private static final io.netty.util.Recycler<BaseCommand> RECYCLER = new
io.netty.util.Recycler<BaseCommand>() {
- protected BaseCommand newObject(Handle handle) {
+ protected BaseCommand newObject(Handle<BaseCommand> handle) {
return new BaseCommand(handle);
}
};
@@ -20136,10 +20202,12 @@ public final class PulsarApi {
this.memoizedIsInitialized = -1;
this.bitField0_ = 0;
this.memoizedSerializedSize = -1;
- if (handle != null) { RECYCLER.recycle(this, handle); }
+ handle.recycle(this);
}
- private BaseCommand(boolean noInit) {}
+ private BaseCommand(boolean noInit) {
+ this.handle = null;
+ }
private static final BaseCommand defaultInstance;
public static BaseCommand getDefaultInstance() {
@@ -21041,20 +21109,20 @@ public final class PulsarApi {
org.apache.pulsar.common.api.proto.PulsarApi.BaseCommand, Builder>
implements
org.apache.pulsar.common.api.proto.PulsarApi.BaseCommandOrBuilder,
org.apache.pulsar.common.util.protobuf.ByteBufCodedInputStream.ByteBufMessageBuilder
{
// Construct using
org.apache.pulsar.common.api.proto.PulsarApi.BaseCommand.newBuilder()
- private final io.netty.util.Recycler.Handle handle;
- private Builder(io.netty.util.Recycler.Handle handle) {
+ private final io.netty.util.Recycler.Handle<Builder> handle;
+ private Builder(io.netty.util.Recycler.Handle<Builder> handle) {
this.handle = handle;
maybeForceBuilderInitialization();
}
private final static io.netty.util.Recycler<Builder> RECYCLER = new
io.netty.util.Recycler<Builder>() {
- protected Builder newObject(io.netty.util.Recycler.Handle handle) {
+ protected Builder newObject(io.netty.util.Recycler.Handle<Builder>
handle) {
return new Builder(handle);
}
};
public void recycle() {
clear();
- if (handle != null) {RECYCLER.recycle(this, handle);}
+ handle.recycle(this);
}
private void maybeForceBuilderInitialization() {
--
To stop receiving notification emails like this one, please contact
mme...@apache.org.
