in lib/Commands.cc [640:812]
std::string Commands::messageType(BaseCommand_Type type) {
switch (type) {
case BaseCommand::CONNECT:
return "CONNECT";
break;
case BaseCommand::CONNECTED:
return "CONNECTED";
break;
case BaseCommand::SUBSCRIBE:
return "SUBSCRIBE";
break;
case BaseCommand::PRODUCER:
return "PRODUCER";
break;
case BaseCommand::SEND:
return "SEND";
break;
case BaseCommand::SEND_RECEIPT:
return "SEND_RECEIPT";
break;
case BaseCommand::SEND_ERROR:
return "SEND_ERROR";
break;
case BaseCommand::MESSAGE:
return "MESSAGE";
break;
case BaseCommand::ACK:
return "ACK";
break;
case BaseCommand::FLOW:
return "FLOW";
break;
case BaseCommand::UNSUBSCRIBE:
return "UNSUBSCRIBE";
break;
case BaseCommand::SUCCESS:
return "SUCCESS";
break;
case BaseCommand::ERROR:
return "ERROR";
break;
case BaseCommand::CLOSE_PRODUCER:
return "CLOSE_PRODUCER";
break;
case BaseCommand::CLOSE_CONSUMER:
return "CLOSE_CONSUMER";
break;
case BaseCommand::PRODUCER_SUCCESS:
return "PRODUCER_SUCCESS";
break;
case BaseCommand::PING:
return "PING";
break;
case BaseCommand::PONG:
return "PONG";
break;
case BaseCommand::PARTITIONED_METADATA:
return "PARTITIONED_METADATA";
break;
case BaseCommand::PARTITIONED_METADATA_RESPONSE:
return "PARTITIONED_METADATA_RESPONSE";
break;
case BaseCommand::REDELIVER_UNACKNOWLEDGED_MESSAGES:
return "REDELIVER_UNACKNOWLEDGED_MESSAGES";
break;
case BaseCommand::LOOKUP:
return "LOOKUP";
break;
case BaseCommand::LOOKUP_RESPONSE:
return "LOOKUP_RESPONSE";
break;
case BaseCommand::CONSUMER_STATS:
return "CONSUMER_STATS";
break;
case BaseCommand::CONSUMER_STATS_RESPONSE:
return "CONSUMER_STATS_RESPONSE";
break;
case BaseCommand::REACHED_END_OF_TOPIC:
return "REACHED_END_OF_TOPIC";
break;
case BaseCommand::SEEK:
return "SEEK";
break;
case BaseCommand::ACTIVE_CONSUMER_CHANGE:
return "ACTIVE_CONSUMER_CHANGE";
break;
case BaseCommand::GET_LAST_MESSAGE_ID:
return "GET_LAST_MESSAGE_ID";
break;
case BaseCommand::GET_LAST_MESSAGE_ID_RESPONSE:
return "GET_LAST_MESSAGE_ID_RESPONSE";
break;
case BaseCommand::GET_TOPICS_OF_NAMESPACE:
return "GET_TOPICS_OF_NAMESPACE";
break;
case BaseCommand::GET_TOPICS_OF_NAMESPACE_RESPONSE:
return "GET_TOPICS_OF_NAMESPACE_RESPONSE";
break;
case BaseCommand::GET_SCHEMA:
return "GET_SCHEMA";
break;
case BaseCommand::GET_SCHEMA_RESPONSE:
return "GET_SCHEMA_RESPONSE";
break;
case BaseCommand::AUTH_CHALLENGE:
return "AUTH_CHALLENGE";
break;
case BaseCommand::AUTH_RESPONSE:
return "AUTH_RESPONSE";
break;
case BaseCommand::ACK_RESPONSE:
return "ACK_RESPONSE";
break;
case BaseCommand::GET_OR_CREATE_SCHEMA:
return "GET_OR_CREATE_SCHEMA";
case BaseCommand::GET_OR_CREATE_SCHEMA_RESPONSE:
return "GET_OR_CREATE_SCHEMA_RESPONSE";
case BaseCommand::NEW_TXN:
return "NEW_TXN";
break;
case BaseCommand::NEW_TXN_RESPONSE:
return "NEW_TXN_RESPONSE";
break;
case BaseCommand::ADD_PARTITION_TO_TXN:
return "ADD_PARTITION_TO_TXN";
break;
case BaseCommand::ADD_PARTITION_TO_TXN_RESPONSE:
return "ADD_PARTITION_TO_TXN_RESPONSE";
break;
case BaseCommand::ADD_SUBSCRIPTION_TO_TXN:
return "ADD_SUBSCRIPTION_TO_TXN";
break;
case BaseCommand::ADD_SUBSCRIPTION_TO_TXN_RESPONSE:
return "ADD_SUBSCRIPTION_TO_TXN_RESPONSE";
break;
case BaseCommand::END_TXN:
return "END_TXN";
break;
case BaseCommand::END_TXN_RESPONSE:
return "END_TXN_RESPONSE";
break;
case BaseCommand::END_TXN_ON_PARTITION:
return "END_TXN_ON_PARTITION";
break;
case BaseCommand::END_TXN_ON_PARTITION_RESPONSE:
return "END_TXN_ON_PARTITION_RESPONSE";
break;
case BaseCommand::END_TXN_ON_SUBSCRIPTION:
return "END_TXN_ON_SUBSCRIPTION";
break;
case BaseCommand::END_TXN_ON_SUBSCRIPTION_RESPONSE:
return "END_TXN_ON_SUBSCRIPTION_RESPONSE";
break;
case BaseCommand::TC_CLIENT_CONNECT_REQUEST:
return "TC_CLIENT_CONNECT_REQUEST";
case BaseCommand::TC_CLIENT_CONNECT_RESPONSE:
return "TC_CLIENT_CONNECT_RESPONSE";
break;
case BaseCommand::WATCH_TOPIC_LIST:
return "WATCH_TOPIC_LIST";
break;
case BaseCommand::WATCH_TOPIC_LIST_SUCCESS:
return "WATCH_TOPIC_LIST_SUCCESS";
break;
case BaseCommand::WATCH_TOPIC_UPDATE:
return "WATCH_TOPIC_UPDATE";
break;
case BaseCommand::WATCH_TOPIC_LIST_CLOSE:
return "WATCH_TOPIC_LIST_CLOSE";
break;
};
BOOST_THROW_EXCEPTION(std::logic_error("Invalid BaseCommand enumeration value"));
}