-
Notifications
You must be signed in to change notification settings - Fork 187
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
General message engineering in Producer #559
Conversation
f"endpoints={endpoints}, messageId={message.message_id}, clientId={self.client_id}") | ||
raise | ||
|
||
if not isinstance(exception, TooManyRequestsException): |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
where is TooManyRequestsException
?
python/rocketmq/producer.py
Outdated
f"endpoints={endpoints}, messageId={message.message_id}, clientId={self.client_id}") | ||
raise | ||
|
||
if message.message_type == "Transaction": |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Enumeration should be used here.
python/rocketmq/client.py
Outdated
logger.info("finish") | ||
break | ||
except Exception as e: | ||
logger.error(f"[Bug] unexpected exception raised during heartbeat, clientId={self.client_id}, Exception: {str(e)}") | ||
|
||
def GetTotalRouteEndpoints(self): |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Please use snake case naming rather than camel naming.
python/rocketmq/client.py
Outdated
def get_client_config(self): | ||
""" | ||
Method to return client configuration. | ||
""" | ||
return self.client_config | ||
|
||
async def OnTopicRouteDataFetched(self, topic, topicRouteData): |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Fix the naming issue...
Brief Description
Regular heartbeat
done
Telemetry performs abnormal recovery
done
The retry of message sending
done
Failed node isolation
done
transaction & delay & fifo message
done
How Did You Test This Change?
run 4 tests in producer.py & test heartbeat & telemetry rebuild by hands