-
Notifications
You must be signed in to change notification settings - Fork 3
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
Queue and Topic depths #14
Conversation
try { | ||
return processQueueControl(connector, brokerName, destination, fn); | ||
} catch (Exception e) { | ||
throw new RuntimeException(e); |
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.
try { | ||
return processTopicControl(connector, brokerName, destination, fn); | ||
} catch (Exception e) { | ||
throw new RuntimeException(e); |
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.
@@ -14,4 +15,8 @@ | |||
String[] queueNames(final String host, final String port, final String brokerName) throws Exception; | |||
|
|||
String[] topicNames(final String host, final String port, final String brokerName) throws Exception; | |||
|
|||
Map<String, Long> queueMessageCount(final String host, final String port, final String brokerName, final String[] queueNames) throws Exception; |
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.
|
||
Map<String, Long> queueMessageCount(final String host, final String port, final String brokerName, final String[] queueNames) throws Exception; | ||
|
||
Map<String, Long> topicMessageCount(final String host, final String port, final String brokerName, final String[] topicNames) throws Exception; |
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.
map.entrySet().stream().sorted(Map.Entry.comparingByKey()).forEach( | ||
entry -> arrayBuilder.add(this.toJsonObject(entry, valueName)) | ||
); | ||
System.out.println(arrayBuilder.build().toString()); |
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.
0ae8137
to
f558a64
Compare
- Use the generic functional interface for server control - Correct the connection startup / teardown process - Tests for messageCounts for queues and topics
f558a64
to
b64c639
Compare
Provide commands to get the messageCount of all queues and topics