Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Make some STOMP fields final

This commit is contained in:
Ville Skyttä 2015-07-20 10:32:56 +03:00 committed by Clebert Suconic
parent 5c4511b59f
commit 45d1601334
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/SimpleBytes.java
View File

@ -21,7 +21,7 @@ import java.nio.charset.StandardCharsets;
public class SimpleBytes public class SimpleBytes
{ {
private int step; private final int step;
private byte[] contents; private byte[] contents;
private int index; private int index;

2
artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompConnection.java
View File

@ -92,7 +92,7 @@ public final class StompConnection implements RemotingConnection
private final Object sendLock = new Object(); private final Object sendLock = new Object();
private int minLargeMessageSize; private final int minLargeMessageSize;
public StompFrame decode(ActiveMQBuffer buffer) throws ActiveMQStompException public StompFrame decode(ActiveMQBuffer buffer) throws ActiveMQStompException
{ {

2
artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompProtocolManagerFactory.java
View File

@ -29,7 +29,7 @@ public class StompProtocolManagerFactory extends AbstractProtocolManagerFactory<
private static final String MODULE_NAME = "artemis-stomp-protocol"; private static final String MODULE_NAME = "artemis-stomp-protocol";
private static String[] SUPPORTED_PROTOCOLS = {STOMP_PROTOCOL_NAME}; private static final String[] SUPPORTED_PROTOCOLS = {STOMP_PROTOCOL_NAME};
public ProtocolManager createProtocolManager(final ActiveMQServer server, final List<StompFrameInterceptor> incomingInterceptors, List<StompFrameInterceptor> outgoingInterceptors) public ProtocolManager createProtocolManager(final ActiveMQServer server, final List<StompFrameInterceptor> incomingInterceptors, List<StompFrameInterceptor> outgoingInterceptors)
{ {