Skip to content

Commit

Permalink
[Java] More tidy up after merge of PR #650.
Browse files Browse the repository at this point in the history
  • Loading branch information
mjpt777 committed Mar 28, 2019
1 parent a61fd2e commit d8cf205
Show file tree
Hide file tree
Showing 3 changed files with 27 additions and 7 deletions.
20 changes: 20 additions & 0 deletions aeron-samples/scripts/backlog-stat
Original file line number Diff line number Diff line change
@@ -0,0 +1,20 @@
#!/usr/bin/env bash
##
## Copyright 2014-2019 Real Logic Ltd.
##
## Licensed under the Apache License, Version 2.0 (the "License");
## you may not use this file except in compliance with the License.
## You may obtain a copy of the License at
##
## http://www.apache.org/licenses/LICENSE-2.0
##
## Unless required by applicable law or agreed to in writing, software
## distributed under the License is distributed on an "AS IS" BASIS,
## WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
## See the License for the specific language governing permissions and
## limitations under the License.
##

${JAVA_HOME}/bin/java \
-cp ../build/libs/samples.jar \
${JVM_OPTS} io.aeron.samples.BacklogStat
2 changes: 1 addition & 1 deletion aeron-samples/scripts/backlog-stat.bat
Original file line number Diff line number Diff line change
Expand Up @@ -17,4 +17,4 @@
@echo off
"%JAVA_HOME%\bin\java" ^
-cp ..\build\libs\samples.jar ^
%JVM_OPTS% io.aeron.samples.BacklogStat %*
%JVM_OPTS% io.aeron.samples.BacklogStat
12 changes: 6 additions & 6 deletions aeron-samples/src/main/java/io/aeron/samples/BacklogStat.java
Original file line number Diff line number Diff line change
Expand Up @@ -56,9 +56,9 @@ public class BacklogStat
public static void main(final String[] args)
{
final CountersReader counters = SamplesUtil.mapCounters();
final BacklogStat streamStat = new BacklogStat(counters);
final BacklogStat backlogStat = new BacklogStat(counters);

streamStat.print(System.out);
backlogStat.print(System.out);
}

public BacklogStat(final CountersReader counters)
Expand All @@ -67,9 +67,9 @@ public BacklogStat(final CountersReader counters)
}

/**
* Take a snapshot of all the backlog information and group by streams.
* Take a snapshot of all the backlog information and group by stream.
*
* @return a snapshot of all the backlog information and group by streams.
* @return a snapshot of all the backlog information and group by stream.
*/
public Map<StreamCompositeKey, StreamBacklog> snapshot()
{
Expand Down Expand Up @@ -134,7 +134,7 @@ public Map<StreamCompositeKey, StreamBacklog> snapshot()
/**
* Print a snapshot of the stream backlog with some explanation to a {@link PrintStream}.
* <p>
* Each stream will be printed on its own section.
* Each stream will be printed in its own section.
*
* @param out to which the stream backlog will be written.
*/
Expand Down Expand Up @@ -291,7 +291,7 @@ public String toString()
}

/**
* Represents a backlog info for a particular stream of messages.
* Represents the backlog information for a particular stream of messages.
*/
public static class StreamBacklog
{
Expand Down

0 comments on commit d8cf205

Please sign in to comment.