You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2017/05/15 14:52:05 UTC
activemq-artemis git commit: ARTEMIS-1160 Fixing Checkstyle
Repository: activemq-artemis
Updated Branches:
refs/heads/master 47e0cffc9 -> 502f9c544
ARTEMIS-1160 Fixing Checkstyle
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/502f9c54
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/502f9c54
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/502f9c54
Branch: refs/heads/master
Commit: 502f9c544c8ba6e18d1164dd7ebb3b9ec9a6ef28
Parents: 47e0cff
Author: Clebert Suconic <cl...@apache.org>
Authored: Mon May 15 10:52:05 2017 -0400
Committer: Clebert Suconic <cl...@apache.org>
Committed: Mon May 15 10:52:05 2017 -0400
----------------------------------------------------------------------
.../amqp/client/transport/NettyTcpTransport.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/502f9c54/tests/artemis-test-support/src/main/java/org/apache/activemq/transport/amqp/client/transport/NettyTcpTransport.java
----------------------------------------------------------------------
diff --git a/tests/artemis-test-support/src/main/java/org/apache/activemq/transport/amqp/client/transport/NettyTcpTransport.java b/tests/artemis-test-support/src/main/java/org/apache/activemq/transport/amqp/client/transport/NettyTcpTransport.java
index 247dd84..7ce3bb9 100644
--- a/tests/artemis-test-support/src/main/java/org/apache/activemq/transport/amqp/client/transport/NettyTcpTransport.java
+++ b/tests/artemis-test-support/src/main/java/org/apache/activemq/transport/amqp/client/transport/NettyTcpTransport.java
@@ -269,16 +269,16 @@ public class NettyTcpTransport implements NettyTransport {
@Override
public void setMaxFrameSize(int maxFrameSize) {
- if (connected.get()) {
- throw new IllegalStateException("Cannot change Max Frame Size while connected.");
- }
+ if (connected.get()) {
+ throw new IllegalStateException("Cannot change Max Frame Size while connected.");
+ }
- this.maxFrameSize = maxFrameSize;
+ this.maxFrameSize = maxFrameSize;
}
@Override
public int getMaxFrameSize() {
- return maxFrameSize;
+ return maxFrameSize;
}
// ----- Internal implementation details, can be overridden as needed -----//