Skip to content

Commit 70db754

Browse files
SequenceTimeMessageBodySource => TimeSequenceMessageBodySource
1 parent 4382295 commit 70db754

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

src/main/java/com/rabbitmq/perf/MulticastParams.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -227,7 +227,7 @@ public Producer createProducer(Connection connection, Stats stats, String id) th
227227
if (bodyFiles.size() > 0) {
228228
messageBodySource = new LocalFilesMessageBodySource(bodyFiles, bodyContentType);
229229
} else {
230-
messageBodySource = new SequenceTimeMessageBodySource(minMsgSize);
230+
messageBodySource = new TimeSequenceMessageBodySource(minMsgSize);
231231
}
232232
final Producer producer = new Producer(channel, exchangeName, id,
233233
randomRoutingKey, flags, producerTxSize,

src/main/java/com/rabbitmq/perf/SequenceTimeMessageBodySource.java renamed to src/main/java/com/rabbitmq/perf/TimeSequenceMessageBodySource.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,11 +22,11 @@
2222
/**
2323
*
2424
*/
25-
public class SequenceTimeMessageBodySource implements MessageBodySource {
25+
public class TimeSequenceMessageBodySource implements MessageBodySource {
2626

2727
private final byte[] message;
2828

29-
public SequenceTimeMessageBodySource(int minMsgSize) {
29+
public TimeSequenceMessageBodySource(int minMsgSize) {
3030
this.message = new byte[minMsgSize];
3131
}
3232

0 commit comments

Comments
 (0)