You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@geode.apache.org by GitBox <gi...@apache.org> on 2022/05/24 17:13:07 UTC
[GitHub] [geode] pivotal-jbarrett commented on a diff in pull request #7688: GEODE-10326: Convert MessageType to enum.
pivotal-jbarrett commented on code in PR #7688:
URL: https://github.com/apache/geode/pull/7688#discussion_r880764715
##########
geode-core/src/main/java/org/apache/geode/internal/cache/tier/MessageType.java:
##########
@@ -229,387 +235,209 @@ public class MessageType {
*
* @since GemFire 4.1.1
*/
- public static final int QUERY = 34;
+ QUERY(34),
- public static final int QUERY_DATA_ERROR = 35;
+ QUERY_DATA_ERROR(35),
- public static final int CLEAR_REGION = 36;
+ CLEAR_REGION(36),
- public static final int CLEAR_REGION_DATA_ERROR = 37;
+ CLEAR_REGION_DATA_ERROR(37),
- public static final int CONTAINS_KEY = 38;
+ CONTAINS_KEY(38),
- public static final int CONTAINS_KEY_DATA_ERROR = 39;
+ CONTAINS_KEY_DATA_ERROR(39),
- public static final int KEY_SET = 40;
+ KEY_SET(40),
- public static final int KEY_SET_DATA_ERROR = 41;
+ KEY_SET_DATA_ERROR(41),
- public static final int EXECUTECQ_MSG_TYPE = 42;
+ EXECUTECQ_MSG_TYPE(42),
- public static final int EXECUTECQ_WITH_IR_MSG_TYPE = 43;
+ EXECUTECQ_WITH_IR_MSG_TYPE(43),
- public static final int STOPCQ_MSG_TYPE = 44;
+ STOPCQ_MSG_TYPE(44),
- public static final int CLOSECQ_MSG_TYPE = 45;
+ CLOSECQ_MSG_TYPE(45),
- public static final int CLOSECLIENTCQS_MSG_TYPE = 46;
+ CLOSECLIENTCQS_MSG_TYPE(46),
- public static final int CQDATAERROR_MSG_TYPE = 47;
+ CQDATAERROR_MSG_TYPE(47),
- public static final int GETCQSTATS_MSG_TYPE = 48;
+ GETCQSTATS_MSG_TYPE(48),
- public static final int MONITORCQ_MSG_TYPE = 49;
+ MONITORCQ_MSG_TYPE(49),
- public static final int CQ_EXCEPTION_TYPE = 50;
+ CQ_EXCEPTION_TYPE(50),
/**
* A message to register the Instantiators.
*
* @since GemFire 5.0
*/
- public static final int REGISTER_INSTANTIATORS = 51;
+ REGISTER_INSTANTIATORS(51),
- public static final int PERIODIC_ACK = 52;
+ PERIODIC_ACK(52),
- public static final int CLIENT_READY = 53;
+ CLIENT_READY(53),
- public static final int CLIENT_MARKER = 54;
+ CLIENT_MARKER(54),
- public static final int INVALIDATE_REGION = 55;
+ INVALIDATE_REGION(55),
- public static final int PUTALL = 56;
+ PUTALL(56),
- public static final int GET_ALL_DATA_ERROR = 58;
+ GET_ALL_DATA_ERROR(58),
- public static final int EXECUTE_REGION_FUNCTION = 59;
+ EXECUTE_REGION_FUNCTION(59),
- public static final int EXECUTE_REGION_FUNCTION_RESULT = 60;
+ EXECUTE_REGION_FUNCTION_RESULT(60),
- public static final int EXECUTE_REGION_FUNCTION_ERROR = 61;
+ EXECUTE_REGION_FUNCTION_ERROR(61),
- public static final int EXECUTE_FUNCTION = 62;
+ EXECUTE_FUNCTION(62),
- public static final int EXECUTE_FUNCTION_RESULT = 63;
+ EXECUTE_FUNCTION_RESULT(63),
- public static final int EXECUTE_FUNCTION_ERROR = 64;
+ EXECUTE_FUNCTION_ERROR(64),
- public static final int CLIENT_REGISTER_INTEREST = 65;
+ CLIENT_REGISTER_INTEREST(65),
- public static final int CLIENT_UNREGISTER_INTEREST = 66;
+ CLIENT_UNREGISTER_INTEREST(66),
- public static final int REGISTER_DATASERIALIZERS = 67;
+ REGISTER_DATASERIALIZERS(67),
- public static final int REQUEST_EVENT_VALUE = 68;
+ REQUEST_EVENT_VALUE(68),
- public static final int REQUEST_EVENT_VALUE_ERROR = 69;
+ REQUEST_EVENT_VALUE_ERROR(69),
- public static final int PUT_DELTA_ERROR = 70;
+ PUT_DELTA_ERROR(70),
- public static final int GET_CLIENT_PR_METADATA = 71;
+ GET_CLIENT_PR_METADATA(71),
- public static final int RESPONSE_CLIENT_PR_METADATA = 72;
+ RESPONSE_CLIENT_PR_METADATA(72),
- public static final int GET_CLIENT_PARTITION_ATTRIBUTES = 73;
+ GET_CLIENT_PARTITION_ATTRIBUTES(73),
- public static final int RESPONSE_CLIENT_PARTITION_ATTRIBUTES = 74;
+ RESPONSE_CLIENT_PARTITION_ATTRIBUTES(74),
- public static final int GET_CLIENT_PR_METADATA_ERROR = 75;
+ GET_CLIENT_PR_METADATA_ERROR(75),
- public static final int GET_CLIENT_PARTITION_ATTRIBUTES_ERROR = 76;
+ GET_CLIENT_PARTITION_ATTRIBUTES_ERROR(76),
- public static final int USER_CREDENTIAL_MESSAGE = 77;
+ USER_CREDENTIAL_MESSAGE(77),
- public static final int REMOVE_USER_AUTH = 78;
+ REMOVE_USER_AUTH(78),
- public static final int EXECUTE_REGION_FUNCTION_SINGLE_HOP = 79;
+ EXECUTE_REGION_FUNCTION_SINGLE_HOP(79),
- public static final int QUERY_WITH_PARAMETERS = 80;
+ QUERY_WITH_PARAMETERS(80),
- public static final int SIZE = 81;
- public static final int SIZE_ERROR = 82;
+ SIZE(81),
+ SIZE_ERROR(82),
- public static final int INVALIDATE = 83;
- public static final int INVALIDATE_ERROR = 84;
+ INVALIDATE(83),
+ INVALIDATE_ERROR(84),
- public static final int COMMIT = 85;
- public static final int COMMIT_ERROR = 86;
+ COMMIT(85),
+ COMMIT_ERROR(86),
- public static final int ROLLBACK = 87;
+ ROLLBACK(87),
- public static final int TX_FAILOVER = 88;
+ TX_FAILOVER(88),
- public static final int GET_ENTRY = 89;
+ GET_ENTRY(89),
- public static final int TX_SYNCHRONIZATION = 90;
+ TX_SYNCHRONIZATION(90),
- public static final int GET_FUNCTION_ATTRIBUTES = 91;
+ GET_FUNCTION_ATTRIBUTES(91),
- public static final int GET_PDX_TYPE_BY_ID = 92;
+ GET_PDX_TYPE_BY_ID(92),
- public static final int GET_PDX_ID_FOR_TYPE = 93;
+ GET_PDX_ID_FOR_TYPE(93),
- public static final int ADD_PDX_TYPE = 94;
+ ADD_PDX_TYPE(94),
- public static final int GET_ALL_FOR_RI = 95; // this message type is not used after 6.x
+ GET_ALL_FOR_RI(95), // this message type is not used after 6.x
- public static final int ADD_PDX_ENUM = 96;
- public static final int GET_PDX_ID_FOR_ENUM = 97;
- public static final int GET_PDX_ENUM_BY_ID = 98;
+ ADD_PDX_ENUM(96),
+ GET_PDX_ID_FOR_ENUM(97),
+ GET_PDX_ENUM_BY_ID(98),
- public static final int SERVER_TO_CLIENT_PING = 99;
+ SERVER_TO_CLIENT_PING(99),
- public static final int GET_ALL_70 = 100;
+ GET_ALL_70(100),
/** gets the pdx type definitions @since GemFire 7.0 */
- public static final int GET_PDX_TYPES = 101;
+ GET_PDX_TYPES(101),
/** gets the pdx enum definitions @since GemFire 7.0 */
- public static final int GET_PDX_ENUMS = 102;
+ GET_PDX_ENUMS(102),
- public static final int TOMBSTONE_OPERATION = 103;
+ TOMBSTONE_OPERATION(103),
- public static final int GATEWAY_RECEIVER_COMMAND = 104;
+ GATEWAY_RECEIVER_COMMAND(104),
- public static final int GETDURABLECQS_MSG_TYPE = 105;
+ GETDURABLECQS_MSG_TYPE(105),
- public static final int GET_DURABLE_CQS_DATA_ERROR = 106;
+ GET_DURABLE_CQS_DATA_ERROR(106),
- public static final int GET_ALL_WITH_CALLBACK = 107;
+ GET_ALL_WITH_CALLBACK(107),
- public static final int PUT_ALL_WITH_CALLBACK = 108;
+ PUT_ALL_WITH_CALLBACK(108),
- public static final int REMOVE_ALL = 109;
+ REMOVE_ALL(109),
/**
* @since Geode 1.15
*/
- public static final int CLIENT_RE_AUTHENTICATE = 110;
- /**
- * Must be equal to last valid message id.
- */
- private static final int LAST_VALID_MESSAGE_ID = CLIENT_RE_AUTHENTICATE;
+ CLIENT_RE_AUTHENTICATE(110);
+
+
+ public final int id;
+
+ MessageType(final int id) {
+ this.id = id;
+ }
+ @Immutable
+ private static final MessageType[] messageTypes = new MessageType[111];
Review Comment:
Ah, but the `values.length() != 111`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: notifications-unsubscribe@geode.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org